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

Packages that use TransactionException

Package	Description
org.ow2.joram.mom.amqp

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

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

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)
static Boolean	StubAgentIn.basicCancel(String consumerTag, String queueName, int channelNumber, short serverId, long proxyId)
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	StubLocal.basicPublish(PublishRequest publishRequest, short serverId, long proxyId)
void	Proxy.basicRecover(boolean requeue, int channelNumber)
static void	StubAgentIn.basicRecover(String queueName, List<Long> idsToRecover)
void	Proxy.basicReject(AMQP.Basic.Reject basicReject)
int	Queue.clear(short serverId, long proxyId)
private void	Proxy.commitTx()
void	Queue.deleteQueue(String queueName, short serverId, long proxyId)
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)
static IExchange	IExchange.loadExchange(String name)
static Queue	Queue.loadQueue(String name)
private static void	AMQPService.loads()
void	IExchange.publish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
void	Queue.publish(Message msg, boolean immediate, short serverId, long proxyId)
protected void	IExchange.publishToQueue(String queueName, String routingKey, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
private static void	StubAgentIn.publishToQueue(PublishToQueue request)
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)
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)
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)
static AMQP.Queue.PurgeOk	StubAgentIn.queuePurge(AMQP.Queue.Purge queuePurge, short serverId, long proxyId)
static int	StubLocal.queuePurge(String queueName, short serverId, long proxyId)
Message	Queue.receive(boolean noAck, short serverId, long proxyId)
void	Queue.recoverMessages(List<Long> idsToRecover)
abstract void	IExchange.removeQueueBindings(String queueName)
private static void	StubAgentIn.removeQueueBindings(RemoveQueueBindings request)
private void	Queue.saveBoundExchange(String exchange)
private void	Queue.saveMessage(Message msg)
private void	Queue.saveQueue(Queue queue)
void	Proxy.txCommit(int channelNumber)

Constructors in org.ow2.joram.mom.amqp that throw TransactionException

Constructor	Description
Queue(String name, boolean durable, boolean autodelete, boolean exclusive, short serverId, long proxyId)