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,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,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,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,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,false,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,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,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,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,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,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,false);
@ -28,7 +28,7 @@ public abstract class AbstractMqttServerSideRpcProtoIntegrationTest extends Abst
@Before
publicvoidbeforeTest()throwsException{
processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,false,false);
processBeforeTest("RPC test device","RPC test gateway",TransportPayloadType.PROTOBUF,null,null,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED,false,false,false);
privatestaticfinalStringMALFORMED_PROTO_PAYLOAD="invalid proto payload str";
@Before
@Override
@ -91,7 +95,7 @@ public abstract class AbstractMqttTimeseriesProtoIntegrationTest extends Abstrac
" }\n"+
" }\n"+
"}";
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);
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,false);
@ -193,7 +197,7 @@ public abstract class AbstractMqttTimeseriesProtoIntegrationTest extends Abstrac
" }\n"+
" }\n"+
"}";
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);
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,false);
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);
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,false);
@ -267,7 +271,7 @@ public abstract class AbstractMqttTimeseriesProtoIntegrationTest extends Abstrac
@Test
publicvoidtestGatewayConnect()throwsException{
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);
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,false);
processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,true);
processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,false);
processBeforeTest("Test Post Telemetry device","Test Post Telemetry gateway",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,true,false,true);
processBeforeTest("Test Post Telemetry device","Test Post Telemetry gateway",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,true,false,false);
processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,true);
processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,false);
Stringsql="Select * from Table Where guid IN (:guids)";
StringsqlToUse="Select * from Table Where guid IN ('634a8d03-6871-4e01-94d0-876bf3e67dff', '3adbb5b8-4dc6-4faf-80dc-681a7b518b5e', '63a50f0c-2058-4d1d-8f15-812eb7f84412')";
"mqtt-enable-compatibility-with-json-payload-format-hint":"When enabled, the platform will use a Protobuf payload format by default. If parsing fails, the platform will attempt to use JSON payload format. Useful for backward compatibility during firmware updates. For example, the initial release of the firmware uses Json, while the new release uses Protobuf. During the process of firmware update for the fleet of devices, it is required to support both Protobuf and JSON simultaneously. The compatibility mode introduces slight performance degradation, so it is recommended to disable this mode once all devices are updated.",
"mqtt-use-json-format-for-default-downlink-topics":"Use Json format for default downlink topics",
"mqtt-use-json-format-for-default-downlink-topics-hint":"When enabled, the platform will use Json payload format to push attributes and RPC via the following topics: <b>v1/devices/me/attributes/response/$request_id</b>, <b>v1/devices/me/attributes</b>, <b>v1/devices/me/rpc/request/$request_id</b>, <b>v1/devices/me/rpc/response/$request_id</b>. This setting does not impact attribute and rpc subscriptions sent using new (v2) topics: <b>v2/a/res/$request_id</b>, <b>v2/a</b>, <b>v2/r/req/$request_id</b>, <b>v2/r/res/$request_id</b>. Where <b>$request_id</b> is an integer request identifier.",
"mqtt-send-ack-on-validation-exception":"Send PUBACK on PUBLISH message validation failure",
"mqtt-send-ack-on-validation-exception-hint":"By default, the platform will close the MQTT session on message validation failure. When enabled, the platform will send publish acknowledgment instead of closing the session.",
"snmp-add-mapping":"Add SNMP mapping",
"snmp-mapping-not-configured":"No mapping for OID to timeseries/telemetry configured",
"snmp-timseries-or-attribute-name":"Timeseries/attribute name for mapping",