Package org.ow2.joram.mom.amqp

Class StubAgentOut

java.lang.Object

org.ow2.joram.mom.amqp.StubAgentOut

All Implemented Interfaces:

DeliveryListener

public class StubAgentOut
extends Object
implements DeliveryListener

The StubAgentOut class handles output interactions with other Joram AMQP servers.

Field Summary

Fields

Modifier and Type	Field	Description
private static long	lockCount
private static Logger	logger	logger
private static long	timeOut

Constructor Summary

Constructors

Constructor	Description
StubAgentOut(long timeOut)

Method Summary

Modifier and Type	Method	Description
static void	asyncSend(Object request, short serverId)
static void	asyncSend(Object request, short serverId, long proxyId)
boolean	deliver(String consumerTag, int channelId, Queue queue, short serverId, long proxyId)
static Long	getNextLock()
static Object	syncSend(Object request, short serverId)
static Object	syncSend(Object request, short serverId, long proxyId)

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Logger logger

logger

timeOut

private static long timeOut

lockCount

private static long lockCount

Constructor Detail

StubAgentOut

public StubAgentOut(long timeOut)

Parameters:

timeOut -

Method Detail

getNextLock

public static Long getNextLock()

Returns:

syncSend

public static Object syncSend(Object request,
                              short serverId)
                       throws AMQPException

Parameters:

request -

serverId -

Returns:

Throws:

InterruptedException

AMQPException

syncSend

public static Object syncSend(Object request,
                              short serverId,
                              long proxyId)
                       throws AMQPException

Parameters:

request -

serverId -

proxyId -

Returns:

Throws:

AMQPException

asyncSend

public static void asyncSend(Object request,
                             short serverId)

Parameters:

request -

serverId -

asyncSend

public static void asyncSend(Object request,
                             short serverId,
                             long proxyId)

Parameters:

request -

serverId -

proxyId -

deliver

public boolean deliver(String consumerTag,
                       int channelId,
                       Queue queue,
                       short serverId,
                       long proxyId)

Specified by:

deliver in interface DeliveryListener