AdminSettingsadminSettings=checkNotNull(adminSettingsService.findAdminSettingsByKey(TenantId.SYS_TENANT_ID,key),"No Administration settings found for key: "+key);
protectedstaticfinalStringPAGE_DATA_PARAMETERS="You can specify parameters to filter the results. "+
@ -45,6 +46,7 @@ public class ControllerConstants {
protectedstaticfinalStringOTA_PACKAGE_ID_PARAM_DESCRIPTION="A string value representing the ota package id. For example, '784f394c-42b6-435a-983c-b7beff2784f9'";
protectedstaticfinalStringENTITY_TYPE_PARAM_DESCRIPTION="A string value representing the entity type. For example, 'DEVICE'";
protectedstaticfinalStringRULE_CHAIN_ID_PARAM_DESCRIPTION="A string value representing the rule chain id. For example, '784f394c-42b6-435a-983c-b7beff2784f9'";
protectedstaticfinalStringRULE_NODE_ID_PARAM_DESCRIPTION="A string value representing the rule node id. For example, '784f394c-42b6-435a-983c-b7beff2784f9'";
protectedstaticfinalStringWIDGET_BUNDLE_ID_PARAM_DESCRIPTION="A string value representing the widget bundle id. For example, '784f394c-42b6-435a-983c-b7beff2784f9'";
protectedstaticfinalStringWIDGET_TYPE_ID_PARAM_DESCRIPTION="A string value representing the widget type id. For example, '784f394c-42b6-435a-983c-b7beff2784f9'";
protectedstaticfinalStringRESOURCE_ID_PARAM_DESCRIPTION="A string value representing the resource id. For example, '784f394c-42b6-435a-983c-b7beff2784f9'";
@ -129,9 +131,9 @@ public class ControllerConstants {
protectedstaticfinalStringEVENT_END_TIME_DESCRIPTION="Timestamp. Events with creation time after it won't be queried.";
protectedstaticfinalStringEDGE_UNASSIGN_ASYNC_FIRST_STEP_DESCRIPTION="Unassignment works in async way - first, 'unassign' notification event pushed to edge queue on platform. ";
protectedstaticfinalStringEDGE_UNASSIGN_RECEIVE_STEP_DESCRIPTION="(Edge will receive this instantly, if it's currently connected, or once it's going to be connected to platform)";
protectedstaticfinalStringEDGE_UNASSIGN_RECEIVE_STEP_DESCRIPTION="(Edge will receive this instantly, if it's currently connected, or once it's going to be connected to platform). ";
protectedstaticfinalStringEDGE_ASSIGN_ASYNC_FIRST_STEP_DESCRIPTION="Assignment works in async way - first, notification event pushed to edge service queue on platform. ";
protectedstaticfinalStringEDGE_ASSIGN_RECEIVE_STEP_DESCRIPTION="(Edge will receive this instantly, if it's currently connected, or once it's going to be connected to platform)";
protectedstaticfinalStringEDGE_ASSIGN_RECEIVE_STEP_DESCRIPTION="(Edge will receive this instantly, if it's currently connected, or once it's going to be connected to platform). ";
@ApiParam(value="If the parameter is set to true, the latest telemetry will be rewritten in case that current latest value was removed, otherwise, in case that parameter is set to false the new latest value will not set.")
description:"${SWAGGER_DESCRIPTION:For instructions how to authorize requests please visit <a href='http://thingsboard.io/docs/reference/rest-api/'>REST API documentation page</a>.}"
description:"${SWAGGER_DESCRIPTION: ThingsBoard open-source IoT platform REST API documentation.}"
type:"${TB_QUEUE_TYPE:in-memory}"# in-memory or kafka (Apache Kafka) or aws-sqs (AWS SQS) or pubsub (PubSub) or service-bus (Azure Service Bus) or rabbitmq (RabbitMQ)
# Key-value properties for Kafka consumer per specific topic, e.g. tb_ota_package is a topic name for ota, tb_rule_engine.sq is a topic name for default SequentialByOriginator queue.
# Check TB_QUEUE_CORE_OTA_TOPIC and TB_QUEUE_RE_SQ_TOPIC params
other:# In this section you can specify custom parameters for Kafka consumer/producer and expose the env variables to configure outside
- key:"request.timeout.ms"# refer to https://docs.confluent.io/platform/current/installation/configuration/producer-configs.html#producerconfigs_request.timeout.ms
super.processBeforeTest("Test Request attribute values from the server proto","Gateway Test Request attribute values from the server proto",TransportPayloadType.PROTOBUF,null,null,true,true);
super.processBeforeTest("Test Request attribute values from the server proto","Gateway Test Request attribute values from the server proto",TransportPayloadType.PROTOBUF,null,null,true,true);
super.processBeforeTest("Test Request attribute values from the server proto","Gateway Test Request attribute values from the server proto",TransportPayloadType.PROTOBUF,null,null);
super.processBeforeTest("Test Request attribute values from the server proto","Gateway Test Request attribute values from the server proto",TransportPayloadType.PROTOBUF,null,null);
super.processBeforeTest("Test Subscribe to attribute updates","Gateway Test Subscribe to attribute updates",TransportPayloadType.PROTOBUF,null,null,true,false);
super.processBeforeTest("Test Subscribe to attribute updates","Gateway Test Subscribe to attribute updates",TransportPayloadType.PROTOBUF,null,null,true,true);
super.processBeforeTest("Test Subscribe to attribute updates","Gateway Test Subscribe to attribute updates",TransportPayloadType.PROTOBUF,null,null,true,true);
super.processBeforeTest("Test Subscribe to attribute updates","Gateway Test Subscribe to attribute updates",TransportPayloadType.PROTOBUF,null,null,true,true);
super.processBeforeTest("Test Subscribe to attribute updates","Gateway Test Subscribe to attribute updates",TransportPayloadType.PROTOBUF,null,null,true,true);
super.processBeforeTest("Test Subscribe to attribute updates","Gateway Test Subscribe to attribute updates",TransportPayloadType.PROTOBUF,null,null,true,false);
super.processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,true,true);
super.processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,true,true);
super.processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,true,true);
super.processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,true,false);
super.processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,true,true);
super.processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,true,true);
super.processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,true,true);
super.processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,true,true);
super.processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,true,true);
super.processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,true,true);
processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED);
processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,false,false);
}
@After
@ -93,122 +53,27 @@ public abstract class AbstractMqttServerSideRpcProtoIntegrationTest extends Abst
super.processBeforeTest("Test Post Attributes device","Test Post Attributes gateway",TransportPayloadType.PROTOBUF,null,POST_DATA_ATTRIBUTES_TOPIC,true,false);
super.processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,true,false);
@ -87,7 +90,7 @@ public abstract class AbstractMqttTimeseriesProtoIntegrationTest extends Abstrac
" }\n"+
" }\n"+
"}";
super.processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,schemaStr,null,null,null,null,null,DeviceProfileProvisionType.DISABLED);
super.processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,schemaStr,null,null,null,null,null,DeviceProfileProvisionType.DISABLED,false,false);
@ -189,7 +192,7 @@ public abstract class AbstractMqttTimeseriesProtoIntegrationTest extends Abstrac
" }\n"+
" }\n"+
"}";
super.processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,schemaStr,null,null,null,null,null,DeviceProfileProvisionType.DISABLED);
super.processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,schemaStr,null,null,null,null,null,DeviceProfileProvisionType.DISABLED,false,false);
super.processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,null,null,null,null,null,null,null,null,DeviceProfileProvisionType.DISABLED);
super.processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,null,null,null,null,null,null,null,null,DeviceProfileProvisionType.DISABLED,false,false);
@ -263,7 +266,7 @@ public abstract class AbstractMqttTimeseriesProtoIntegrationTest extends Abstrac
@Test
publicvoidtestGatewayConnect()throwsException{
super.processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,null,null,null,null,null,null,DeviceProfileProvisionType.DISABLED);
super.processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,null,null,null,null,null,null,DeviceProfileProvisionType.DISABLED,false,false);