public class DirectExchange extends IExchange
Modifier and Type | Field and Description |
---|---|
private Map<String,Set<String>> |
bindings |
static String |
DEFAULT_NAME |
static Logger |
logger |
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
static String |
TYPE |
DEFAULT_EXCHANGE_NAME, durable, name, PREFIX_EXCHANGE
Constructor and Description |
---|
DirectExchange() |
DirectExchange(String name,
boolean durable) |
Modifier and Type | Method and Description |
---|---|
void |
bind(String queueName,
String routingKey,
Map<String,Object> arguments) |
void |
doPublish(String routingKey,
boolean mandatory,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
Set<String> |
getBoundQueues() |
String |
getType() |
boolean |
isUnused() |
void |
readExternal(ObjectInput in) |
void |
removeQueueBindings(String queueName) |
void |
setArguments(Map<String,Object> arguments) |
void |
unbind(String queueName,
String routingKey,
Map<String,Object> arguments) |
void |
writeExternal(ObjectOutput out) |
checkPublication, createExchange, deleteExchange, getHandledMessageCount, getName, getPublishedMessageCount, isDurable, loadExchange, publish, publishToQueue, saveExchange
private static final long serialVersionUID
public static final Logger logger
public static final String DEFAULT_NAME
public static final String TYPE
public DirectExchange()
public DirectExchange(String name, boolean durable)
public void unbind(String queueName, String routingKey, Map<String,Object> arguments) throws NotFoundException
unbind
in class IExchange
NotFoundException
public void doPublish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId) throws NotFoundException, NoConsumersException, TransactionException
doPublish
in class IExchange
NotFoundException
NoConsumersException
TransactionException
public void setArguments(Map<String,Object> arguments)
setArguments
in class IExchange
public String getType()
public void removeQueueBindings(String queueName)
removeQueueBindings
in class IExchange
public Set<String> getBoundQueues()
getBoundQueues
in interface IExchangeMBean
getBoundQueues
in class IExchange
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
writeExternal
in class IExchange
out
- IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
readExternal
in class IExchange
in
- IOException
ClassNotFoundException
Copyright © 2022 ScalAgent D.T.. All rights reserved.