Class PublishToQueue
- java.lang.Object
-
- org.ow2.joram.mom.amqp.structures.PublishToQueue
-
- All Implemented Interfaces:
Serializable
public class PublishToQueue extends Object implements Serializable
This class is used in anAMQPRequestNotto publish a message to a distant queue after exchange routing.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description private byte[]bodyprivate intchannelNumberprivate StringexchangeNameprivate booleanimmediateprivate AMQP.Basic.BasicPropertiespropertiesprivate longproxyIdprivate StringqueueNameprivate StringroutingKeyprivate static longserialVersionUIDprivate shortserverId
-
Constructor Summary
Constructors Constructor Description PublishToQueue(String queueName, String exchangeName, String routingKey, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte[]getBody()intgetChannelNumber()StringgetExchangeName()MessagegetMessage()AMQP.Basic.BasicPropertiesgetProperties()longgetProxyId()StringgetQueueName()StringgetRoutingKey()shortgetServerId()booleanisImmediate()
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
queueName
private String queueName
-
exchangeName
private String exchangeName
-
routingKey
private String routingKey
-
properties
private AMQP.Basic.BasicProperties properties
-
body
private byte[] body
-
serverId
private short serverId
-
proxyId
private long proxyId
-
immediate
private boolean immediate
-
channelNumber
private int channelNumber
-
-
Constructor Detail
-
PublishToQueue
public PublishToQueue(String queueName, String exchangeName, String routingKey, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
-
-
Method Detail
-
isImmediate
public boolean isImmediate()
-
getRoutingKey
public String getRoutingKey()
-
getProperties
public AMQP.Basic.BasicProperties getProperties()
-
getBody
public byte[] getBody()
-
getServerId
public short getServerId()
-
getProxyId
public long getProxyId()
-
getQueueName
public String getQueueName()
-
getExchangeName
public String getExchangeName()
-
getChannelNumber
public int getChannelNumber()
-
getMessage
public Message getMessage()
-
-