public class PublishToQueue extends Object implements Serializable
AMQPRequestNot
to publish a message to a
distant queue after exchange routing.Modifier and Type | Field and Description |
---|---|
private byte[] |
body |
private int |
channelNumber |
private String |
exchangeName |
private boolean |
immediate |
private AMQP.Basic.BasicProperties |
properties |
private long |
proxyId |
private String |
queueName |
private String |
routingKey |
private static long |
serialVersionUID |
private short |
serverId |
Constructor and Description |
---|
PublishToQueue(String queueName,
String exchangeName,
String routingKey,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
Modifier and Type | Method and Description |
---|---|
byte[] |
getBody() |
int |
getChannelNumber() |
String |
getExchangeName() |
Message |
getMessage() |
AMQP.Basic.BasicProperties |
getProperties() |
long |
getProxyId() |
String |
getQueueName() |
String |
getRoutingKey() |
short |
getServerId() |
boolean |
isImmediate() |
private static final long serialVersionUID
private String queueName
private String exchangeName
private String routingKey
private AMQP.Basic.BasicProperties properties
private byte[] body
private short serverId
private long proxyId
private boolean immediate
private int channelNumber
public PublishToQueue(String queueName, String exchangeName, String routingKey, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
public boolean isImmediate()
public String getRoutingKey()
public AMQP.Basic.BasicProperties getProperties()
public byte[] getBody()
public short getServerId()
public long getProxyId()
public String getQueueName()
public String getExchangeName()
public int getChannelNumber()
public Message getMessage()
Copyright © 2021 ScalAgent D.T.. All rights reserved.