Uses of Interface
com.rabbitmq.client.amqp.Message
Packages that use Message
-
Uses of Message in com.rabbitmq.client.amqp
Methods in com.rabbitmq.client.amqp that return MessageModifier and TypeMethodDescriptionMessage.absoluteExpiryTime(long absoluteExpiryTime) Set the expiry time.Message.annotation(String key, Object value) Set the value of a message annotation.Message.body(byte[] body) Set the body of the message.Message.contentEncoding(String contentEncoding) Set the content-encoding.Message.contentType(String contentType) Set the content-type.Message.correlationId(byte[] correlationId) Set the message correlation ID (array of bytes).Message.correlationId(long correlationId) Set the message correlation ID (long).Message.correlationId(Object correlationId) Set the message correlation ID.Message.correlationId(String correlationId) Set the message correlation ID (string).Message.correlationId(UUID correlationId) Set the message correlation ID (UUID).Message.creationTime(long creationTime) Set the creation time.Message.forEachAnnotation(BiConsumer<String, Object> action) Iterate over message annotations.Message.forEachProperty(BiConsumer<String, Object> action) Iterate over application properties.Set the group ID.Message.groupSequence(int groupSequence) Set the position of the message in its group.RpcServer.Handler.handle(RpcServer.Context ctx, Message request) Process request message.Message.MessageAddressBuilder.message()Publisher.Context.message()The message.Publisher.message()Create a message meant to be published by the publisher instance.Publisher.message(byte[] body) Create a message meant to be published by the publisher instance.RpcClient.message()Create a message meant to be published by the underlying publisher instance.RpcClient.message(byte[] body) Create a message meant to be published by the underlying publisher instance.RpcServer.Context.message()Create a message meant to be published by the underlying publisher instance.RpcServer.Context.message(byte[] body) Create a message meant to be published by the underlying publisher instance.Message.messageId(byte[] id) Set the message ID (array of bytes).Message.messageId(long id) Set the message ID (long).Set the message ID.Set the message ID (string).Set the message ID (UUID).Message.priority(byte priority) Set the priority of the message.Set an application property.Set an application property.Set an application property.Set an application property.Set an application property.Set an application property.Set an application property.Set an application property.Set an application property.Set an application property.Set an application property.Message.propertyDecimal128(String key, BigDecimal value) Set an application property.Message.propertyDecimal32(String key, BigDecimal value) Set an application property.Message.propertyDecimal64(String key, BigDecimal value) Set an application property.Message.propertySymbol(String key, String value) Set an application property.Message.propertyTimestamp(String key, long value) Set an application property.Message.propertyUnsigned(String key, byte value) Set an application property.Message.propertyUnsigned(String key, int value) Set an application property.Message.propertyUnsigned(String key, long value) Set an application property.Message.propertyUnsigned(String key, short value) Set an application property.Set the reply-to field.Message.replyToGroupId(String groupId) Set the reply-to group ID.Set the message subject.Set the to field.Set the message TTL.Message.userId(byte[] userId) Set the user ID.Methods in com.rabbitmq.client.amqp that return types with arguments of type MessageModifier and TypeMethodDescriptionPublish a request message and expect a response.Methods in com.rabbitmq.client.amqp with parameters of type MessageModifier and TypeMethodDescriptionvoidConsumer.MessageHandler.handle(Consumer.Context context, Message message) Process a messageRpcServer.Handler.handle(RpcServer.Context ctx, Message request) Process request message.<T> TObservationCollector.publish(String exchange, String routingKey, Message message, ObservationCollector.ConnectionInfo connectionInfo, Function<Message, T> publishCall) Observe the publishing of a message.voidPublisher.publish(Message message, Publisher.Callback callback) Publish a message.Publish a request message and expect a response.Method parameters in com.rabbitmq.client.amqp with type arguments of type MessageModifier and TypeMethodDescriptionRpcClientBuilder.correlationIdExtractor(Function<Message, Object> correlationIdExtractor) Callback to extract the correlation ID from a reply message.RpcServerBuilder.correlationIdExtractor(Function<Message, Object> correlationIdExtractor) Logic to extract the correlation ID from a request message.<T> TObservationCollector.publish(String exchange, String routingKey, Message message, ObservationCollector.ConnectionInfo connectionInfo, Function<Message, T> publishCall) Observe the publishing of a message.RpcServerBuilder.replyPostProcessor(BiFunction<Message, Object, Message> replyPostProcessor) A callback called after request processing but before sending the reply message.RpcServerBuilder.replyPostProcessor(BiFunction<Message, Object, Message> replyPostProcessor) A callback called after request processing but before sending the reply message.RpcClientBuilder.requestPostProcessor(BiFunction<Message, Object, Message> requestPostProcessor) A callback before sending a request message.RpcClientBuilder.requestPostProcessor(BiFunction<Message, Object, Message> requestPostProcessor) A callback before sending a request message.