public class StubAgentOut extends Object implements DeliveryListener
StubAgentOut
class handles output interactions with other Joram
AMQP servers.Modifier and Type | Field and Description |
---|---|
private static long |
lockCount |
static Logger |
logger
logger
|
private static long |
timeOut |
Constructor and Description |
---|
StubAgentOut(long timeOut) |
Modifier and Type | Method and 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) |
public static Logger logger
private static long timeOut
private static long lockCount
public static Long getNextLock()
public static Object syncSend(Object request, short serverId) throws AMQPException
request
- serverId
- InterruptedException
AMQPException
public static Object syncSend(Object request, short serverId, long proxyId) throws AMQPException
request
- serverId
- proxyId
- AMQPException
public static void asyncSend(Object request, short serverId)
request
- serverId
- public static void asyncSend(Object request, short serverId, long proxyId)
request
- serverId
- proxyId
- public boolean deliver(String consumerTag, int channelId, Queue queue, short serverId, long proxyId)
deliver
in interface DeliveryListener
Copyright © 2022 ScalAgent D.T.. All rights reserved.