Modifier and Type | Method and Description |
---|---|
AMQConstant |
AMQException.getErrorCode()
Gets the AMQ protocol exception code associated with this exception.
|
Constructor and Description |
---|
AMQChannelClosedException(AMQConstant errorCode,
String msg,
Throwable cause) |
AMQChannelException(AMQConstant errorCode,
String msg,
int classId,
int methodId,
MethodRegistry methodRegistry) |
AMQConnectionClosedException(AMQConstant errorCode,
String msg,
Throwable cause) |
AMQConnectionException(AMQConstant errorCode,
String msg,
AMQMethodBody body,
MethodRegistry methodRegistry) |
AMQConnectionException(AMQConstant errorCode,
String msg,
int classId,
int methodId,
MethodRegistry methodRegistry,
Throwable cause) |
AMQException(AMQConstant errorCode,
boolean isHardError,
String message,
Throwable cause) |
AMQException(AMQConstant errorCode,
String message) |
AMQException(AMQConstant errorCode,
String msg,
Throwable cause)
Constructor for a Protocol Exception
|
AMQProtocolException(AMQConstant errorCode,
String msg,
Throwable cause)
Constructor for a Protocol Exception
|
AMQUndeliveredException(AMQConstant errorCode,
String msg,
Object bounced,
Throwable cause) |
Constructor and Description |
---|
AMQAuthenticationException(AMQConstant error,
String msg,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
boolean |
AMQProtocolSession.channelClosed(int channelId,
AMQConstant code,
String text)
Called from the ChannelClose handler when a channel close frame is received.
|
Modifier and Type | Method and Description |
---|---|
AMQChannelException |
AMQMethodBodyImpl.getChannelException(AMQConstant code,
String message,
MethodRegistry methodRegistry) |
AMQChannelException |
AMQMethodBody.getChannelException(AMQConstant code,
String message,
MethodRegistry methodRegistry) |
AMQConnectionException |
AMQMethodBodyImpl.getConnectionException(AMQConstant code,
String message,
MethodRegistry methodRegistry) |
AMQConnectionException |
AMQMethodBody.getConnectionException(AMQConstant code,
String message,
MethodRegistry methodRegistry) |
Constructor and Description |
---|
AMQFrameDecodingException(AMQConstant errorCode,
String message) |
AMQFrameDecodingException(AMQConstant errorCode,
String message,
Throwable cause) |
Modifier and Type | Field and Description |
---|---|
static AMQConstant |
AMQConstant.ACCESS_REFUSED
The client attempted to work with a server entity to which it has no access due to security settings.
|
static AMQConstant |
AMQConstant.ALREADY_EXISTS
The client attempted to work with a server entity to which it has no access because another client is
working with it.
|
static AMQConstant |
AMQConstant.ARGUMENT_INVALID |
static AMQConstant |
AMQConstant.CHANNEL_ERROR
The client attempted to work with a channel that had not been correctly opened.
|
static AMQConstant |
AMQConstant.COMMAND_INVALID
The client sent an invalid sequence of frames, attempting to perform an operation that was considered invalid
by the server.
|
static AMQConstant |
AMQConstant.CONNECTION_FORCED
An operator intervened to close the connection for some reason.
|
static AMQConstant |
AMQConstant.FRAME_END |
static AMQConstant |
AMQConstant.FRAME_ERROR
The client sent a malformed frame that the server could not decode.
|
static AMQConstant |
AMQConstant.FRAME_MIN_SIZE |
static AMQConstant |
AMQConstant.IN_USE
The client requested a method that was not allowed because some precondition failed.
|
static AMQConstant |
AMQConstant.INTERNAL_ERROR
The server could not complete the method because of an internal error.
|
static AMQConstant |
AMQConstant.INVALID_ARGUMENT |
static AMQConstant |
AMQConstant.INVALID_PATH
The client tried to work with an unknown virtual host or cluster.
|
static AMQConstant |
AMQConstant.INVALID_ROUTING_KEY |
static AMQConstant |
AMQConstant.MESSAGE_TOO_LARGE
The client attempted to transfer content larger than the server could accept at the present time.
|
static AMQConstant |
AMQConstant.NO_CONSUMERS
When the exchange cannot deliver to a consumer when the immediate flag is set.
|
static AMQConstant |
AMQConstant.NO_ROUTE
When the exchange cannot route the result of a .Publish, most likely due to an invalid routing key.
|
static AMQConstant |
AMQConstant.NOT_ALLOWED
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.
|
static AMQConstant |
AMQConstant.NOT_DELIVERED
The client asked for a specific message that is no longer available.
|
static AMQConstant |
AMQConstant.NOT_FOUND
The client attempted to work with a server entity that does not exist.
|
static AMQConstant |
AMQConstant.NOT_IMPLEMENTED
The client tried to use functionality that is not implemented in the server.
|
static AMQConstant |
AMQConstant.REPLY_SUCCESS
Indicates that the method completed successfully.
|
static AMQConstant |
AMQConstant.REQUEST_TIMEOUT |
static AMQConstant |
AMQConstant.RESOURCE_ERROR
The server could not complete the method because it lacked sufficient resources.
|
static AMQConstant |
AMQConstant.SYNTAX_ERROR
The client sent a frame that contained illegal values for one or more fields.
|
static AMQConstant |
AMQConstant.UNSUPPORTED_CLIENT_PROTOCOL_ERROR
The client imp does not support the protocol version
|
Modifier and Type | Method and Description |
---|---|
static AMQConstant |
AMQConstant.getConstant(int code)
Creates a constant for a status code by looking up the code in the map of known codes.
|
Modifier and Type | Method and Description |
---|---|
void |
AMQSessionModel.close(AMQConstant cause,
String message) |
Modifier and Type | Method and Description |
---|---|
void |
ServerSession.close(AMQConstant cause,
String message) |
void |
AMQPConnection_0_10.closeSessionAsync(AMQSessionModel<?> session,
AMQConstant cause,
String message) |
void |
ServerConnection.closeSessionAsync(ServerSession session,
AMQConstant cause,
String message) |
void |
AMQPConnection_0_10.sendConnectionCloseAsync(AMQConstant cause,
String message) |
void |
ServerConnection.sendConnectionCloseAsync(AMQConstant cause,
String message) |
Modifier and Type | Method and Description |
---|---|
void |
AMQChannel.close(AMQConstant cause,
String message) |
void |
AMQPConnection_0_8.closeChannel(int channelId,
AMQConstant cause,
String message) |
void |
AMQPConnection_0_8.closeChannelAndWriteFrame(AMQChannel channel,
AMQConstant cause,
String message) |
void |
AMQPConnection_0_8.closeSessionAsync(AMQSessionModel<?> session,
AMQConstant cause,
String message) |
void |
AMQPConnection_0_8.sendConnectionCloseAsync(AMQConstant cause,
String message) |
Modifier and Type | Method and Description |
---|---|
void |
Session_1_0.close(AMQConstant cause,
String message) |
void |
AMQPConnection_1_0.closeSessionAsync(AMQSessionModel<?> session,
AMQConstant cause,
String message) |
void |
Connection_1_0.closeSessionAsync(Session_1_0 session,
AMQConstant cause,
String message) |
void |
Connection_1_0.sendConnectionCloseAsync(AMQConstant cause,
String message) |
void |
AMQPConnection_1_0.sendConnectionCloseAsync(AMQConstant cause,
String message) |
Modifier and Type | Method and Description |
---|---|
void |
AMQPConnection.closeSessionAsync(AMQSessionModel<?> session,
AMQConstant cause,
String message) |
void |
AMQPConnection.sendConnectionCloseAsync(AMQConstant connectionForced,
String reason) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.