Share via

com.microsoft.azure.sdk.iot.device.transport.amqps

  • Reference

AMQPS IoT Hub transport and communication classes.

Classes

AmqpsIotHubConnection

An AMQPS IotHub connection between a device and an IoTHub or Edgehub. This class is responsible for reacting to connection level and reactor level events. It is also responsible for creating sessions and handlers for those sessions. An instance of this object may be reused after it has been closed. This class is used for both single-plexed and multiplexed connections.

AmqpsMessage

Extension of the QPID-Proton-J MessageImpl class which implements the Message interface. Adds a Delivery object as a private member variable and adds a new ACK_TYPE enum. Adds the ability to easily acknowledge a single message.

AmqpsSendResult
LoggingFlowController

Copy of org.apache.qpid.proton.reactor.FlowController but with some small edits for logging purposes.

Use this FlowController to automatically flow link credit back to the service from this client's receiver links after each delivery on the receiver link.

ReactorRunner