Modifier and Type | Field and Description |
---|---|
private static Pattern |
exchangeNamePattern
The exchange name consists of a non-empty sequence of these characters:
letters, digits, hyphen, underscore, period, or colon.
|
Constructor and Description |
---|
StubLocal() |
Modifier and Type | Method and Description |
---|---|
static void |
basicConsume(DeliveryListener deliveryListener,
String queueName,
String consumerTag,
boolean exclusive,
boolean noAck,
boolean noLocal,
int channelNumber,
short serverId,
long proxyId) |
static Message |
basicGet(String queueName,
boolean noAck,
short serverId,
long proxyId) |
static void |
basicPublish(PublishRequest publishRequest,
short serverId,
long proxyId) |
private static void |
checkName(String name) |
static void |
exchangeDeclare(String exchangeName,
String type,
boolean durable,
boolean passive) |
static void |
exchangeDelete(String exchangeName,
boolean ifUnused) |
static void |
queueBind(String queueName,
String exchangeName,
String routingKey,
Map<String,Object> arguments,
short serverId,
long proxyId) |
static AMQP.Queue.DeclareOk |
queueDeclare(String queueName,
boolean passive,
boolean durable,
boolean autoDelete,
boolean exclusive,
short serverId,
long proxyId) |
static int |
queueDelete(String queueName,
boolean ifUnused,
boolean ifEmpty,
short serverId,
long proxyId) |
static int |
queuePurge(String queueName,
short serverId,
long proxyId) |
static void |
queueUnbind(String exchangeName,
String queueName,
String routingKey,
Map<String,Object> arguments,
short serverId,
long proxyId) |
private static final Pattern exchangeNamePattern
public static AMQP.Queue.DeclareOk queueDeclare(String queueName, boolean passive, boolean durable, boolean autoDelete, boolean exclusive, short serverId, long proxyId) throws NotFoundException, ResourceLockedException, PreconditionFailedException, AccessRefusedException, TransactionException
public static int queueDelete(String queueName, boolean ifUnused, boolean ifEmpty, short serverId, long proxyId) throws PreconditionFailedException, NotFoundException, ResourceLockedException, TransactionException
public static void queueBind(String queueName, String exchangeName, String routingKey, Map<String,Object> arguments, short serverId, long proxyId) throws NotFoundException, ResourceLockedException, TransactionException
public static void queueUnbind(String exchangeName, String queueName, String routingKey, Map<String,Object> arguments, short serverId, long proxyId) throws NotFoundException, ResourceLockedException
public static int queuePurge(String queueName, short serverId, long proxyId) throws SyntaxErrorException, NotFoundException, ResourceLockedException, TransactionException
private static void checkName(String name) throws AccessRefusedException, PreconditionFailedException
public static void exchangeDeclare(String exchangeName, String type, boolean durable, boolean passive) throws NotFoundException, CommandInvalidException, NotAllowedException, PreconditionFailedException, AccessRefusedException
public static void exchangeDelete(String exchangeName, boolean ifUnused) throws NotFoundException, PreconditionFailedException, AccessRefusedException
public static Message basicGet(String queueName, boolean noAck, short serverId, long proxyId) throws NotFoundException, ResourceLockedException, TransactionException
public static void basicConsume(DeliveryListener deliveryListener, String queueName, String consumerTag, boolean exclusive, boolean noAck, boolean noLocal, int channelNumber, short serverId, long proxyId) throws NotFoundException, ResourceLockedException, AccessRefusedException
public static void basicPublish(PublishRequest publishRequest, short serverId, long proxyId) throws NotFoundException, NoConsumersException, TransactionException
Copyright © 2013 ScalAgent D.T.. All Rights Reserved.