activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTNIOTransport.java
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpNioTransport.java

activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTWireFormat.java
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpWireFormat.java

activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java

activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpNioSslTransportFactory.java
activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTNIOSSLTransportFactory.java

activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTInactivityMonitor.java
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpInactivityMonitor.java

activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTTransportFactory.java
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpTransportFactory.java