CloudToDeviceMessageSenderLinkHandler Class

  • java.lang.Object
    • BaseHandler
      • SenderLinkHandler
        • com.microsoft.azure.sdk.iot.service.transport.amqps.CloudToDeviceMessageSenderLinkHandler

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

com.microsoft.azure.sdk.iot.service.transport.amqps.SenderLinkHandler.onLinkInit(Event) com.microsoft.azure.sdk.iot.service.transport.amqps.SenderLinkHandler.onLinkLocalClose(Event) com.microsoft.azure.sdk.iot.service.transport.amqps.SenderLinkHandler.onLinkLocalOpen(Event) com.microsoft.azure.sdk.iot.service.transport.amqps.SenderLinkHandler.onLinkRemoteClose(Event) com.microsoft.azure.sdk.iot.service.transport.amqps.SenderLinkHandler.onLinkRemoteOpen(Event)

Constructor Details

CloudToDeviceMessageSenderLinkHandler

public CloudToDeviceMessageSenderLinkHandler(Sender sender, String linkCorrelationId, LinkStateCallback linkStateCallback)

Parameters:

sender
linkCorrelationId
linkStateCallback

Method Details

getLinkInstanceType

protected String getLinkInstanceType()

onConnectionRemoteClose

public void onConnectionRemoteClose(Event event)

Parameters:

event

onDelivery

public void onDelivery(Event event)

Parameters:

event

onLinkFlow

public void onLinkFlow(Event event)

Event handler for the link flow event

Parameters:

event - The proton event object

onTimerTask

public void onTimerTask(Event event)

Parameters:

event

sendAsync

public void sendAsync(String deviceId, String moduleId, Message iotHubMessage, Consumer callback, Object context)

Parameters:

deviceId
moduleId
iotHubMessage
callback
context

Applies to