@ -65,12 +63,18 @@ public class CoapServerSideRpcProtoIntegrationTest extends AbstractCoapServerSid
@Before
publicvoidbeforeTest()throwsException{
processBeforeTest("RPC test device",CoapDeviceType.DEFAULT,TransportPayloadType.PROTOBUF,null,null,null,RPC_REQUEST_PROTO_SCHEMA,null,null,DeviceProfileProvisionType.DISABLED);
@ -117,7 +123,13 @@ public abstract class AbstractCoapTimeseriesProtoIntegrationTest extends Abstrac
" }\n"+
" }\n"+
"}";
processBeforeTest("Test Post Telemetry device proto payload",CoapDeviceType.DEFAULT,TransportPayloadType.PROTOBUF,schemaStr,null,null,null,null,null,DeviceProfileProvisionType.DISABLED);
@ -239,7 +256,13 @@ public abstract class AbstractCoapTimeseriesProtoIntegrationTest extends Abstrac
" }\n"+
" }\n"+
"}";
processBeforeTest("Test Post Telemetry device proto payload",CoapDeviceType.DEFAULT,TransportPayloadType.PROTOBUF,schemaStr,null,null,null,null,null,DeviceProfileProvisionType.DISABLED);
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);
@ -30,12 +30,12 @@ public class MqttAttributesRequestJsonIntegrationTest extends AbstractMqttAttrib
@Before
publicvoidbeforeTest()throwsException{
processBeforeTest("Test Request attribute values from the server json","Gateway Test Request attribute values from the server json",TransportPayloadType.JSON,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 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,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,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,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,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,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,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,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,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,false);
@ -30,12 +29,13 @@ public class MqttServerSideRpcProtoIntegrationTest extends AbstractMqttServerSid
@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,false);
processBeforeTest("Test Post Attributes device","Test Post Attributes gateway",TransportPayloadType.PROTOBUF,null,POST_DATA_ATTRIBUTES_TOPIC,true,false);
@ -57,14 +57,25 @@ public abstract class AbstractMqttTimeseriesProtoIntegrationTest extends Abstrac
@Test
publicvoidtestPushTelemetry()throwsException{
processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null);
processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null,true,false);
@ -95,7 +106,13 @@ 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,false);
processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null);
@ -197,7 +219,13 @@ 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,false);
processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null);
processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null);
processBeforeTest("Test Post Telemetry device proto payload","Test Post Telemetry gateway proto payload",TransportPayloadType.PROTOBUF,POST_DATA_TELEMETRY_TOPIC,null);
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);
@ -271,7 +320,13 @@ 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,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);