Package interlok.rabbitmq
RabbitMQ connectivity using their java client.
-
Interface Summary Interface Description ConnectionWrapper Interface that wraps connections and builders usually implemented byRabbitMqConnection
.Declaration.ExchangeDeclaration Interface that allows exchange declaration to be composed.Declaration.QueueDeclaration Interface that allows queue declaration to be composed.Translator.BasicPropertiesBuilder CreateBasicProperties
from anAdaptrisMessage
Translator.BasicPropertiesHandler Transfer the contents ofDelivery#getProperties()
into theAdaptrisMessage
Translator.EnvelopeHandler Transfer the contents ofDelivery#getEnvelope()
into theAdaptrisMessage
Translator.PropertiesBuilderFactory Creates aBasicProperties.Builder
object fromAdaptrisMessage
. -
Class Summary Class Description AlwaysRestartExceptionHandler ConnectionErrorHandler
implementation which always restarts whenever an error is encounted.BasicConnectionFactoryBuilder A basic connection factory for RabbitMQ.BasicConsumer Connects to a RabbitMQ Queue and consumes messages.ConfiguredPropertiesBuilderFactory Implementation that allows you to explicit configure values in config.ConnectionFactoryBuilder Declaration EnvelopeToMetadata Add metadata to the message from theDelivery#getEnvelope()
object.ExceptionHandlerImpl Abstract implementation ofExceptionHandler
for RabbitMQ.ExplicitExchange Declaring an explicit exchange.ExplicitQueue Explicitly configured Queue declaration.MetadataConstants Various metadata keys that represent the corresponding Delivery/Envelope properties.MetadataToProperties Build a BasicProperties object from metadata.PropertiesToMetadata Add metadata to the message from theBasicProperties
object.PublishToDefaultExchange WrapsStandardMessageProducer
as a service for discoverability purposes.RabbitMqConnection Wraps a connection for RabbitMQ.SimpleConnectionFactoryBuilder A simple connection factory for RabbitMQ.StandardMessageProducer Publishes a message to RabbitMQ.StandardPropertiesBuilderFactory Implementation that uses values fromMetadataConstants
to populate theBasicProperties#Builder
.Translator Translating betweenAdaptrisMessage
and their RabbitMQ Equivalents. -
Enum Summary Enum Description PublishToDefaultExchange.Behaviour Controls behaviour when publishing the messsage.