public class StubAgentIn extends Object
StubAgentIn
class handles input interactions with other Joram
AMQP servers.Modifier and Type | Class and Description |
---|---|
(package private) static class |
StubAgentIn.Null |
Modifier and Type | Field and Description |
---|---|
static org.objectweb.util.monolog.api.Logger |
logger
logger
|
private static StubAgentIn.Null |
nullResponse |
Constructor and Description |
---|
StubAgentIn() |
Modifier and Type | Method and Description |
---|---|
private static void |
addBoundExchange(AddBoundExchange request,
short serverId,
long proxyId) |
static void |
basicAck(String queueName,
List<Long> idsToAck) |
static Boolean |
basicCancel(String consumerTag,
String queueName,
int channelNumber,
short serverId,
long proxyId) |
static void |
basicConsume(AMQP.Basic.Consume basicConsume,
short serverId,
long proxyId) |
static Message |
basicGet(AMQP.Basic.Get basicGet,
short serverId,
long proxyId) |
static void |
basicPublish(PublishRequest publishRequest,
short serverId,
long proxyId) |
static void |
basicRecover(String queueName,
List<Long> idsToRecover) |
private static Object |
doProcessMethod(AbstractMarshallingMethod method,
short serverId,
long proxyId) |
static void |
exchangeDeclare(AMQP.Exchange.Declare exchangeDeclare) |
static void |
exchangeDelete(AMQP.Exchange.Delete exchangeDelete) |
static void |
processRequest(AgentId from,
long keyLock,
long proxyId,
Object request) |
static void |
processResponse(AgentId from,
long keyLock,
Object response) |
private static void |
publishToQueue(PublishToQueue request) |
static void |
queueBind(AMQP.Queue.Bind queueBind,
short serverId,
long proxyId) |
static AMQP.Queue.DeclareOk |
queueDeclare(AMQP.Queue.Declare queueDeclare,
short serverId,
long proxyId) |
static AMQP.Queue.DeleteOk |
queueDelete(AMQP.Queue.Delete queueDelete,
short serverId,
long proxyId) |
static AMQP.Queue.PurgeOk |
queuePurge(AMQP.Queue.Purge queuePurge,
short serverId,
long proxyId) |
static void |
queueUnbind(AMQP.Queue.Unbind queueUnbind,
short serverId,
long proxyId) |
private static void |
removeBoundExchange(RemoveBoundExchange request,
short serverId,
long proxyId) |
private static void |
removeQueueBindings(RemoveQueueBindings request) |
public static org.objectweb.util.monolog.api.Logger logger
private static StubAgentIn.Null nullResponse
public static void processResponse(AgentId from, long keyLock, Object response)
from
- keyLock
- response
- public static void processRequest(AgentId from, long keyLock, long proxyId, Object request)
from
- keyLock
- request
- private static Object doProcessMethod(AbstractMarshallingMethod method, short serverId, long proxyId) throws AMQPException
method
- Exception
AMQPException
private static void removeQueueBindings(RemoveQueueBindings request) throws TransactionException
TransactionException
private static void addBoundExchange(AddBoundExchange request, short serverId, long proxyId) throws ResourceLockedException, TransactionException
private static void publishToQueue(PublishToQueue request) throws TransactionException
TransactionException
private static void removeBoundExchange(RemoveBoundExchange request, short serverId, long proxyId) throws ResourceLockedException
ResourceLockedException
public static Boolean basicCancel(String consumerTag, String queueName, int channelNumber, short serverId, long proxyId) throws NotFoundException, ResourceLockedException, PreconditionFailedException, TransactionException
public static void basicConsume(AMQP.Basic.Consume basicConsume, short serverId, long proxyId) throws NotFoundException, ResourceLockedException, AccessRefusedException
public static Message basicGet(AMQP.Basic.Get basicGet, short serverId, long proxyId) throws NotFoundException, ResourceLockedException, TransactionException
public static void basicPublish(PublishRequest publishRequest, short serverId, long proxyId) throws NotFoundException
NotFoundException
public static void basicRecover(String queueName, List<Long> idsToRecover) throws TransactionException
TransactionException
public static void exchangeDeclare(AMQP.Exchange.Declare exchangeDeclare) throws CommandInvalidException, PreconditionFailedException, NotAllowedException, NotFoundException, AccessRefusedException
public static void exchangeDelete(AMQP.Exchange.Delete exchangeDelete) throws NotFoundException, PreconditionFailedException, AccessRefusedException
public static void queueBind(AMQP.Queue.Bind queueBind, short serverId, long proxyId) throws NotFoundException, ResourceLockedException, TransactionException
public static AMQP.Queue.DeclareOk queueDeclare(AMQP.Queue.Declare queueDeclare, short serverId, long proxyId) throws ResourceLockedException, NotFoundException, PreconditionFailedException, AccessRefusedException, TransactionException
public static AMQP.Queue.DeleteOk queueDelete(AMQP.Queue.Delete queueDelete, short serverId, long proxyId) throws NotFoundException, PreconditionFailedException, ResourceLockedException, TransactionException
public static AMQP.Queue.PurgeOk queuePurge(AMQP.Queue.Purge queuePurge, short serverId, long proxyId) throws NotFoundException, SyntaxErrorException, ResourceLockedException, TransactionException
public static void queueUnbind(AMQP.Queue.Unbind queueUnbind, short serverId, long proxyId) throws NotFoundException, ResourceLockedException
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.