public class RabbitStreamTemplate extends java.lang.Object implements RabbitStreamOperations, org.springframework.beans.factory.BeanNameAware
RabbitStreamOperations.| Modifier and Type | Field and Description |
|---|---|
protected org.springframework.core.log.LogAccessor |
logger |
| Constructor and Description |
|---|
RabbitStreamTemplate(com.rabbitmq.stream.Environment environment,
java.lang.String streamName)
Construct an instance with the provided
Environment. |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> |
convertAndSend(java.lang.Object message)
Convert to and send a Spring AMQP message.
|
org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> |
convertAndSend(java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor mpp)
Convert to and send a Spring AMQP message.
|
com.rabbitmq.stream.MessageBuilder |
messageBuilder()
Return the producer's
MessageBuilder to create native stream messages. |
org.springframework.amqp.support.converter.MessageConverter |
messageConverter()
Return the message converter.
|
org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> |
send(org.springframework.amqp.core.Message message)
Send a Spring AMQP message.
|
org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> |
send(com.rabbitmq.stream.Message message)
Send a native stream message.
|
void |
setBeanName(java.lang.String name) |
void |
setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
Set a converter for
convertAndSend(Object) operations. |
void |
setProducerCustomizer(ProducerCustomizer producerCustomizer)
Used to customize the
ProducerBuilder before the Producer is built. |
void |
setStreamConverter(StreamMessageConverter streamConverter)
Set a converter to convert from
Message to Message
for send(Message) and convertAndSend(Object) methods. |
StreamMessageConverter |
streamMessageConverter()
Return the stream message converter.
|
public RabbitStreamTemplate(com.rabbitmq.stream.Environment environment,
java.lang.String streamName)
Environment.environment - the environment.streamName - the stream name.public void setBeanName(java.lang.String name)
setBeanName in interface org.springframework.beans.factory.BeanNameAwarepublic void setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
convertAndSend(Object) operations.messageConverter - the converter.public void setStreamConverter(StreamMessageConverter streamConverter)
Message to Message
for send(Message) and convertAndSend(Object) methods.streamConverter - the converter.public void setProducerCustomizer(ProducerCustomizer producerCustomizer)
ProducerBuilder before the Producer is built.producerCustomizer - the customizer;public org.springframework.amqp.support.converter.MessageConverter messageConverter()
RabbitStreamOperationsmessageConverter in interface RabbitStreamOperationspublic StreamMessageConverter streamMessageConverter()
RabbitStreamOperationsstreamMessageConverter in interface RabbitStreamOperationspublic org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> send(org.springframework.amqp.core.Message message)
RabbitStreamOperationssend in interface RabbitStreamOperationsmessage - the message.public org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> convertAndSend(java.lang.Object message)
RabbitStreamOperationsconvertAndSend in interface RabbitStreamOperationsmessage - the payload.public org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> convertAndSend(java.lang.Object message,
@Nullable
org.springframework.amqp.core.MessagePostProcessor mpp)
RabbitStreamOperationsMessagePostProcessor is
provided and returns null, the message is not sent and the future is
completed with false.convertAndSend in interface RabbitStreamOperationsmessage - the payload.mpp - a message post processor.public org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> send(com.rabbitmq.stream.Message message)
RabbitStreamOperationssend in interface RabbitStreamOperationsmessage - the message.RabbitStreamOperations.messageBuilder()public com.rabbitmq.stream.MessageBuilder messageBuilder()
RabbitStreamOperationsMessageBuilder to create native stream messages.messageBuilder in interface RabbitStreamOperationsRabbitStreamOperations.send(com.rabbitmq.stream.Message)public void close()
Close the underlying producer; a new producer will be created on the next operation that requires one.
close in interface java.lang.AutoCloseableclose in interface RabbitStreamOperations