Package interlok.rabbitmq
package interlok.rabbitmq
RabbitMQ connectivity using their java client.
-
ClassDescription
ConnectionErrorHandlerimplementation which always restarts whenever an error is encounted.A basic connection factory for RabbitMQ.Connects to a RabbitMQ Queue and consumes messages.Implementation that allows you to explicit configure values in config.Interface that wraps connections and builders usually implemented byRabbitMqConnection.Interface that allows exchange declaration to be composed.Interface that allows queue declaration to be composed.Add metadata to the message from theDelivery#getEnvelope()object.Abstract implementation ofExceptionHandlerfor RabbitMQ.Declaring an explicit exchange.Explicitly configured Queue declaration.Various metadata keys that represent the corresponding Delivery/Envelope properties.Build a BasicProperties object from metadata.Add metadata to the message from theBasicPropertiesobject.WrapsStandardMessageProduceras a service for discoverability purposes.Controls behaviour when publishing the messsage.Wraps a connection for RabbitMQ.A simple connection factory for RabbitMQ.Publishes a message to RabbitMQ.Implementation that uses values fromMetadataConstantsto populate theBasicProperties#Builder.Translating betweenAdaptrisMessageand their RabbitMQ Equivalents.CreateBasicPropertiesfrom anAdaptrisMessageTransfer the contents ofDelivery#getProperties()into theAdaptrisMessageTransfer the contents ofDelivery#getEnvelope()into theAdaptrisMessageCreates aBasicProperties.Builderobject fromAdaptrisMessage.