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

Class AmqpsMessage

java.lang.Object

org.apache.qpid.proton.message.impl.MessageImpl

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

All Implemented Interfaces:

org.apache.qpid.proton.message.Message, org.apache.qpid.proton.message.ProtonJMessage

public class AmqpsMessage
extends org.apache.qpid.proton.message.impl.MessageImpl

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.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.qpid.proton.message.Message

org.apache.qpid.proton.message.Message.Factory

Field Summary

Fields inherited from interface org.apache.qpid.proton.message.Message

DEFAULT_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AmqpsMessage()

Method Summary

Modifier and Type	Method and Description
void	acknowledge(org.apache.qpid.proton.amqp.transport.DeliveryState ackType) Sends acknowledgement of this message using the provided ACK_TYPE.

Methods inherited from class org.apache.qpid.proton.message.impl.MessageImpl

clear, decode, decode, decode, encode, encode, encode2, getAddress, getApplicationProperties, getBody, getContentEncoding, getContentType, getCorrelationId, getCreationTime, getDeliveryAnnotations, getDeliveryCount, getError, getExpiryTime, getFooter, getGroupId, getGroupSequence, getHeader, getMessageAnnotations, getMessageId, getPriority, getProperties, getReplyTo, getReplyToGroupId, getSubject, getTtl, getUserId, isDurable, isFirstAcquirer, setAddress, setApplicationProperties, setBody, setContentEncoding, setContentType, setCorrelationId, setCreationTime, setDeliveryAnnotations, setDeliveryCount, setDurable, setExpiryTime, setFirstAcquirer, setFooter, setGroupId, setGroupSequence, setHeader, setMessageAnnotations, setMessageId, setPriority, setProperties, setReplyTo, setReplyToGroupId, setSubject, setTtl, setUserId, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqpsMessage

public AmqpsMessage()

Method Detail

acknowledge

public void acknowledge(org.apache.qpid.proton.amqp.transport.DeliveryState ackType)

Sends acknowledgement of this message using the provided ACK_TYPE.

Parameters:

ackType - acknowledgement type to send