HiveMQ Edge Protocol Adapters

 <simulation>
    <id>test-simulation-server</id>
    <minValue>-10</minValue>
    <maxValue>10</maxValue>
    <pollingIntervalMillis>5000</pollingIntervalMillis>
    <subscriptions>
        <subscription>
            <destination>test</destination>
            <qos>1</qos>
        </subscription>
    </subscriptions>
</simulation>

 <modbus>
    <id>modbus-connection</id>
    <port>502</port>
    <host>some-ip4-address</host>
    <publishChangedDataOnly>true</publishChangedDataOnly>
    <publishingInterval>500</publishingInterval>
    <subscriptions>
        <subscription>
            <holding-registers>
                <endIdx>1</endIdx>
                <startIdx>0</startIdx>
            </holding-registers>
            <destination>test</destination>
        </subscription>
    </subscriptions>
    <maxPollingErrorsBeforeRemoval>5</maxPollingErrorsBeforeRemoval>
</modbus>

{
"value": 1000
}

{
  "value": {
    "Position_Reached": false,
    "Target_Position": 2700,
    "Increment": 0,
    "Actual_Position": 0,
    "Config": {
      "Ref_Pos": 0,
      "Loop_Value": 0
    }
  }
}

<opc-ua-client>
    <id>opc-example</id>
    <uri>opc.tcp://my-opc-server-uri-or-ip:4840</uri>
    <subscriptions>
        <subscription>
            <node>ns=3;s="node-name"</node>
            <mqtt-topic>my/mqtt/topic/1</mqtt-topic>
        </subscription>
    </subscriptions>
</opc-ua-client>

<hivemq>
...
    <protocol-adapters>
        <opc-ua-client>
            <id>full-opc-example</id>
            <uri>opc.tcp://my-opc-server-uri-or-ip:4840</uri>
            <auth>
                <basic>
                    <username>my-user</username>
                    <password>secret</password>
                </basic>
            </auth>
            <tls>
                <enabled>true</enabled>
                <keystore>
                    <path>/path/to/my/keystore.jks</path>
                    <password>keystore-password</password>
                    <private-key-password>key-password</private-key-password>
                </keystore>
                <truststore>
                    <path>/path/to/my/truststore.jks</path>
                    <password>truststore-password</password>
                </truststore>
            </tls>
            <security>
                <policy>BASIC256SHA256</policy>
            </security>
            <subscriptions>
                <subscription>
                    <node>ns=3;s="node-name"</node>
                    <mqtt-topic>my/mqtt/topic/1</mqtt-topic>
                    <qos>2</qos>
                    <message-expiry-interval>60</message-expiry-interval>
                    <publishing-interval>1000</publishing-interval>
                    <server-queue-size>1</server-queue-size>
                </subscription>
                <subscription>
                    <node>ns=3;i=101</node>
                    <mqtt-topic>my/mqtt/topic/2</mqtt-topic>
                </subscription>
            </subscriptions>
        </opc-ua-client>
    </protocol-adapters>
...
</hivemq>

 <s7>
    <id>my-s7-id</id>
    <host>my-ip-address-or-host</host>
    <port>102</port>
    <controllerType>S7_1500</controllerType>
    <subscriptions>
        <subscription>
            <tagName>my-tag-name-1</tagName>
            <tagAddress>%I204.0</tagAddress>
            <destination>my/topic/1</destination>
            <dataType>SINT</dataType>
            <qos>1</qos>
        </subscription>
    </subscriptions>
</s7>

 <s7>
    <id>my-s7-id</id>
    <host>my-ip-addr-or-host</host>
    <port>102</port>
    <controllerType>S7_1500</controllerType>
    <maxPollingErrorsBeforeRemoval>10</maxPollingErrorsBeforeRemoval>
    <pollingIntervalMillis>1000</pollingIntervalMillis>
    <remoteRack>0</remoteRack>
    <remoteSlot>0</remoteSlot>
    <remoteRack2>1</remoteRack2>
    <remoteSlot2>0</remoteSlot2>
    <remoteTsap>0</remoteTsap>
    <publishChangedDataOnly>true</publishChangedDataOnly>
    <subscriptions>
        <subscription>
            <tagName>my-tag-name-1</tagName>
            <tagAddress>%I204.0</tagAddress>
            <destination>my/topic/1</destination>
            <dataType>BOOL</dataType>
            <qos>1</qos>
            <messageHandlingOptions>MQTTMessagePerTag</messageHandlingOptions>
            <includeTimestamp>true</includeTimestamp>
            <includeTagNames>false</includeTagNames>
        </subscription>
        <subscription>
            <tagName>my-tag-name-2</tagName>
            <tagAddress>%I205.0</tagAddress>
            <destination>my/topic/2</destination>
            <dataType>BOOL</dataType>
            <qos>0</qos>
            <messageHandlingOptions>MQTTMessagePerTag</messageHandlingOptions>
            <includeTimestamp>true</includeTimestamp>
            <includeTagNames>true</includeTagNames>
        </subscription>
    </subscriptions>
</s7>

<ads>
    <id>my-ads-id</id>
    <host>my-ip-addr-or-host</host>
    <port>48898</port>
    <targetAmsNetId>2.3.4.5.1.1</targetAmsNetId>
    <targetAmsPort>850</targetAmsPort>
    <sourceAmsNetId>5.4.3.2.1.1</sourceAmsNetId>
    <subscriptions>
        <subscription>
            <tagName>my-tag-name</tagName>
            <tagAddress>MYPROGRAM.MyStringVar</tagAddress>
            <destination>my/mqtt/topic</destination>
            <dataType>STRING</dataType>
            <qos>1</qos>
        </subscription>
    </subscriptions>
</ads>

<hivemq>
...
  <protocol-adapters>
    <ads>
        <id>asd</id>
        <host>172.16.10.54</host>
        <port>48898</port>
        <targetAmsNetId>2.3.4.5.1.1</targetAmsNetId>
        <targetAmsPort>850</targetAmsPort>
        <sourceAmsNetId>5.4.3.2.1.1</sourceAmsNetId>
        <sourceAmsPort>49999</sourceAmsPort>
        <subscriptions>
            <subscription>
                <tagName>my-tag-name</tagName>
                <tagAddress>MYPROGRAM.MyStringVar</tagAddress>
                <destination>my/mqtt/topic</destination>
                <dataType>STRING</dataType>
                <qos>1</qos>
                <includeTagNames>false</includeTagNames>
                <includeTimestamp>true</includeTimestamp>
                <messageHandlingOptions>MQTTMessagePerTag</messageHandlingOptions>
            </subscription>
        </subscriptions>
        <publishChangedDataOnly>true</publishChangedDataOnly>
        <pollingIntervalMillis>1000</pollingIntervalMillis>
        <maxPollingErrorsBeforeRemoval>10</maxPollingErrorsBeforeRemoval>
    </ads>
    ...
  </protocol-adapters>
...
</hivemq>

<ethernet-ip>
    <id>my-eip-id</id>
    <ethernet-ip>
        <id>my-eip-adapter-id</id>
        <host>my-ip-addr-or-host</host>
        <subscriptions>
            <subscription>
                <tagName>my-tag-name</tagName>
                <tagAddress>my_tag_name</tagAddress>
                <destination>my/mqtt/topic</destination>
                <dataType>STRING</dataType>
                <qos>1</qos>
            </subscription>
        </subscriptions>
    </ethernet-ip>
</ethernet-ip>

<hivemq>
...
  <protocol-adapters>
    <ethernet-ip>
        <id>my-eip-adapter-id</id>
        <host>172.16.10.54</host>
        <port>44818</port>
        <backplane>1</backplane>
        <slot>0</slot>
        <subscriptions>
            <subscription>
                <tagName>my-tag-name</tagName>
                <tagAddress>my_tag_name</tagAddress>
                <destination>my/mqtt/topic</destination>
                <dataType>STRING</dataType>
                <qos>1</qos>
                <includeTagNames>false</includeTagNames>
                <includeTimestamp>true</includeTimestamp>
                <messageHandlingOptions>MQTTMessagePerTag</messageHandlingOptions>
            </subscription>
        </subscriptions>
        <publishChangedDataOnly>true</publishChangedDataOnly>
        <pollingIntervalMillis>1000</pollingIntervalMillis>
        <maxPollingErrorsBeforeRemoval>10</maxPollingErrorsBeforeRemoval>
    </ethernet-ip>
    ...
  </protocol-adapters>
...
</hivemq>

<protocol-adapters>
    ...
    <http>
        <qos>1</qos>
        <httpRequestMethod>GET</httpRequestMethod>
        <httpConnectTimeout>5</httpConnectTimeout>
        <httpRequestBodyContentType>JSON</httpRequestBodyContentType>
        <httpPublishSuccessStatusCodeOnly>true</httpPublishSuccessStatusCodeOnly>
        <httpHeaders>
            <httpHeader>
                <name>Authorization</name>
                <value>Bearer Some-Token</value>
            </httpHeader>
        </httpHeaders>
        <allowUntrustedCertificates>false</allowUntrustedCertificates>
        <maxPollingErrorsBeforeRemoval>10</maxPollingErrorsBeforeRemoval>
        <pollingIntervalMillis>1000</pollingIntervalMillis>
        <url>http://localhost:8080/metrics</url>
        <destination>http-device</destination>
        <id>HTTPEndpoint</id>
    </http>
    ...
</protocol-adapters>

public class SimulationProtocolAdapterFactory implements ProtocolAdapterFactory<SimulationAdapterConfig> {

    @Override
    public @NotNull ProtocolAdapterInformation getInformation() {
        return SimulationProtocolAdapterInformation.INSTANCE;
    }

    @Override
    public @NotNull ProtocolAdapter createAdapter(@NotNull final ProtocolAdapterInformation adapterInformation, @NotNull final ProtocolAdapterInput<SimulationAdapterConfig> input) {
        return new SimulationProtocolAdapter(adapterInformation, input.getConfig(), input.getMetricRegistry());
    }

    @Override
    public @NotNull SimulationAdapterConfig convertConfigObject(final @NotNull Map<@NotNull String, Object> config) {
        return SimulationConfigConverter.convertConfig(config);
    }

    @Override
    public Map<String, Object> unconvertConfigObject(final CustomConfig config) {
        return SimulationConfigConverter.unconvertConfig(config);
    }

    @Override
    public @NotNull Class<SimulationAdapterConfig> getConfigClass() {
        return SimulationAdapterConfig.class;
    }

}

INFO  - Loaded 2 protocol adapters: ['ModBus TCP', 'OPC-UA Client']

+ your-adapter.jar
- META-INF/
    + services/
    -- com.hivemq.edge.modules.api.adapters.ProtocolAdapterFactory
- com
    + yourorganisation
        + adapter
        -- <ProtocolName>AdapterFactory
        -- <ProtocolName>AdapterInformation
        -- <ProtocolName>AdapterConfig
        -- <ProtocolName>AdapterConfigConverter
        -- <ProtocolName>Adapter