Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -52,19 +52,30 @@ public final class MqttMessages {
public static final String PAYLOAD_INVALID = "payload is invalidate";

private MqttMessages() {}

// ---------------------------------------------------------------------------
// Additional auto-collected messages
// ---------------------------------------------------------------------------
public static final String LOG_LINE_PATTERN_PARSING_FAILS_FAILED_LINE_MESSAGE_ARG_EXCEPTION_6EFB0EE2 = "The line pattern parsing fails, and the failed line message is {} ,exception is";
public static final String LOG_CONNECTION_REFUSED_CLIENT_ID_MISSING_EMPTY_VALID_CLIENT_ID_REQUIRED_A566DC15 =
"Connection refused: client_id is missing or empty. A valid client_id is required to establish"
+ " a connection.";
public static final String LOG_RECEIVE_PUBLISH_MESSAGE_CLIENTID_ARG_USERNAME_ARG_QOS_ARG_TOPIC_7E60C3A6 = "Receive publish message. clientId: {}, username: {}, qos: {}, topic: {}, payload: {}";
public static final String LOG_MQTT_JSON_INSERT_ERROR_CODE_ARG_MESSAGE_ARG_B1A78FBD = "mqtt json insert error, code={}, message={}";
public static final String LOG_MEET_ERROR_INSERTING_DATABASE_ARG_TABLE_ARG_TAGS_ARG_ATTRIBUTES_173457D5 =
"meet error when inserting database {}, table {}, tags {}, attributes {}, fields {}, at time"
+ " {}, because ";
public static final String LOG_MEET_ERROR_INSERTING_DEVICE_ARG_MEASUREMENTS_ARG_AT_TIME_ARG_680D67D2 = "meet error when inserting device {}, measurements {}, at time {}, because ";
public static final String LOG_START_MQTT_SERVICE_SUCCESSFULLY_LISTENING_IP_ARG_PORT_ARG_47CE46D5 = "Start MQTT service successfully, listening on ip {} port {}";

public static final String
LOG_LINE_PATTERN_PARSING_FAILS_FAILED_LINE_MESSAGE_ARG_EXCEPTION_6EFB0EE2 =
"The line pattern parsing fails, and the failed line message is {} ,exception is";
public static final String
LOG_CONNECTION_REFUSED_CLIENT_ID_MISSING_EMPTY_VALID_CLIENT_ID_REQUIRED_A566DC15 =
"Connection refused: client_id is missing or empty. A valid client_id is required to establish"
+ " a connection.";
public static final String
LOG_RECEIVE_PUBLISH_MESSAGE_CLIENTID_ARG_USERNAME_ARG_QOS_ARG_TOPIC_7E60C3A6 =
"Receive publish message. clientId: {}, username: {}, qos: {}, topic: {}, payload: {}";
public static final String LOG_MQTT_JSON_INSERT_ERROR_CODE_ARG_MESSAGE_ARG_B1A78FBD =
"mqtt json insert error, code={}, message={}";
public static final String
LOG_MEET_ERROR_INSERTING_DATABASE_ARG_TABLE_ARG_TAGS_ARG_ATTRIBUTES_173457D5 =
"meet error when inserting database {}, table {}, tags {}, attributes {}, fields {}, at time"
+ " {}, because ";
public static final String
LOG_MEET_ERROR_INSERTING_DEVICE_ARG_MEASUREMENTS_ARG_AT_TIME_ARG_680D67D2 =
"meet error when inserting device {}, measurements {}, at time {}, because ";
public static final String
LOG_START_MQTT_SERVICE_SUCCESSFULLY_LISTENING_IP_ARG_PORT_ARG_47CE46D5 =
"Start MQTT service successfully, listening on ip {} port {}";
}
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,7 @@ public final class MqttMessages {
public static final String TIMESTAMP_ERROR = "时间戳格式错误,行内容:{}";

// --- MPPPublishHandler ---
public static final String ON_PUBLISH_EXCEPTION =
"onPublish 执行异常,消息为 [{}],错误:";
public static final String ON_PUBLISH_EXCEPTION = "onPublish 执行异常,消息为 [{}],错误:";
public static final String PROCESS_RESULT = "处理结果:{}";

// --- MQTTService ---
Expand All @@ -43,24 +42,36 @@ public final class MqttMessages {
public static final String PAYLOAD_FORMAT_MANAGER_INIT_ERROR =
"MQTT PayloadFormatManager init() 出错。";
public static final String FORMATTER_IS_NULL = "PayloadFormatManager(),formatter 为 null。";
public static final String FIND_MQTT_PLUGIN =
"PayloadFormatManager(),找到 MQTT Payload 插件 {}。";
public static final String FIND_MQTT_PLUGIN = "PayloadFormatManager(),找到 MQTT Payload 插件 {}。";
public static final String MQTT_PLUGIN_JAR_URLS = "MQTT 插件 jarURLs:{}";
public static final String UNKNOWN_PAYLOAD_FORMAT_NAMED = "未知 payload 格式名称:";

// --- JSONPayloadFormatter ---
public static final String PAYLOAD_INVALID = "payload 无效";

private MqttMessages() {}

// ---------------------------------------------------------------------------
// Additional auto-collected messages
// ---------------------------------------------------------------------------
public static final String LOG_LINE_PATTERN_PARSING_FAILS_FAILED_LINE_MESSAGE_ARG_EXCEPTION_6EFB0EE2 = "行模式解析失败,失败的行消息为 {},异常为";
public static final String LOG_CONNECTION_REFUSED_CLIENT_ID_MISSING_EMPTY_VALID_CLIENT_ID_REQUIRED_A566DC15 = "连接被拒绝:client_id 缺失或为空。建立连接需要有效的 client_id。";
public static final String LOG_RECEIVE_PUBLISH_MESSAGE_CLIENTID_ARG_USERNAME_ARG_QOS_ARG_TOPIC_7E60C3A6 = "收到 publish 消息。clientId: {}, 用户名: {}, qos: {}, 主题: {}, payload: {}";
public static final String LOG_MQTT_JSON_INSERT_ERROR_CODE_ARG_MESSAGE_ARG_B1A78FBD = "MQTT JSON 插入错误,code={},消息={}";
public static final String LOG_MEET_ERROR_INSERTING_DATABASE_ARG_TABLE_ARG_TAGS_ARG_ATTRIBUTES_173457D5 = "插入数据库 {}、表 {}、标签 {}、属性 {}、字段 {}、时间 {} 时遇到错误,原因:";
public static final String LOG_MEET_ERROR_INSERTING_DEVICE_ARG_MEASUREMENTS_ARG_AT_TIME_ARG_680D67D2 = "插入设备 {}、测点 {}、时间 {} 时遇到错误,原因:";
public static final String LOG_START_MQTT_SERVICE_SUCCESSFULLY_LISTENING_IP_ARG_PORT_ARG_47CE46D5 = "MQTT 服务启动成功,监听 IP {},端口 {}";

public static final String
LOG_LINE_PATTERN_PARSING_FAILS_FAILED_LINE_MESSAGE_ARG_EXCEPTION_6EFB0EE2 =
"行模式解析失败,失败的行消息为 {},异常为";
public static final String
LOG_CONNECTION_REFUSED_CLIENT_ID_MISSING_EMPTY_VALID_CLIENT_ID_REQUIRED_A566DC15 =
"连接被拒绝:client_id 缺失或为空。建立连接需要有效的 client_id。";
public static final String
LOG_RECEIVE_PUBLISH_MESSAGE_CLIENTID_ARG_USERNAME_ARG_QOS_ARG_TOPIC_7E60C3A6 =
"收到 publish 消息。clientId: {}, 用户名: {}, qos: {}, 主题: {}, payload: {}";
public static final String LOG_MQTT_JSON_INSERT_ERROR_CODE_ARG_MESSAGE_ARG_B1A78FBD =
"MQTT JSON 插入错误,code={},消息={}";
public static final String
LOG_MEET_ERROR_INSERTING_DATABASE_ARG_TABLE_ARG_TAGS_ARG_ATTRIBUTES_173457D5 =
"插入数据库 {}、表 {}、标签 {}、属性 {}、字段 {}、时间 {} 时遇到错误,原因:";
public static final String
LOG_MEET_ERROR_INSERTING_DEVICE_ARG_MEASUREMENTS_ARG_AT_TIME_ARG_680D67D2 =
"插入设备 {}、测点 {}、时间 {} 时遇到错误,原因:";
public static final String
LOG_START_MQTT_SERVICE_SUCCESSFULLY_LISTENING_IP_ARG_PORT_ARG_47CE46D5 =
"MQTT 服务启动成功,监听 IP {},端口 {}";
}
Original file line number Diff line number Diff line change
Expand Up @@ -34,9 +34,8 @@ public final class RestMessages {
public static final String SQL_SHOULD_NOT_BE_NULL = "sql should not be null";
public static final String ROW_LIMIT_SHOULD_BE_POSITIVE = "row_limit should be positive";
public static final String ROW_LIMIT_CAMEL_SHOULD_BE_POSITIVE = "rowLimit should be positive";
public static final String
MESSAGE_DATASET_ROW_SIZE_EXCEEDED_THE_GIVEN_MAX_ROW_SIZE_ARG_7A3F6452 =
"Dataset row size exceeded the given max row size (%d)";
public static final String MESSAGE_DATASET_ROW_SIZE_EXCEEDED_THE_GIVEN_MAX_ROW_SIZE_ARG_7A3F6452 =
"Dataset row size exceeded the given max row size (%d)";
public static final String PREFIX_PATHS_NOT_NULL = "prefix_paths should not be null";
public static final String TIMESTAMPS_NOT_NULL = "timestamps should not be null";
public static final String IS_ALIGNED_NOT_NULL = "is_aligned should not be null";
Expand All @@ -61,16 +60,14 @@ public final class RestMessages {
public static final String DATABASE_NOT_NULL = "database should not be null";
public static final String TABLE_NOT_NULL = "table should not be null";
public static final String COLUMN_NAMES_NOT_NULL = "column_names should not be null";
public static final String COLUMN_CATEGORIES_NOT_NULL =
"column_categories should not be null";
public static final String COLUMN_CATEGORIES_NOT_NULL = "column_categories should not be null";
public static final String COLUMN_NAMES_AND_COLUMN_CATEGORIES_SIZE_MISMATCH =
"column_names and column_categories should have the same size";
public static final String COLUMN_CATEGORIES_AND_DATA_TYPES_SIZE_MISMATCH =
"column_categories and data_types should have the same size";
public static final String VALUES_AND_TIMESTAMPS_SIZE_MISMATCH =
"values and timestamps should have the same size";
public static final String ILLEGAL_TABLE_DATA_TYPE =
"The %s data type of %s is illegal";
public static final String ILLEGAL_TABLE_DATA_TYPE = "The %s data type of %s is illegal";
public static final String ILLEGAL_DEVICE_MEASUREMENT_DATA_TYPE =
"The %s data type of %s.%s is illegal";
public static final String ROW_VALUES_SIZE_MISMATCH =
Expand Down Expand Up @@ -121,9 +118,9 @@ public final class RestMessages {
"Each insertRecords row should have the same number of measurements, data types and values";

private RestMessages() {}

// ---------------------------------------------------------------------------
// Additional auto-collected messages
// ---------------------------------------------------------------------------
public static final String EXCEPTION_UNSUPPORTED_DATA_TYPE_0521CEDE = "unsupported data type: ";

}
Original file line number Diff line number Diff line change
Expand Up @@ -34,9 +34,8 @@ public final class RestMessages {
public static final String SQL_SHOULD_NOT_BE_NULL = "sql 不能为空";
public static final String ROW_LIMIT_SHOULD_BE_POSITIVE = "row_limit 应为正数";
public static final String ROW_LIMIT_CAMEL_SHOULD_BE_POSITIVE = "rowLimit 应为正数";
public static final String
MESSAGE_DATASET_ROW_SIZE_EXCEEDED_THE_GIVEN_MAX_ROW_SIZE_ARG_7A3F6452 =
"数据集行数超过给定的最大行数(%d)";
public static final String MESSAGE_DATASET_ROW_SIZE_EXCEEDED_THE_GIVEN_MAX_ROW_SIZE_ARG_7A3F6452 =
"数据集行数超过给定的最大行数(%d)";
public static final String PREFIX_PATHS_NOT_NULL = "prefix_paths 不能为空";
public static final String TIMESTAMPS_NOT_NULL = "timestamps 不能为空";
public static final String IS_ALIGNED_NOT_NULL = "is_aligned 不能为空";
Expand Down Expand Up @@ -66,13 +65,10 @@ public final class RestMessages {
"column_names 和 column_categories 的数量应相同";
public static final String COLUMN_CATEGORIES_AND_DATA_TYPES_SIZE_MISMATCH =
"column_categories 和 data_types 的数量应相同";
public static final String VALUES_AND_TIMESTAMPS_SIZE_MISMATCH =
"values 和 timestamps 的数量应相同";
public static final String VALUES_AND_TIMESTAMPS_SIZE_MISMATCH = "values 和 timestamps 的数量应相同";
public static final String ILLEGAL_TABLE_DATA_TYPE = "%s 是 %s 的非法数据类型";
public static final String ILLEGAL_DEVICE_MEASUREMENT_DATA_TYPE =
"%s 是 %s.%s 的非法数据类型";
public static final String ROW_VALUES_SIZE_MISMATCH =
"第 %d 行的 values 数量与 data_types 数量不相等";
public static final String ILLEGAL_DEVICE_MEASUREMENT_DATA_TYPE = "%s 是 %s.%s 的非法数据类型";
public static final String ROW_VALUES_SIZE_MISMATCH = "第 %d 行的 values 数量与 data_types 数量不相等";
public static final String ERROR_MESSAGE_SEPARATOR = ",";

// --- RequestSizeLimitFilter ---
Expand All @@ -88,8 +84,7 @@ public final class RestMessages {
// --- RequestLimitChecker ---
public static final String MESSAGE_INSERTTABLET_REQUEST_8647CA58 = "insertTablet 请求";
public static final String MESSAGE_INSERTRECORDS_REQUEST_93E12369 = "insertRecords 请求";
public static final String MESSAGE_TABLE_INSERTTABLET_REQUEST_573D371C =
"table insertTablet 请求";
public static final String MESSAGE_TABLE_INSERTTABLET_REQUEST_573D371C = "table insertTablet 请求";
public static final String EXCEPTION_ARG_ROW_COUNT_ARG_EXCEEDS_LIMIT_ARG_EE427E4B =
"%s 行数 %d 超过限制 %d";
public static final String EXCEPTION_ARG_COLUMN_COUNT_ARG_EXCEEDS_LIMIT_ARG_DEE9637E =
Expand Down Expand Up @@ -119,9 +114,9 @@ public final class RestMessages {
"每个 insertRecords 行中的 measurements、data types 和 values 数量应相同";

private RestMessages() {}

// ---------------------------------------------------------------------------
// Additional auto-collected messages
// ---------------------------------------------------------------------------
public static final String EXCEPTION_UNSUPPORTED_DATA_TYPE_0521CEDE = "不支持的数据类型: ";

}
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,7 @@ public final class TriggerApiMessages {
public static final String NO_SUCH_TRIGGER_EVENT = "不存在该触发器事件(id: %d)";

// --- FailureStrategy ---
public static final String UNSUPPORTED_FAILURE_STRATEGY_TYPE =
"不支持的 FailureStrategy 类型。";
public static final String UNSUPPORTED_FAILURE_STRATEGY_TYPE = "不支持的 FailureStrategy 类型。";

private TriggerApiMessages() {}
}
Original file line number Diff line number Diff line change
Expand Up @@ -63,8 +63,7 @@ public final class UdfApiMessages {
public static final String UDF_OUTPUT_DATA_TYPE_NOT_SET = "UDF outputDataType is not set.";

// SlidingTimeWindowAccessStrategy
public static final String METHOD_DEPRECATED_SINCE_V014 =
"The method is deprecated since v0.14.";
public static final String METHOD_DEPRECATED_SINCE_V014 = "The method is deprecated since v0.14.";

// Type
public static final String UNSUPPORTED_TYPE = "Unsupported type: ";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,10 +29,8 @@ public final class UdfApiMessages {
public static final String UNKNOWN_ARGUMENT_TYPE = "未知参数类型:";

// TableFunctionProcessorProvider
public static final String TABLE_FUNCTION_DOES_NOT_PROCESS_INPUT_DATA =
"此表函数不处理输入数据";
public static final String TABLE_FUNCTION_DOES_NOT_PROCESS_LEAF_DATA =
"此表函数不处理叶子数据";
public static final String TABLE_FUNCTION_DOES_NOT_PROCESS_INPUT_DATA = "此表函数不处理输入数据";
public static final String TABLE_FUNCTION_DOES_NOT_PROCESS_LEAF_DATA = "此表函数不处理叶子数据";

// DescribedSchema
public static final String DESCRIBED_SCHEMA_HAS_NO_FIELDS = "DescribedSchema 没有字段";
Expand All @@ -45,8 +43,7 @@ public final class UdfApiMessages {
"fieldNames 和 fieldTypes 必须具有相同的大小";

// ParameterSpecification
public static final String NON_NULL_DEFAULT_VALUE_FOR_REQUIRED_ARG =
"必填参数不能有非 null 默认值";
public static final String NON_NULL_DEFAULT_VALUE_FOR_REQUIRED_ARG = "必填参数不能有非 null 默认值";

// ScalarFunctionAnalysis
public static final String SCALAR_FUNCTION_ANALYSIS_OUTPUT_DATA_TYPE_NOT_SET =
Expand Down
Loading