Index

A B C D E F G H I J K L M N O P Q R S T U V W X Z _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

W

waitForConfirms() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl

waitForConfirms(long) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl

waitForConfirms(long) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations

Delegate to the underlying dedicated channel to wait for confirms.

waitForConfirms(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

waitForConfirmsOrDie() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl

waitForConfirmsOrDie(long) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl

waitForConfirmsOrDie(long) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations

Delegate to the underlying dedicated channel to wait for confirms.

waitForConfirmsOrDie(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

waitForReturnIfNeeded() - Method in class org.springframework.amqp.rabbit.connection.PendingConfirm

Return true if a return has been passed to the listener or if no return has been received.

WebFluxNodeLocator - Class in org.springframework.amqp.rabbit.connection

A LocalizedQueueConnectionFactory.NodeLocator using the Spring WebFlux WebClient.

WebFluxNodeLocator() - Constructor for class org.springframework.amqp.rabbit.connection.WebFluxNodeLocator

where(String) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer

whereAll(String...) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer

whereAll(Map<String, Object>) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer

whereAny(String...) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer

whereAny(Map<String, Object>) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer

with(Enum<?>) - Method in class org.springframework.amqp.core.BindingBuilder.DirectExchangeRoutingKeyConfigurer

with(Enum<?>) - Method in class org.springframework.amqp.core.BindingBuilder.GenericExchangeRoutingKeyConfigurer

with(Enum<?>) - Method in class org.springframework.amqp.core.BindingBuilder.TopicExchangeRoutingKeyConfigurer

with(String) - Method in class org.springframework.amqp.core.BindingBuilder.DirectExchangeRoutingKeyConfigurer

with(String) - Method in class org.springframework.amqp.core.BindingBuilder.GenericExchangeRoutingKeyConfigurer

with(String) - Method in class org.springframework.amqp.core.BindingBuilder.TopicExchangeRoutingKeyConfigurer

withArgument(String, Object) - Method in class org.springframework.amqp.core.ExchangeBuilder

Add an argument.

withArgument(String, Object) - Method in class org.springframework.amqp.core.QueueBuilder

The final queue will contain argument used to declare a queue.

withArguments(Map<String, Object>) - Method in class org.springframework.amqp.core.ExchangeBuilder

Add the arguments.

withArguments(Map<String, Object>) - Method in class org.springframework.amqp.core.QueueBuilder

The final queue will contain arguments used to declare a queue.

withBody(byte[]) - Static method in class org.springframework.amqp.core.MessageBuilder

The final message body will be a direct reference to 'body'.

withBody(byte[], int, int) - Static method in class org.springframework.amqp.core.MessageBuilder

The final message body will be a new array containing the byte range from 'body'.

withClonedBody(byte[]) - Static method in class org.springframework.amqp.core.MessageBuilder

The final message body will be a copy of 'body' in a new array.

withQueueName() - Method in class org.springframework.amqp.core.BindingBuilder.DirectExchangeRoutingKeyConfigurer

wrap(Message<?>) - Static method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor

Create a AmqpMessageHeaderAccessor from the headers of an existing message.

WrappedTransactionException(Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.WrappedTransactionException

wrapToListenerExecutionFailedExceptionIfNeeded(Exception, Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

A B C D E F G H I J K L M N O P Q R S T U V W X Z _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form