Package | Description |
---|---|
com.rabbitmq.client |
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
|
com.rabbitmq.client.impl |
Implementations of interfaces specified in the client API, and their supporting classes.
|
com.rabbitmq.client.impl.recovery |
Implementation of connection and topology recovery.
|
com.rabbitmq.tools.jsonrpc |
JSON-RPC client and server classes for supporting JSON-RPC over an AMQP transport.
|
Modifier and Type | Field and Description |
---|---|
static AMQP.BasicProperties |
MessageProperties.BASIC
Content-type "application/octet-stream", deliveryMode 1 (nonpersistent), priority zero
|
static AMQP.BasicProperties |
MessageProperties.MINIMAL_BASIC
Empty basic properties, with no fields set
|
static AMQP.BasicProperties |
MessageProperties.MINIMAL_PERSISTENT_BASIC
Empty basic properties, with only deliveryMode set to 2 (persistent)
|
static AMQP.BasicProperties |
MessageProperties.PERSISTENT_BASIC
Content-type "application/octet-stream", deliveryMode 2 (persistent), priority zero
|
static AMQP.BasicProperties |
MessageProperties.PERSISTENT_TEXT_PLAIN
Content-type "text/plain", deliveryMode 2 (persistent), priority zero
|
protected AMQP.BasicProperties |
RpcClient.Response.properties |
static AMQP.BasicProperties |
MessageProperties.TEXT_PLAIN
Content-type "text/plain", deliveryMode 1 (nonpersistent), priority zero
|
Modifier and Type | Method and Description |
---|---|
AMQP.BasicProperties |
AMQP.BasicProperties.Builder.build() |
AMQP.BasicProperties |
RpcClient.Response.getProperties() |
AMQP.BasicProperties |
Return.getProperties() |
AMQP.BasicProperties |
Delivery.getProperties()
Retrieve the message properties.
|
AMQP.BasicProperties |
GetResponse.getProps()
Get the
BasicProperties included in this response |
protected AMQP.BasicProperties |
RpcServer.postprocessReplyProperties(Delivery request,
AMQP.BasicProperties.Builder builder)
Gives a chance to set/modify reply properties after the handling call
|
protected AMQP.BasicProperties |
RpcServer.preprocessReplyProperties(Delivery request,
AMQP.BasicProperties.Builder builder)
Gives a chance to set/modify reply properties before handling call.
|
Modifier and Type | Method and Description |
---|---|
void |
Channel.basicPublish(String exchange,
String routingKey,
AMQP.BasicProperties props,
byte[] body)
Publish a message.
|
void |
Channel.basicPublish(String exchange,
String routingKey,
boolean mandatory,
AMQP.BasicProperties props,
byte[] body)
Publish a message.
|
void |
Channel.basicPublish(String exchange,
String routingKey,
boolean mandatory,
boolean immediate,
AMQP.BasicProperties props,
byte[] body)
Publish a message.
|
RpcClient.Response |
RpcClient.doCall(AMQP.BasicProperties props,
byte[] message) |
RpcClient.Response |
RpcClient.doCall(AMQP.BasicProperties props,
byte[] message,
int timeout) |
byte[] |
RpcServer.handleCall(AMQP.BasicProperties requestProperties,
byte[] requestBody,
AMQP.BasicProperties replyProperties)
Mid-level response method.
|
byte[] |
StringRpcServer.handleCall(byte[] requestBody,
AMQP.BasicProperties replyProperties)
Overridden to do UTF-8 processing, and delegate to
handleStringCall.
|
byte[] |
RpcServer.handleCall(byte[] requestBody,
AMQP.BasicProperties replyProperties)
High-level response method.
|
byte[] |
MapRpcServer.handleCall(byte[] requestBody,
AMQP.BasicProperties replyProperties)
Overridden to delegate to handleMapCall.
|
byte[] |
RpcServer.handleCall(Delivery request,
AMQP.BasicProperties replyProperties)
Lowest-level response method.
|
void |
RpcServer.handleCast(AMQP.BasicProperties requestProperties,
byte[] requestBody)
Mid-level handler method.
|
void |
Consumer.handleDelivery(String consumerTag,
Envelope envelope,
AMQP.BasicProperties properties,
byte[] body)
Called when a
basic.deliver is received for this consumer. |
void |
DefaultConsumer.handleDelivery(String consumerTag,
Envelope envelope,
AMQP.BasicProperties properties,
byte[] body)
|
Map<String,Object> |
MapRpcServer.handleMapCall(Map<String,Object> request,
AMQP.BasicProperties replyProperties)
Delegates to
MapRpcServer.handleMapCall(Map) . |
void |
ReturnListener.handleReturn(int replyCode,
String replyText,
String exchange,
String routingKey,
AMQP.BasicProperties properties,
byte[] body) |
String |
StringRpcServer.handleStringCall(String request,
AMQP.BasicProperties replyProperties)
Delegates to handleStringCall(String).
|
byte[] |
RpcClient.primitiveCall(AMQP.BasicProperties props,
byte[] message) |
byte[] |
RpcClient.primitiveCall(AMQP.BasicProperties props,
byte[] message,
int timeout) |
void |
RpcClient.publish(AMQP.BasicProperties props,
byte[] message) |
Constructor and Description |
---|
Delivery(Envelope envelope,
AMQP.BasicProperties properties,
byte[] body) |
GetResponse(Envelope envelope,
AMQP.BasicProperties props,
byte[] body,
int messageCount)
Construct a
GetResponse with the specified construction parameters |
Response(String consumerTag,
Envelope envelope,
AMQP.BasicProperties properties,
byte[] body) |
Return(int replyCode,
String replyText,
String exchange,
String routingKey,
AMQP.BasicProperties properties,
byte[] body) |
Modifier and Type | Method and Description |
---|---|
void |
ChannelN.basicPublish(String exchange,
String routingKey,
AMQP.BasicProperties props,
byte[] body)
Public API - Publish a message.
|
void |
ChannelN.basicPublish(String exchange,
String routingKey,
boolean mandatory,
AMQP.BasicProperties props,
byte[] body)
Public API - Publish a message.
|
void |
ChannelN.basicPublish(String exchange,
String routingKey,
boolean mandatory,
boolean immediate,
AMQP.BasicProperties props,
byte[] body)
Public API - Publish a message.
|
Modifier and Type | Method and Description |
---|---|
void |
AutorecoveringChannel.basicPublish(String exchange,
String routingKey,
AMQP.BasicProperties props,
byte[] body) |
void |
AutorecoveringChannel.basicPublish(String exchange,
String routingKey,
boolean mandatory,
AMQP.BasicProperties props,
byte[] body) |
void |
AutorecoveringChannel.basicPublish(String exchange,
String routingKey,
boolean mandatory,
boolean immediate,
AMQP.BasicProperties props,
byte[] body) |
Modifier and Type | Method and Description |
---|---|
String |
JsonRpcServer.handleStringCall(String requestBody,
AMQP.BasicProperties replyProperties)
Override our superclass' method, dispatching to doCall.
|
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.