Uses of Class
org.ow2.joram.mom.amqp.exceptions.ResourceLockedException

Packages that use ResourceLockedException

Package	Description
org.ow2.joram.mom.amqp

Uses of ResourceLockedException in org.ow2.joram.mom.amqp

Methods in org.ow2.joram.mom.amqp that throw ResourceLockedException

Modifier and Type	Method	Description
void	Queue.addBoundExchange(String exchange, short serverId, long proxyId)
private static void	StubAgentIn.addBoundExchange(AddBoundExchange request, short serverId, long proxyId)
void	Proxy.basicCancel(String consumerTag, int channelNumber)
static Boolean	StubAgentIn.basicCancel(String consumerTag, String queueName, int channelNumber, short serverId, long proxyId)
void	Proxy.basicConsume(AMQP.Basic.Consume basicConsume)
static void	StubAgentIn.basicConsume(AMQP.Basic.Consume basicConsume, short serverId, long proxyId)
static void	StubLocal.basicConsume(DeliveryListener deliveryListener, String queueName, String consumerTag, boolean exclusive, boolean noAck, boolean noLocal, int channelNumber, short serverId, long proxyId)
GetResponse	Proxy.basicGet(AMQP.Basic.Get basicGet)
static Message	StubAgentIn.basicGet(AMQP.Basic.Get basicGet, short serverId, long proxyId)
static Message	StubLocal.basicGet(String queueName, boolean noAck, short serverId, long proxyId)
void	Queue.cancel(String consumerTag, int channelNumber, short serverId, long proxyId)
int	Queue.clear(short serverId, long proxyId)
void	Queue.consume(DeliveryListener proxy, int channelId, String consumerTag, boolean exclusiveConsumer, boolean noAck, boolean noLocal, short serverId, long proxyId)
void	Queue.deleteQueue(String queueName, short serverId, long proxyId)
private void	Proxy.doCancel(String consumerTag, int channelNumber, QueueShell queueShell)
AMQP.Queue.DeclareOk	Queue.getInfo(short serverId, long proxyId)
void	Proxy.queueBind(AMQP.Queue.Bind queueBind)
static void	StubAgentIn.queueBind(AMQP.Queue.Bind queueBind, short serverId, long proxyId)
static void	StubLocal.queueBind(String queueName, String exchangeName, String routingKey, Map<String,Object> arguments, short serverId, long proxyId)
AMQP.Queue.DeclareOk	Proxy.queueDeclare(AMQP.Queue.Declare queueDeclare)
static AMQP.Queue.DeclareOk	StubAgentIn.queueDeclare(AMQP.Queue.Declare queueDeclare, short serverId, long proxyId)
static AMQP.Queue.DeclareOk	StubLocal.queueDeclare(String queueName, boolean passive, boolean durable, boolean autoDelete, boolean exclusive, short serverId, long proxyId)
AMQP.Queue.DeleteOk	Proxy.queueDelete(AMQP.Queue.Delete queueDelete)
static AMQP.Queue.DeleteOk	StubAgentIn.queueDelete(AMQP.Queue.Delete queueDelete, short serverId, long proxyId)
static int	StubLocal.queueDelete(String queueName, boolean ifUnused, boolean ifEmpty, short serverId, long proxyId)
AMQP.Queue.PurgeOk	Proxy.queuePurge(AMQP.Queue.Purge queuePurge)
static AMQP.Queue.PurgeOk	StubAgentIn.queuePurge(AMQP.Queue.Purge queuePurge, short serverId, long proxyId)
static int	StubLocal.queuePurge(String queueName, short serverId, long proxyId)
static void	StubAgentIn.queueUnbind(AMQP.Queue.Unbind queueUnbind, short serverId, long proxyId)
static void	StubLocal.queueUnbind(String exchangeName, String queueName, String routingKey, Map<String,Object> arguments, short serverId, long proxyId)
Message	Queue.receive(boolean noAck, short serverId, long proxyId)
void	Queue.removeBoundExchange(String exchangeName, short serverId, long proxyId)
private static void	StubAgentIn.removeBoundExchange(RemoveBoundExchange request, short serverId, long proxyId)