Uses of Class
com.rabbitmq.client.AMQP.BasicProperties
Package
Description
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
Implementations of interfaces specified in the client API, and their supporting classes.
Implementation of connection and topology recovery.
JSON-RPC client and server classes for supporting JSON-RPC over an AMQP transport.
-
Uses of AMQP.BasicProperties in com.rabbitmq.client
Modifier and TypeFieldDescriptionstatic final AMQP.BasicProperties
MessageProperties.BASIC
Content-type "application/octet-stream", deliveryMode 1 (nonpersistent), priority zerostatic final AMQP.BasicProperties
MessageProperties.MINIMAL_BASIC
Empty basic properties, with no fields setstatic final AMQP.BasicProperties
MessageProperties.MINIMAL_PERSISTENT_BASIC
Empty basic properties, with only deliveryMode set to 2 (persistent)static final AMQP.BasicProperties
MessageProperties.PERSISTENT_BASIC
Content-type "application/octet-stream", deliveryMode 2 (persistent), priority zerostatic final AMQP.BasicProperties
MessageProperties.PERSISTENT_TEXT_PLAIN
Content-type "text/plain", deliveryMode 2 (persistent), priority zeroprotected AMQP.BasicProperties
RpcClient.Response.properties
static final AMQP.BasicProperties
MessageProperties.TEXT_PLAIN
Content-type "text/plain", deliveryMode 1 (nonpersistent), priority zeroModifier and TypeMethodDescriptionAMQP.BasicProperties.Builder.build()
Delivery.getProperties()
Retrieve the message properties.Return.getProperties()
RpcClient.Response.getProperties()
GetResponse.getProps()
Get theAMQP.BasicProperties
included in this responseprotected AMQP.BasicProperties
RpcServer.postprocessReplyProperties
(Delivery request, AMQP.BasicProperties.Builder builder) Gives a chance to set/modify reply properties after the handling callprotected AMQP.BasicProperties
RpcServer.preprocessReplyProperties
(Delivery request, AMQP.BasicProperties.Builder builder) Gives a chance to set/modify reply properties before handling call.Modifier and TypeMethodDescriptionvoid
Channel.basicPublish
(String exchange, String routingKey, boolean mandatory, boolean immediate, 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, AMQP.BasicProperties props, byte[] body) Publish a message.RpcClient.doCall
(AMQP.BasicProperties props, byte[] message) RpcClient.doCall
(AMQP.BasicProperties props, byte[] message, int timeout) byte[]
MapRpcServer.handleCall
(byte[] requestBody, AMQP.BasicProperties replyProperties) Overridden to delegate to handleMapCall.byte[]
RpcServer.handleCall
(byte[] requestBody, AMQP.BasicProperties replyProperties) High-level response method.byte[]
RpcServer.handleCall
(AMQP.BasicProperties requestProperties, byte[] requestBody, AMQP.BasicProperties replyProperties) Mid-level response method.byte[]
RpcServer.handleCall
(Delivery request, AMQP.BasicProperties replyProperties) Lowest-level response method.byte[]
StringRpcServer.handleCall
(byte[] requestBody, AMQP.BasicProperties replyProperties) Overridden to do UTF-8 processing, and delegate to handleStringCall.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 abasic.deliver
is received for this consumer.void
DefaultConsumer.handleDelivery
(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) MapRpcServer.handleMapCall
(Map<String, Object> request, AMQP.BasicProperties replyProperties) Delegates toMapRpcServer.handleMapCall(Map)
.void
ReturnListener.handleReturn
(int replyCode, String replyText, String exchange, String routingKey, AMQP.BasicProperties properties, byte[] body) 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) ModifierConstructorDescriptionDelivery
(Envelope envelope, AMQP.BasicProperties properties, byte[] body) GetResponse
(Envelope envelope, AMQP.BasicProperties props, byte[] body, int messageCount) Construct aGetResponse
with the specified construction parametersResponse
(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) Return
(int replyCode, String replyText, String exchange, String routingKey, AMQP.BasicProperties properties, byte[] body) -
Uses of AMQP.BasicProperties in com.rabbitmq.client.impl
Modifier and TypeMethodDescriptionvoid
ChannelN.basicPublish
(String exchange, String routingKey, boolean mandatory, boolean immediate, 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, AMQP.BasicProperties props, byte[] body) Public API - Publish a message. -
Uses of AMQP.BasicProperties in com.rabbitmq.client.impl.recovery
Modifier and TypeMethodDescriptionvoid
AutorecoveringChannel.basicPublish
(String exchange, String routingKey, boolean mandatory, boolean immediate, 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, AMQP.BasicProperties props, byte[] body) -
Uses of AMQP.BasicProperties in com.rabbitmq.client.observation
Modifier and TypeMethodDescriptionvoid
ObservationCollector.publish
(ObservationCollector.PublishCall call, AMQP.Basic.Publish publish, AMQP.BasicProperties properties, byte[] body, ObservationCollector.ConnectionInfo connectionInfo) Decorate message publishing.void
ObservationCollector.PublishCall.publish
(AMQP.BasicProperties properties) -
Uses of AMQP.BasicProperties in com.rabbitmq.tools.jsonrpc
Modifier and TypeMethodDescriptionJsonRpcServer.handleStringCall
(String requestBody, AMQP.BasicProperties replyProperties) Override our superclass' method, dispatching to doCall.