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

Class AmqpSend

java.lang.Object

com.microsoft.azure.sdk.iot.service.transport.amqps.AmqpSend

public class AmqpSend
extends Object

Instance of the QPID-Proton-J BaseHandler class overriding the events what are needed to handle high level open, close and send methods. Initialize and use AmqpsSendHandler class for low level ampqs operations.

Field Summary

Fields

Modifier and Type	Field and Description
protected AmqpSendHandler	amqpSendHandler
protected String	hostName
protected IotHubServiceClientProtocol	iotHubServiceClientProtocol
protected String	sasToken
protected String	userName

Constructor Summary

Constructors

Constructor and Description
AmqpSend(String hostName, String userName, String sasToken, IotHubServiceClientProtocol iotHubServiceClientProtocol) Constructor to set up connection parameters

Method Summary

Modifier and Type	Method and Description
void	close() Invalidate AmqpsSendHandler member variable
void	open() Create AmqpsSendHandler and store it in a member variable
void	send(String deviceId, String moduleId, Message message) Create binary message Initialize and start Proton reactor Send the created message

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

hostName

protected final String hostName

userName

protected final String userName

sasToken

protected final String sasToken

amqpSendHandler

protected AmqpSendHandler amqpSendHandler

iotHubServiceClientProtocol

protected IotHubServiceClientProtocol iotHubServiceClientProtocol

Constructor Detail

AmqpSend

public AmqpSend(String hostName,
                String userName,
                String sasToken,
                IotHubServiceClientProtocol iotHubServiceClientProtocol)

Constructor to set up connection parameters

Parameters:

hostName - The address string of the service (example: AAA.BBB.CCC)

userName - The username string to use SASL authentication (example: user@sas.service)

sasToken - The SAS token string

iotHubServiceClientProtocol - protocol to use

Method Detail

open

public void open()

Create AmqpsSendHandler and store it in a member variable

close

public void close()

Invalidate AmqpsSendHandler member variable

send

public void send(String deviceId,
                 String moduleId,
                 Message message)
          throws IOException,
                 IotHubException

Create binary message Initialize and start Proton reactor Send the created message

Parameters:

deviceId - The device name string

moduleId - The module name string

message - The message to be sent

Throws:

IOException - This exception is thrown if the AmqpSend object is not initialized

IotHubException - If IotHub rejects the message for any reason