Package test.de.iip_ecosphere.platform.connectors.mqttv5

Class PahoMqttv5ConnectorTest

java.lang.Object
test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest
test.de.iip_ecosphere.platform.connectors.mqttv5.PahoMqttv5ConnectorTest
public class PahoMqttv5ConnectorTest extends test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest
Implements a test for PahoMqttv5Connector. Data is sent via the test server from a transport connector to the machine connector which mirrors the data and sends it back in another format. Builds up a TestHiveMqServer so that the test is self-contained.
Author:
Holger Eichelberger, SSE

  • Nested Class Summary

    Nested classes/interfaces inherited from class test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest

    test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest.ConnectorParameterConfigurer

  • Field Summary

    Fields inherited from class test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest

    CMD_CHANNEL, PROD_CHANNEL

  • Constructor Summary

    Constructors
    Constructor
    Description
    PahoMqttv5ConnectorTest()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected de.iip_ecosphere.platform.transport.connectors.TransportParameter.TransportParameterBuilder
    configureTransportParameter(de.iip_ecosphere.platform.transport.connectors.TransportParameter.TransportParameterBuilder builder)
     
    protected de.iip_ecosphere.platform.connectors.Connector<byte[],byte[],test.de.iip_ecosphere.platform.transport.Product,test.de.iip_ecosphere.platform.transport.Command>
    createConnector(de.iip_ecosphere.platform.connectors.types.ChannelProtocolAdapter<byte[],byte[],test.de.iip_ecosphere.platform.transport.Product,test.de.iip_ecosphere.platform.transport.Command>... adapter)
     
    protected de.iip_ecosphere.platform.support.Server
    createTestServer(de.iip_ecosphere.platform.support.ServerAddress addr, File configDir)
     
    protected de.iip_ecosphere.platform.transport.connectors.TransportConnector
    createTransportConnector()
     
    protected test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest.ConnectorParameterConfigurer
    getConfigurer(boolean withTls)
     
    protected Class<? extends de.iip_ecosphere.platform.connectors.ConnectorDescriptor>
    getConnectorDescriptor()
     
    protected boolean
    implementsEncryption()
     

    Methods inherited from class test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest

    createConnectorParameter, createTransportParameter, doTest, doTestMultiChannel, testConnector, testTlsConnector

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • PahoMqttv5ConnectorTest

      public PahoMqttv5ConnectorTest()

  • Method Details

    • createConnector

      protected de.iip_ecosphere.platform.connectors.Connector<byte[],byte[],test.de.iip_ecosphere.platform.transport.Product,test.de.iip_ecosphere.platform.transport.Command> createConnector(de.iip_ecosphere.platform.connectors.types.ChannelProtocolAdapter<byte[],byte[],test.de.iip_ecosphere.platform.transport.Product,test.de.iip_ecosphere.platform.transport.Command>... adapter)
      Specified by:
      createConnector in class test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest

    • createTransportConnector

      protected de.iip_ecosphere.platform.transport.connectors.TransportConnector createTransportConnector()
      Specified by:
      createTransportConnector in class test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest

    • configureTransportParameter

      protected de.iip_ecosphere.platform.transport.connectors.TransportParameter.TransportParameterBuilder configureTransportParameter(de.iip_ecosphere.platform.transport.connectors.TransportParameter.TransportParameterBuilder builder)
      Specified by:
      configureTransportParameter in class test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest

    • getConnectorDescriptor

      protected Class<? extends de.iip_ecosphere.platform.connectors.ConnectorDescriptor> getConnectorDescriptor()
      Specified by:
      getConnectorDescriptor in class test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest

    • createTestServer

      protected de.iip_ecosphere.platform.support.Server createTestServer(de.iip_ecosphere.platform.support.ServerAddress addr, File configDir)
      Specified by:
      createTestServer in class test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest

    • getConfigurer

      protected test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest.ConnectorParameterConfigurer getConfigurer(boolean withTls)
      Specified by:
      getConfigurer in class test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest

    • implementsEncryption

      protected boolean implementsEncryption()
      Specified by:
      implementsEncryption in class test.de.iip_ecosphere.platform.connectors.AbstractSerializingConnectorTest