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

Packages that use NotFoundException

Package	Description
org.ow2.joram.mom.amqp

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

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

Modifier and Type	Method	Description
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	Proxy.basicPublish(PublishRequest publishRequest)
static void	StubAgentIn.basicPublish(PublishRequest publishRequest, short serverId, long proxyId)
static void	StubLocal.basicPublish(PublishRequest publishRequest, short serverId, long proxyId)
protected void	IExchange.checkPublication(boolean mandatory)
private void	Proxy.doCancel(String consumerTag, int channelNumber, QueueShell queueShell)
void	DirectExchange.doPublish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
void	FanoutExchange.doPublish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
void	HeadersExchange.doPublish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
abstract void	IExchange.doPublish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
void	TopicExchange.doPublish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
void	Proxy.exchangeDeclare(AMQP.Exchange.Declare exchangeDeclare)
static void	StubAgentIn.exchangeDeclare(AMQP.Exchange.Declare exchangeDeclare)
static void	StubLocal.exchangeDeclare(String exchangeName, String type, boolean durable, boolean passive)
void	Proxy.exchangeDelete(AMQP.Exchange.Delete exchangeDelete)
static void	StubAgentIn.exchangeDelete(AMQP.Exchange.Delete exchangeDelete)
static void	StubLocal.exchangeDelete(String exchangeName, boolean ifUnused)
void	IExchange.publish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, 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)
void	Proxy.queueUnbind(AMQP.Queue.Unbind queueUnbind)
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)
void	DirectExchange.unbind(String queueName, String routingKey, Map<String,Object> arguments)
void	FanoutExchange.unbind(String queueName, String routingKey, Map<String,Object> arguments)
void	HeadersExchange.unbind(String queueName, String routingKey, Map<String,Object> arguments)
abstract void	IExchange.unbind(String queueName, String routingKey, Map<String,Object> arguments)
void	TopicExchange.unbind(String queueName, String routingKey, Map<String,Object> arguments)