CloudToDeviceMessageSenderLinkHandler Class
- java.
lang. Object - BaseHandler
- SenderLinkHandler
- com.
microsoft. azure. sdk. iot. service. transport. amqps. CloudToDeviceMessageSenderLinkHandler
- com.
public class CloudToDeviceMessageSenderLinkHandler
Instance of the QPID-Proton-J BaseHandler class to override the events what are needed to handle the send operation Contains and sets connection parameters (path, port, endpoint) Maintains the layers of AMQP protocol (Link, Session, Connection, Transport) Creates and sets SASL authentication for transport
Constructor Summary
Constructor | Description | |
---|---|---|
CloudToDeviceMessageSenderLinkHandler(Sender sender, String linkCorrelationId, LinkStateCallback linkStateCallback) |
Method Summary
Modifier and Type | Method and Description |
---|---|
String | getLinkInstanceType() |
void | onConnectionRemoteClose(Event event) |
void | onDelivery(Event event) |
void |
onLinkFlow(Event event)
Event handler for the link flow event |
void | onTimerTask(Event event) |
void | sendAsync(String deviceId, String moduleId, Message iotHubMessage, Consumer<SendResult> callback, Object context) |
Inherited Members
Constructor Details
CloudToDeviceMessageSenderLinkHandler
public CloudToDeviceMessageSenderLinkHandler(Sender sender, String linkCorrelationId, LinkStateCallback linkStateCallback)
Parameters:
Method Details
getLinkInstanceType
protected String getLinkInstanceType()
onConnectionRemoteClose
public void onConnectionRemoteClose(Event event)
Parameters:
onDelivery
public void onDelivery(Event event)
Parameters:
onLinkFlow
public void onLinkFlow(Event event)
Event handler for the link flow event
Parameters:
onTimerTask
public void onTimerTask(Event event)
Parameters:
sendAsync
public void sendAsync(String deviceId, String moduleId, Message iotHubMessage, Consumer
Parameters:
Applies to
Azure SDK for Java