Package | Description |
---|---|
org.ow2.joram.mom.amqp | |
org.ow2.joram.mom.amqp.exceptions |
Modifier and Type | Method and Description |
---|---|
private void |
Proxy.throwException(AMQPException amqe,
int channelNumber,
int classId,
int methodId)
Releases connection or channel resources and close it by sending a
notification to the client.
|
Modifier and Type | Method and Description |
---|---|
private void |
AMQPConnectionListener.acceptConnection() |
void |
Proxy.basicCancel(String consumerTag,
int channelNumber) |
void |
Proxy.basicConsume(AMQP.Basic.Consume basicConsume) |
GetResponse |
Proxy.basicGet(AMQP.Basic.Get basicGet) |
void |
Proxy.channelClose(int channelNumber) |
void |
Proxy.cleanConsumers(short sid) |
private void |
Proxy.doCancel(String consumerTag,
int channelNumber,
QueueShell queueShell) |
protected void |
Proxy.doProcessMethod(AbstractMarshallingMethod method) |
private static Object |
StubAgentIn.doProcessMethod(AbstractMarshallingMethod method,
short serverId,
long proxyId) |
void |
Proxy.exchangeDeclare(AMQP.Exchange.Declare exchangeDeclare) |
void |
Proxy.exchangeDelete(AMQP.Exchange.Delete exchangeDelete) |
void |
Proxy.queueBind(AMQP.Queue.Bind queueBind) |
AMQP.Queue.DeclareOk |
Proxy.queueDeclare(AMQP.Queue.Declare queueDeclare) |
AMQP.Queue.DeleteOk |
Proxy.queueDelete(AMQP.Queue.Delete queueDelete) |
AMQP.Queue.PurgeOk |
Proxy.queuePurge(AMQP.Queue.Purge queuePurge) |
void |
Proxy.queueUnbind(AMQP.Queue.Unbind queueUnbind) |
static Object |
StubAgentOut.syncSend(Object request,
short serverId) |
static Object |
StubAgentOut.syncSend(Object request,
short serverId,
long proxyId) |
private void |
Proxy.throwException(AMQPException amqe,
int channelNumber,
int classId,
int methodId)
Releases connection or channel resources and close it by sending a
notification to the client.
|
Modifier and Type | Class and Description |
---|---|
class |
AccessRefusedException
The client attempted to work with a server entity to which it has no access
due to security settings.
|
class |
ChannelErrorException
Exception thrown if the client attempted to work with a channel that had not
been correctly opened.
|
class |
ChannelException
These exceptions are all associated with failures that affect the current
channel but not other channels in the same connection;
|
class |
CommandInvalidException
Exception thrown if the client sent an invalid sequence of frames, attempting
to perform an operation that was considered invalid by the server.
|
class |
ConnectionException
These exceptions are all associated with failures that preclude any further
activity on the connection and require its closing.
|
class |
FrameErrorException
Exception thrown if the sender sent a malformed frame that the recipient
could not decode.
|
class |
InternalErrorException
Exception thrown if the server could not complete the method because of an
internal error.
|
class |
InterruptedException |
class |
NoConsumersException
Exception thrown when the exchange cannot deliver to a consumer when the
immediate flag is set.
|
class |
NotAllowedException
Exception thrown if the client tried to work with some entity in a manner
that is prohibited by the server, due to security settings or by some other
criteria.
|
class |
NotFoundException
Exception thrown if the client attempted to work with a server entity that
does not exist.
|
class |
NotImplementedException
Exception thrown if the client tried to use functionality that is not
implemented in the server.
|
class |
PreconditionFailedException
Exception thrown if the client requested a method that was not allowed
because some precondition failed.
|
class |
ResourceLockedException
Exception thrown if the client attempted to work with a server entity to
which it has no access because another client is working with it.
|
class |
SyntaxErrorException
Exception thrown if the sender sent a frame that contained illegal values for
one or more fields.
|
class |
TransactionException |
class |
UnexpectedFrameException
Exception thrown if the peer sent a frame that was not expected, usually in
the context of a content header and body.
|
Copyright © 2022 ScalAgent D.T.. All rights reserved.