Index (rabbitmq-root 1.1.0.M1 API)

A B C D F G H I J N O P Q R S V W

A

ack() - Method in interface io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgement
ack(boolean) - Method in interface io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgement: Acknowledges this message.
AcknowledgementBinder<T extends io.micronaut.messaging.Acknowledgement> - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of type Acknowledgement from the RabbitConsumerState.
AcknowledgementBinder() - Constructor for class io.micronaut.configuration.rabbitmq.bind.AcknowledgementBinder
argumentType() - Method in class io.micronaut.configuration.rabbitmq.bind.AcknowledgementBinder
argumentType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgementBinder
argumentType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitBasicPropertiesBinder
argumentType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitEnvelopeBinder

B

bind(ArgumentConversionContext<T>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.AcknowledgementBinder
bind(ArgumentConversionContext<BasicProperties>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitBasicPropertiesBinder
bind(ArgumentConversionContext<Object>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitBodyBinder
bind(ArgumentConversionContext<Object>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitDefaultBinder: Checks if the argument name matches one of the BasicProperties.
bind(ArgumentConversionContext<Envelope>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitEnvelopeBinder
bind(ArgumentConversionContext<Object>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderBinder
bind(ArgumentConversionContext<Object>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitPropertyBinder
Binding - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Used to specify which binding (routing key) messages should be sent to.
BrokerResponse - Enum in io.micronaut.configuration.rabbitmq.reactive: An enumeration to represent the three possible states of response from a broker.

C

ChannelPool - Interface in io.micronaut.configuration.rabbitmq.connect: A pool of Channels to allow for channels to be shared across threads but not at the same time.
close() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitMessageCloseable
close() - Method in class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool
close() - Method in class io.micronaut.configuration.rabbitmq.intercept.RabbitMQConsumerAdvice
createChannel() - Method in class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool: Creates a channel.
createListener(Channel, AtomicReference<BrokerResponse>) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Listens for ack/nack from the broker.

D

DefaultChannelPool - Class in io.micronaut.configuration.rabbitmq.connect: Default implementation of ChannelPool.
DefaultChannelPool(Connection, Integer) - Constructor for class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool: Default constructor.
DefaultConsumer - Interface in io.micronaut.configuration.rabbitmq.intercept: A default Consumer that delegates cancelled or shutdown with a single method DefaultConsumer.handleTerminate(String).
DefaultRabbitListenerExceptionHandler - Class in io.micronaut.configuration.rabbitmq.exception: The default ExceptionHandler used when a RabbitListener fails to process a RabbitMQ message.
DefaultRabbitListenerExceptionHandler() - Constructor for class io.micronaut.configuration.rabbitmq.exception.DefaultRabbitListenerExceptionHandler
DefaultRabbitMessageSerDesRegistry - Class in io.micronaut.configuration.rabbitmq.serdes: Default implementation of RabbitMessageSerDesRegistry.
DefaultRabbitMessageSerDesRegistry(RabbitMessageSerDes<?>...) - Constructor for class io.micronaut.configuration.rabbitmq.serdes.DefaultRabbitMessageSerDesRegistry: Default constructor.
deserialize(RabbitConsumerState, Class<Object>) - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
deserialize(RabbitConsumerState, Class<Object>) - Method in class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes
deserialize(RabbitConsumerState, Class<T>) - Method in interface io.micronaut.configuration.rabbitmq.serdes.RabbitMessageSerDes: Deserializes the message into the requested type.

F

findArgumentBinder(Argument<T>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitBinderRegistry
findSerdes(Class<T>) - Method in class io.micronaut.configuration.rabbitmq.serdes.DefaultRabbitMessageSerDesRegistry
findSerDes(Class) - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes: Finds the correct serDes based on the type.
findSerdes(Class<T>) - Method in interface io.micronaut.configuration.rabbitmq.serdes.RabbitMessageSerDesRegistry: Returns the serdes that supports the given type.

G

get(CharSequence, ArgumentConversionContext<T>) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderConvertibleValues
getAnnotationType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitBodyBinder
getAnnotationType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderBinder
getAnnotationType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitPropertyBinder
getBody() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState
getBody() - Method in class io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState
getByteArraySerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getByteBufferSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getChannel() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState: This channel is being used exclusively by the consumer that consumed this message.
getChannel() - Method in interface io.micronaut.configuration.rabbitmq.connect.ChannelPool: Retrieves a channel from the pool.
getChannel() - Method in class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool
getChannel() - Method in class io.micronaut.configuration.rabbitmq.intercept.RabbitMQConsumerAdvice
getChannel() - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Creates a Single from a channel, emitting an error if the channel could not be retrieved.
getConversionErrors() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderConvertibleValues
getDoubleSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getEnvelope() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState
getExchange() - Method in class io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState
getFailures() - Method in exception io.micronaut.configuration.rabbitmq.exception.RabbitClientException
getFloatSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getHealthInformation() - Method in class io.micronaut.configuration.rabbitmq.health.RabbitMQHealthIndicator
getIntegerSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getListener() - Method in exception io.micronaut.configuration.rabbitmq.exception.RabbitListenerException
getLongSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getMessageState() - Method in exception io.micronaut.configuration.rabbitmq.exception.RabbitListenerException
getName() - Method in class io.micronaut.configuration.rabbitmq.health.RabbitMQHealthIndicator
getOrder() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getOrder() - Method in class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes
getProperties() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState
getProperties() - Method in class io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState
getRoutingKey() - Method in class io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState
getShortSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getStringSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getUUIDSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes

H

handle(RabbitListenerException) - Method in class io.micronaut.configuration.rabbitmq.exception.DefaultRabbitListenerExceptionHandler
handleCancel(String) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer
handleCancelOk(String) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer
handleConsumeOk(String) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer
handleRecoverOk(String) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer
handleShutdownSignal(String, ShutdownSignalException) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer
handleTerminate(String) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer: Called when a consumer is cancelled or shut down.

I

initializePublish(Channel) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Initializes the channel to allow publisher acknowledgements.
intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.configuration.rabbitmq.intercept.RabbitMQIntroductionAdvice
io.micronaut.configuration.rabbitmq.annotation - package io.micronaut.configuration.rabbitmq.annotation: Annotations for creating RabbitMQ consumers and producers.
io.micronaut.configuration.rabbitmq.bind - package io.micronaut.configuration.rabbitmq.bind: Classes for binding RabbitMQ messages to consumer methods.
io.micronaut.configuration.rabbitmq.connect - package io.micronaut.configuration.rabbitmq.connect: Classes handling the connection RabbitMQ.
io.micronaut.configuration.rabbitmq.exception - package io.micronaut.configuration.rabbitmq.exception: RabbitMQ specific exceptions.
io.micronaut.configuration.rabbitmq.executor - package io.micronaut.configuration.rabbitmq.executor: Classes related to configuring the thread pool to run RabbitMQ consumers.
io.micronaut.configuration.rabbitmq.health - package io.micronaut.configuration.rabbitmq.health: Classes related to performing health checks for RabbitMQ.
io.micronaut.configuration.rabbitmq.intercept - package io.micronaut.configuration.rabbitmq.intercept: Contains the implementations of the Around advices for RabbitMQ consumer and producer methods.
io.micronaut.configuration.rabbitmq.metrics - package io.micronaut.configuration.rabbitmq.metrics: Contains classes specific to capturing RabbitMQ metrics.
io.micronaut.configuration.rabbitmq.reactive - package io.micronaut.configuration.rabbitmq.reactive: Contains classes specific to converting the RabbitMQ java client API to a reactive API.
io.micronaut.configuration.rabbitmq.serdes - package io.micronaut.configuration.rabbitmq.serdes: Classes for serializing and deserializing RabbitMQ message bodies.

J

JavaLangRabbitMessageSerDes - Class in io.micronaut.configuration.rabbitmq.serdes: Serializes and deserializes standard Java types.
JavaLangRabbitMessageSerDes() - Constructor for class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes: Default constructor.
javaSerDes - Variable in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
JsonRabbitMessageSerDes - Class in io.micronaut.configuration.rabbitmq.serdes: Serializes and deserializes objects as JSON using Jackson.
JsonRabbitMessageSerDes(JacksonObjectSerializer) - Constructor for class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes: Default constructor.

N

nack() - Method in interface io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgement
nack(boolean, boolean) - Method in interface io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgement: Rejects this message.
names() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderConvertibleValues

O

onCreated(BeanCreatedEvent<ConnectionFactory>) - Method in class io.micronaut.configuration.rabbitmq.metrics.RabbitMetricsInterceptor
ORDER - Static variable in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes: The order of this serDes.
ORDER - Static variable in class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes: The order of this serDes.

P

process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.configuration.rabbitmq.intercept.RabbitMQConsumerAdvice
publish(String, String, AMQP.BasicProperties, byte[]) - Method in interface io.micronaut.configuration.rabbitmq.reactive.ReactivePublisher: Publish the message with the provided arguments and return a reactive type that completes successfully when the broker acknowledged the message.
publish(String, String, AMQP.BasicProperties, byte[]) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher
publishInternal(Channel, RabbitPublishState) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Publishes the message to the channel.

Q

Queue - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Used to specify which queue messages should be consumed from.

R

RabbitAcknowledgement - Interface in io.micronaut.configuration.rabbitmq.bind: A contract for acknowledging or rejecting RabbitMQ messages.
RabbitAcknowledgementBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of type RabbitAcknowledgement from the RabbitConsumerState.
RabbitAcknowledgementBinder() - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgementBinder
RabbitAnnotatedArgumentBinder<A extends Annotation> - Interface in io.micronaut.configuration.rabbitmq.bind: An interface for RabbitMQ argument binding based on an annotation.
RabbitArgumentBinder<T> - Interface in io.micronaut.configuration.rabbitmq.bind: An interface for RabbitMQ argument binding.
RabbitBasicPropertiesBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of type BasicProperties from the RabbitConsumerState.
RabbitBasicPropertiesBinder() - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitBasicPropertiesBinder
RabbitBinderRegistry - Class in io.micronaut.configuration.rabbitmq.bind: Used to determine which RabbitArgumentBinder to use for any given argument.
RabbitBinderRegistry(RabbitDefaultBinder, RabbitArgumentBinder...) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitBinderRegistry: Default constructor.
RabbitBodyBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of with the Body annotation from the RabbitConsumerState.
RabbitBodyBinder(RabbitMessageSerDesRegistry) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitBodyBinder: Default constructor.
RabbitClient - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: An introduction advice that automatically implements interfaces and abstract classes and publishes RabbitMQ messages.
RabbitClientException - Exception in io.micronaut.configuration.rabbitmq.exception: Exception thrown when an error occurs publishing a RabbitMQ message.
RabbitClientException(String) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitClientException: Creates a new exception.
RabbitClientException(String, List<RabbitPublishState>) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitClientException: Creates a new exception.
RabbitClientException(String, Throwable) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitClientException: Creates a new exception.
RabbitClientException(String, Throwable, List<RabbitPublishState>) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitClientException: Creates a new exception.
RabbitConnectionFactory - Class in io.micronaut.configuration.rabbitmq.connect: A factory for creating a connection to RabbitMQ.
RabbitConnectionFactory() - Constructor for class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactory
RabbitConnectionFactoryConfig - Class in io.micronaut.configuration.rabbitmq.connect: The default RabbitMQ configuration class.
RabbitConnectionFactoryConfig() - Constructor for class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig
RabbitConsumerExecutorFactory - Class in io.micronaut.configuration.rabbitmq.executor: Configures a ScheduledExecutorService for running RabbitListener instances.
RabbitConsumerExecutorFactory() - Constructor for class io.micronaut.configuration.rabbitmq.executor.RabbitConsumerExecutorFactory
RabbitConsumerState - Class in io.micronaut.configuration.rabbitmq.bind: Stores the state of a RabbitMQ message to be consumed.
RabbitConsumerState(Envelope, AMQP.BasicProperties, byte[], Channel) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState: Default constructor.
RabbitDefaultBinder - Class in io.micronaut.configuration.rabbitmq.bind: The default binder for binding an argument from the RabbitConsumerState that is used if no other binder supports the argument.
RabbitDefaultBinder(RabbitPropertyBinder, RabbitBodyBinder) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitDefaultBinder: Default constructor.
RabbitEnvelopeBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of type Envelope from the RabbitConsumerState.
RabbitEnvelopeBinder() - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitEnvelopeBinder
RabbitHeaderBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of with the Header annotation from the RabbitConsumerState.
RabbitHeaderBinder(ConversionService) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderBinder: Default constructor.
RabbitHeaderConvertibleValues - Class in io.micronaut.configuration.rabbitmq.bind: Converts RabbitMQ header values to the requested type.
RabbitHeaderConvertibleValues(Map<String, Object>, ConversionService<?>) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderConvertibleValues: Default constructor.
RabbitListener - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Class level annotation to indicate that a bean will be consumers of messages from RabbitMQ.
RabbitListenerException - Exception in io.micronaut.configuration.rabbitmq.exception: Exception thrown when an error occurs processing a RabbitMQ message via a RabbitListener.
RabbitListenerException(String, Object, RabbitConsumerState) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitListenerException: Creates a new exception.
RabbitListenerException(String, Throwable, Object, RabbitConsumerState) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitListenerException: Creates a new exception.
RabbitListenerException(Throwable, Object, RabbitConsumerState) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitListenerException: Creates a new exception.
RabbitListenerExceptionHandler - Interface in io.micronaut.configuration.rabbitmq.exception: Interface that RabbitListener beans can implement to handle exceptions.
RabbitMessageCloseable - Class in io.micronaut.configuration.rabbitmq.bind: Responsible for acknowledging or rejecting a message.
RabbitMessageCloseable(RabbitConsumerState, boolean, boolean) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitMessageCloseable: Default constructor.
RabbitMessageSerDes<T> - Interface in io.micronaut.configuration.rabbitmq.serdes: Responsible for serializing and deserializing RabbitMQ message bodies.
RabbitMessageSerDesRegistry - Interface in io.micronaut.configuration.rabbitmq.serdes: A registry of RabbitMessageSerDes instances.
RabbitMetricsInterceptor - Class in io.micronaut.configuration.rabbitmq.metrics: Interceptor of the connection factory to set the metrics collector.
RabbitMetricsInterceptor(Provider<MeterRegistry>, String, Map<String, String>) - Constructor for class io.micronaut.configuration.rabbitmq.metrics.RabbitMetricsInterceptor: Default constructor.
RabbitMQConsumerAdvice - Class in io.micronaut.configuration.rabbitmq.intercept: An ExecutableMethodProcessor that will process all beans annotated with RabbitListener and create and subscribe the relevant methods as consumers to RabbitMQ queues.
RabbitMQConsumerAdvice(BeanContext, ChannelPool, RabbitBinderRegistry, RabbitListenerExceptionHandler, ConversionService) - Constructor for class io.micronaut.configuration.rabbitmq.intercept.RabbitMQConsumerAdvice: Default constructor.
RabbitMQHealthIndicator - Class in io.micronaut.configuration.rabbitmq.health: A HealthIndicator for RabbitMQ.
RabbitMQHealthIndicator(Connection) - Constructor for class io.micronaut.configuration.rabbitmq.health.RabbitMQHealthIndicator: Default constructor.
RabbitMQIntroductionAdvice - Class in io.micronaut.configuration.rabbitmq.intercept: Implementation of the RabbitClient advice annotation.
RabbitMQIntroductionAdvice(ChannelPool, ReactivePublisher<?>, ConversionService<?>, RabbitMessageSerDesRegistry) - Constructor for class io.micronaut.configuration.rabbitmq.intercept.RabbitMQIntroductionAdvice: Default constructor.
RabbitProperties - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Annotation to collect a set of properties.
RabbitProperty - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Used to set properties while publishing or bind to properties while consuming.
RabbitPropertyBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of with the RabbitProperty annotation from the RabbitConsumerState.
RabbitPropertyBinder(ConversionService) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitPropertyBinder: Default constructor.
RabbitPublishState - Class in io.micronaut.configuration.rabbitmq.reactive: Stores the state of a RabbitMQ message to be published.
RabbitPublishState(String, String, AMQP.BasicProperties, byte[]) - Constructor for class io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState: Default constructor.
RabbitTypeArgumentBinder<T> - Interface in io.micronaut.configuration.rabbitmq.bind: An interface for RabbitMQ argument binding based on argument type.
ReactivePublisher<T> - Interface in io.micronaut.configuration.rabbitmq.reactive: A generic contract for publishing RabbitMQ messages reactively.
returnChannel(Channel) - Method in interface io.micronaut.configuration.rabbitmq.connect.ChannelPool: Returns a channel to the pool.
returnChannel(Channel) - Method in class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool
returnChannel(Channel) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Removes confirm listeners from the channel and returns the channel to the pool.
RxJavaReactivePublisher - Class in io.micronaut.configuration.rabbitmq.reactive: A reactive publisher implementation that uses a single channel per publish operation and returns an RxJava2 Completable.
RxJavaReactivePublisher(ChannelPool) - Constructor for class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Default constructor.

S

serialize(Object) - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
serialize(Object) - Method in class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes
serialize(T) - Method in interface io.micronaut.configuration.rabbitmq.serdes.RabbitMessageSerDes: Serializes the data into a byte[] to be published to RabbitMQ.
supports(ArgumentConversionContext<Object>) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitPropertyBinder
supports(Class<Object>) - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
supports(Class<Object>) - Method in class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes
supports(Class<T>) - Method in interface io.micronaut.configuration.rabbitmq.serdes.RabbitMessageSerDes: Determines if this serdes supports the given type.

V

valueOf(String) - Static method in enum io.micronaut.configuration.rabbitmq.reactive.BrokerResponse: Returns the enum constant of this type with the specified name.
values() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderConvertibleValues
values() - Static method in enum io.micronaut.configuration.rabbitmq.reactive.BrokerResponse: Returns an array containing the constants of this enum type, in the order they are declared.

W

withAcknowledge(Boolean) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitMessageCloseable: Builder style sets whether the message should be acknowledged.

A B C D F G H I J N O P Q R S V W