Package org.ow2.joram.mom.amqp

Class StubLocal

java.lang.Object

org.ow2.joram.mom.amqp.StubLocal

public class StubLocal
extends Object

The StubLocal class handles interactions with local AMQP objects.

Field Summary

Fields

Modifier and Type	Field	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 Summary

Constructors

Constructor	Description
StubLocal()

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

exchangeNamePattern

private static final Pattern exchangeNamePattern

The exchange name consists of a non-empty sequence of these characters: letters, digits, hyphen, underscore, period, or colon.

Constructor Detail

StubLocal

public StubLocal()

Method Detail

queueDeclare

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

Throws:

NotFoundException

ResourceLockedException

PreconditionFailedException

AccessRefusedException

TransactionException

queueDelete

public static int queueDelete(String queueName,
                              boolean ifUnused,
                              boolean ifEmpty,
                              short serverId,
                              long proxyId)
                       throws PreconditionFailedException,
                              NotFoundException,
                              ResourceLockedException,
                              TransactionException

Throws:

PreconditionFailedException

NotFoundException

ResourceLockedException

TransactionException

queueBind

public static void queueBind(String queueName,
                             String exchangeName,
                             String routingKey,
                             Map<String,Object> arguments,
                             short serverId,
                             long proxyId)
                      throws NotFoundException,
                             ResourceLockedException,
                             TransactionException

Throws:

NotFoundException

ResourceLockedException

TransactionException

queueUnbind

public static void queueUnbind(String exchangeName,
                               String queueName,
                               String routingKey,
                               Map<String,Object> arguments,
                               short serverId,
                               long proxyId)
                        throws NotFoundException,
                               ResourceLockedException

Throws:

NotFoundException

ResourceLockedException

queuePurge

public static int queuePurge(String queueName,
                             short serverId,
                             long proxyId)
                      throws SyntaxErrorException,
                             NotFoundException,
                             ResourceLockedException,
                             TransactionException

Throws:

SyntaxErrorException

NotFoundException

ResourceLockedException

TransactionException

checkName

private static void checkName(String name)
                       throws AccessRefusedException,
                              PreconditionFailedException

Throws:

AccessRefusedException

PreconditionFailedException

exchangeDeclare

public static void exchangeDeclare(String exchangeName,
                                   String type,
                                   boolean durable,
                                   boolean passive)
                            throws NotFoundException,
                                   CommandInvalidException,
                                   NotAllowedException,
                                   PreconditionFailedException,
                                   AccessRefusedException

Throws:

NotFoundException

CommandInvalidException

NotAllowedException

PreconditionFailedException

AccessRefusedException

exchangeDelete

public static void exchangeDelete(String exchangeName,
                                  boolean ifUnused)
                           throws NotFoundException,
                                  PreconditionFailedException,
                                  AccessRefusedException

Throws:

NotFoundException

PreconditionFailedException

AccessRefusedException

basicGet

public static Message basicGet(String queueName,
                               boolean noAck,
                               short serverId,
                               long proxyId)
                        throws NotFoundException,
                               ResourceLockedException,
                               TransactionException

Throws:

NotFoundException

ResourceLockedException

TransactionException

basicConsume

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

Throws:

NotFoundException

ResourceLockedException

AccessRefusedException

basicPublish

public static void basicPublish(PublishRequest publishRequest,
                                short serverId,
                                long proxyId)
                         throws NotFoundException,
                                NoConsumersException,
                                TransactionException

Throws:

NotFoundException

NoConsumersException

TransactionException