AmqpMessage Class

  • java.lang.Object
    • com.microsoft.azure.sdk.iot.provisioning.device.transport.amqp.AmqpMessage

public class AmqpMessage

Constructor Summary

Constructor Description
AmqpMessage()
AmqpMessage(MessageImpl messageImpl)

Consule a MessageImpl object

Method Summary

Modifier and Type Method and Description
void decode(byte[] data, int offset, int length)

Sets the data value

int encode(byte[] data, int offset)
byte [] getAmqpBody()

Returns the amqp body used in the message

Map<String, Object> getApplicationProperty()

Set the application property for the message

void setApplicationProperty(Map<String, Object> userProperties)

Set the application property for the message

void setBody(byte[] msgData)
void setBody(Data msgData)

set the Body of the AMQP message

Constructor Details

AmqpMessage

public AmqpMessage()

AmqpMessage

public AmqpMessage(MessageImpl messageImpl)

Consule a MessageImpl object

Parameters:

messageImpl - the ProtonJ Impl message.

Method Details

decode

public void decode(byte[] data, int offset, int length)

Sets the data value

Parameters:

data -

thebyte[] 

</code> to be decoded </p>
offset - the offset in the byte[]
length - the total length

encode

public int encode(byte[] data, int offset)

Parameters:

data
offset

getAmqpBody

public byte [] getAmqpBody()

Returns the amqp body used in the message

Returns:

Byte array

getApplicationProperty

public Map getApplicationProperty()

Set the application property for the message

Returns:

Map of properties

setApplicationProperty

public void setApplicationProperty(Map userProperties)

Set the application property for the message

Parameters:

userProperties - The user prototype.

setBody

public void setBody(byte[] msgData)

Parameters:

msgData

setBody

public void setBody(Data msgData)

set the Body of the AMQP message

Parameters:

msgData - the AMQP message body.

Applies to