A B C D E G H I M N P R S T V W
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- AlwaysRestartExceptionHandler - Class in interlok.rabbitmq
-
ConnectionErrorHandlerimplementation which always restarts whenever an error is encounted. - AlwaysRestartExceptionHandler() - Constructor for class interlok.rabbitmq.AlwaysRestartExceptionHandler
B
- BasicConnectionFactoryBuilder - Class in interlok.rabbitmq
-
A basic connection factory for RabbitMQ.
- BasicConnectionFactoryBuilder() - Constructor for class interlok.rabbitmq.BasicConnectionFactoryBuilder
- BasicConsumer - Class in interlok.rabbitmq
-
Connects to a RabbitMQ Queue and consumes messages.
- BasicConsumer() - Constructor for class interlok.rabbitmq.BasicConsumer
- build() - Method in class interlok.rabbitmq.BasicConnectionFactoryBuilder
- build() - Method in class interlok.rabbitmq.ConnectionFactoryBuilder
-
Build the connection factory.
- build() - Method in class interlok.rabbitmq.SimpleConnectionFactoryBuilder
- build(AdaptrisMessage) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
- build(AdaptrisMessage) - Method in class interlok.rabbitmq.MetadataToProperties
- build(AdaptrisMessage) - Method in class interlok.rabbitmq.StandardPropertiesBuilderFactory
- build(AdaptrisMessage) - Method in interface interlok.rabbitmq.Translator.BasicPropertiesBuilder
- build(AdaptrisMessage) - Method in interface interlok.rabbitmq.Translator.PropertiesBuilderFactory
- build(Delivery, AdaptrisMessageFactory) - Static method in class interlok.rabbitmq.Translator
-
Create an
AdaptrisMessagefrom the incomingDelivery. - build(Delivery, Translator.BasicPropertiesHandler, AdaptrisMessageFactory) - Static method in class interlok.rabbitmq.Translator
-
Create an
AdaptrisMessagefrom the incomingDelivery. - build(Delivery, Translator.BasicPropertiesHandler, Translator.EnvelopeHandler, AdaptrisMessageFactory) - Static method in class interlok.rabbitmq.Translator
-
Create an
AdaptrisMessagefrom the incomingDelivery. - build(Map<String, String>) - Method in interface interlok.rabbitmq.Translator.PropertiesBuilderFactory
-
Convenience method to build a Builder.
C
- closeConnection() - Method in class interlok.rabbitmq.RabbitMqConnection
- closeService() - Method in class interlok.rabbitmq.PublishToDefaultExchange
- ConfiguredPropertiesBuilderFactory - Class in interlok.rabbitmq
-
Implementation that allows you to explicit configure values in config.
- ConfiguredPropertiesBuilderFactory() - Constructor for class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
- connectionFactoryBuilder() - Method in interface interlok.rabbitmq.ConnectionWrapper
- connectionFactoryBuilder() - Method in class interlok.rabbitmq.RabbitMqConnection
- ConnectionFactoryBuilder - Class in interlok.rabbitmq
- ConnectionFactoryBuilder() - Constructor for class interlok.rabbitmq.ConnectionFactoryBuilder
- ConnectionWrapper - Interface in interlok.rabbitmq
-
Interface that wraps connections and builders usually implemented by
RabbitMqConnection. - consumeLocationKey() - Method in class interlok.rabbitmq.BasicConsumer
D
- Declaration - Class in interlok.rabbitmq
- Declaration.ExchangeDeclaration - Interface in interlok.rabbitmq
-
Interface that allows exchange declaration to be composed.
- Declaration.QueueDeclaration - Interface in interlok.rabbitmq
-
Interface that allows queue declaration to be composed.
- declare(Channel) - Method in interface interlok.rabbitmq.Declaration.ExchangeDeclaration
-
Declare the exchange.
- declare(Channel) - Method in class interlok.rabbitmq.ExplicitExchange
- declare(Channel, String) - Method in interface interlok.rabbitmq.Declaration.QueueDeclaration
-
Declare the queue.
- declare(Channel, String) - Method in class interlok.rabbitmq.ExplicitQueue
- doProduce(AdaptrisMessage, String) - Method in class interlok.rabbitmq.StandardMessageProducer
- doService(AdaptrisMessage) - Method in class interlok.rabbitmq.PublishToDefaultExchange
E
- endpoint(AdaptrisMessage) - Method in class interlok.rabbitmq.StandardMessageProducer
- EnvelopeToMetadata - Class in interlok.rabbitmq
-
Add metadata to the message from the
Delivery#getEnvelope()object. - EnvelopeToMetadata() - Constructor for class interlok.rabbitmq.EnvelopeToMetadata
- ExceptionHandlerImpl - Class in interlok.rabbitmq
-
Abstract implementation of
ExceptionHandlerfor RabbitMQ. - ExceptionHandlerImpl() - Constructor for class interlok.rabbitmq.ExceptionHandlerImpl
- ExplicitExchange - Class in interlok.rabbitmq
-
Declaring an explicit exchange.
- ExplicitExchange() - Constructor for class interlok.rabbitmq.ExplicitExchange
- ExplicitQueue - Class in interlok.rabbitmq
-
Explicitly configured Queue declaration.
- ExplicitQueue() - Constructor for class interlok.rabbitmq.ExplicitQueue
G
- getAppId() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getAppId() - getAutoDelete() - Method in class interlok.rabbitmq.ExplicitQueue
-
Whether or not the queue is deleted when no longer in use.
- getBehaviour() - Method in class interlok.rabbitmq.PublishToDefaultExchange
-
What to do after publishing the message depending on whether that was successful or not.
- getBrokerUrl() - Method in class interlok.rabbitmq.SimpleConnectionFactoryBuilder
-
The RabbitMQ Broker URL.
- getBuilderFactory() - Method in class interlok.rabbitmq.MetadataToProperties
-
Add specific headers to any created
AMQP.BasicPropertiesobject. - getClusterId() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getClusterId() - getConnection() - Method in class interlok.rabbitmq.PublishToDefaultExchange
-
The RabbitMQ Connection.
- getContentEncoding() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getContentEncoding() - getContentType() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getContentType() - getCorrelationId() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getCorrelationId() - getDeliveryMode() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getDeliveryMode() - getDurable() - Method in class interlok.rabbitmq.ExplicitExchange
-
Whether or not the exchange should survive a server restart.
- getDurable() - Method in class interlok.rabbitmq.ExplicitQueue
-
Whether or not the queue should survive a server restart.
- getEnvelopeHandler() - Method in class interlok.rabbitmq.BasicConsumer
-
How to handle the
Delivery#getEnvelope(). - getExchangeDeclaration() - Method in class interlok.rabbitmq.StandardMessageProducer
-
How the Exchange will be declared prior to use.
- getExclusive() - Method in class interlok.rabbitmq.ExplicitQueue
-
Whether or not the queue is exlusive to the connection.
- getExpiration() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getExpiration() - getFactoryBuilder() - Method in class interlok.rabbitmq.RabbitMqConnection
-
Configures the underlying
com.rabbitmq.client.ConnectionFactorywhich is responsible for creatingConnection - getHeaderFilter() - Method in class interlok.rabbitmq.MetadataToProperties
-
Metadata filter that filters metadata so that it is part of
com.rabbitmq.client.BasicProperties#getHeaders(). - getMessageId() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getMessageId() - getName() - Method in class interlok.rabbitmq.ExplicitExchange
-
The exchange name.
- getPassword() - Method in class interlok.rabbitmq.BasicConnectionFactoryBuilder
-
The password.
- getPrefix() - Method in class interlok.rabbitmq.PropertiesToMetadata
-
Set the prefix (if any) for metadata keys when converting
BasicProperties#getHeaders(). - getPriority() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getPriority() - getPropertiesHandler() - Method in class interlok.rabbitmq.BasicConsumer
-
How to handle the
Delivery#getProperties(). - getPropertyBuilder() - Method in class interlok.rabbitmq.PublishToDefaultExchange
-
How to build the required
BasicPropertiesif required. - getPropertyBuilder() - Method in class interlok.rabbitmq.StandardMessageProducer
-
How to build the required
BasicPropertiesif required. - getQueue() - Method in class interlok.rabbitmq.BasicConsumer
-
The queue to consume from.
- getQueue() - Method in class interlok.rabbitmq.PublishToDefaultExchange
-
The queue to publish to.
- getQueue() - Method in class interlok.rabbitmq.StandardMessageProducer
-
The queue to publish to.
- getQueueDeclaration() - Method in class interlok.rabbitmq.StandardMessageProducer
-
How the Queue will be declared prior to use.
- getReplyTo() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getReplyTo() - getTimestamp() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getTimestamp() - getType() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getType() - getType() - Method in class interlok.rabbitmq.ExplicitExchange
-
The exchange type.
- getUserId() - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getUserId() - getUsername() - Method in class interlok.rabbitmq.BasicConnectionFactoryBuilder
-
The username used to connection to the broker.
H
- handle(AMQP.BasicProperties, AdaptrisMessage) - Method in class interlok.rabbitmq.PropertiesToMetadata
- handle(AMQP.BasicProperties, AdaptrisMessage) - Method in interface interlok.rabbitmq.Translator.BasicPropertiesHandler
- handle(Envelope, AdaptrisMessage) - Method in class interlok.rabbitmq.EnvelopeToMetadata
- handle(Envelope, AdaptrisMessage) - Method in interface interlok.rabbitmq.Translator.EnvelopeHandler
- handleBlockedListenerException(Connection, Throwable) - Method in class interlok.rabbitmq.AlwaysRestartExceptionHandler
- handleChannelRecoveryException(Channel, Throwable) - Method in class interlok.rabbitmq.AlwaysRestartExceptionHandler
- handleConfirmListenerException(Channel, Throwable) - Method in class interlok.rabbitmq.AlwaysRestartExceptionHandler
- handleConnectionException() - Method in class interlok.rabbitmq.ExceptionHandlerImpl
- handleConnectionRecoveryException(Connection, Throwable) - Method in class interlok.rabbitmq.AlwaysRestartExceptionHandler
- handleConsumerException(Channel, Throwable, Consumer, String, String) - Method in class interlok.rabbitmq.AlwaysRestartExceptionHandler
- handleReturnListenerException(Channel, Throwable) - Method in class interlok.rabbitmq.AlwaysRestartExceptionHandler
- handleTopologyRecoveryException(Connection, Channel, TopologyRecoveryException) - Method in class interlok.rabbitmq.AlwaysRestartExceptionHandler
- handleUnexpectedConnectionDriverException(Connection, Throwable) - Method in class interlok.rabbitmq.AlwaysRestartExceptionHandler
I
- initConnection() - Method in class interlok.rabbitmq.RabbitMqConnection
- initService() - Method in class interlok.rabbitmq.PublishToDefaultExchange
- interlok.rabbitmq - package interlok.rabbitmq
-
RabbitMQ connectivity using their java client.
M
- MetadataConstants - Class in interlok.rabbitmq
-
Various metadata keys that represent the corresponding Delivery/Envelope properties.
- MetadataToProperties - Class in interlok.rabbitmq
-
Build a BasicProperties object from metadata.
- MetadataToProperties() - Constructor for class interlok.rabbitmq.MetadataToProperties
N
- name() - Method in interface interlok.rabbitmq.Declaration.ExchangeDeclaration
-
The name of the exchange that was declared.
- name() - Method in class interlok.rabbitmq.ExplicitExchange
- newThreadName() - Method in class interlok.rabbitmq.BasicConsumer
- NO_EXCEPTION - interlok.rabbitmq.PublishToDefaultExchange.Behaviour
-
Never throw an exception and add values against
MetadataConstants.RMQ_PUBLISH_STATUSto indicate success/failure.
P
- prepare() - Method in class interlok.rabbitmq.BasicConsumer
- prepare() - Method in class interlok.rabbitmq.PublishToDefaultExchange
- prepare() - Method in class interlok.rabbitmq.StandardMessageProducer
- prepareConnection() - Method in class interlok.rabbitmq.RabbitMqConnection
- PropertiesToMetadata - Class in interlok.rabbitmq
-
Add metadata to the message from the
BasicPropertiesobject. - PropertiesToMetadata() - Constructor for class interlok.rabbitmq.PropertiesToMetadata
- PublishToDefaultExchange - Class in interlok.rabbitmq
-
Wraps
StandardMessageProduceras a service for discoverability purposes. - PublishToDefaultExchange() - Constructor for class interlok.rabbitmq.PublishToDefaultExchange
- PublishToDefaultExchange.Behaviour - Enum in interlok.rabbitmq
-
Controls behaviour when publishing the messsage.
R
- RabbitMqConnection - Class in interlok.rabbitmq
-
Wraps a connection for RabbitMQ.
- RabbitMqConnection() - Constructor for class interlok.rabbitmq.RabbitMqConnection
- registerConnection(AdaptrisConnection) - Method in class interlok.rabbitmq.ExceptionHandlerImpl
- RMQ_APP_ID - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqAppId".
- RMQ_CLASS_ID - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqClassId".
- RMQ_CLUSTER_ID - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqClusterId".
- RMQ_CONSUMER_TAG - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqConsumerTag".
- RMQ_CONTENT_ENCODING - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqContentEncoding".
- RMQ_CONTENT_TYPE - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqContentType".
- RMQ_CORRELATION_ID - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqCorrelationId".
- RMQ_DELIVERY_MODE - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqDeliveryMode".
- RMQ_DELIVERY_TAG - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqDeliveryTag".
- RMQ_EXCHANGE - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqExchange".
- RMQ_EXPIRATION - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqExpiration".
- RMQ_IS_REDELIVERY - Static variable in class interlok.rabbitmq.MetadataConstants
- RMQ_MESSAGE_ID - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqMessageId".
- RMQ_PRIORITY - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqPriority".
- RMQ_PUBLISH_STATUS - Static variable in class interlok.rabbitmq.MetadataConstants
-
Used by
PublishToDefaultExchangeto indicate success/failure via metadata. - RMQ_QUEUE - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqQueue".
- RMQ_REPLY_TO - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqReplyTo".
- RMQ_ROUTING_KEY - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqRoutingKey".
- RMQ_TIMESTAMP - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqTimestamp".
- RMQ_TYPE - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqType".
- RMQ_USER_ID - Static variable in class interlok.rabbitmq.MetadataConstants
-
"rmqUserId".
S
- setAppId(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getAppId() - setAutoDelete(Boolean) - Method in class interlok.rabbitmq.ExplicitQueue
-
Whether or not the queue is deleted when no longer in use.
- setBehaviour(PublishToDefaultExchange.Behaviour) - Method in class interlok.rabbitmq.PublishToDefaultExchange
-
What to do after publishing the message depending on whether that was successful or not.
- setBrokerUrl(String) - Method in class interlok.rabbitmq.SimpleConnectionFactoryBuilder
-
The RabbitMQ Broker URL.
- setBuilderFactory(Translator.PropertiesBuilderFactory) - Method in class interlok.rabbitmq.MetadataToProperties
-
Add specific headers to any created
AMQP.BasicPropertiesobject. - setClusterId(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getClusterId() - setConnection(AdaptrisConnection) - Method in class interlok.rabbitmq.PublishToDefaultExchange
-
The RabbitMQ Connection.
- setContentEncoding(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getContentEncoding() - setContentType(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getContentType() - setCorrelationId(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getCorrelationId() - setDeliveryMode(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getDeliveryMode() - setDurable(Boolean) - Method in class interlok.rabbitmq.ExplicitExchange
-
Whether or not the exchange should survive a server restart.
- setDurable(Boolean) - Method in class interlok.rabbitmq.ExplicitQueue
-
Whether or not the queue should survive a server restart.
- setEnvelopeHandler(Translator.EnvelopeHandler) - Method in class interlok.rabbitmq.BasicConsumer
-
How to handle the
Delivery#getEnvelope(). - setExchangeDeclaration(Declaration.ExchangeDeclaration) - Method in class interlok.rabbitmq.StandardMessageProducer
-
How the Exchange will be declared prior to use.
- setExclusive(Boolean) - Method in class interlok.rabbitmq.ExplicitQueue
-
Whether or not the queue is exlusive to the connection.
- setExpiration(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getExpiration() - setFactoryBuilder(ConnectionFactoryBuilder) - Method in class interlok.rabbitmq.RabbitMqConnection
-
Configures the underlying
com.rabbitmq.client.ConnectionFactorywhich is responsible for creatingConnection - setHeaderFilter(MetadataFilter) - Method in class interlok.rabbitmq.MetadataToProperties
-
Metadata filter that filters metadata so that it is part of
com.rabbitmq.client.BasicProperties#getHeaders(). - setMessageId(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getMessageId() - setName(String) - Method in class interlok.rabbitmq.ExplicitExchange
-
The exchange name.
- setPassword(String) - Method in class interlok.rabbitmq.BasicConnectionFactoryBuilder
-
The password.
- setPrefix(String) - Method in class interlok.rabbitmq.PropertiesToMetadata
-
Set the prefix (if any) for metadata keys when converting
BasicProperties#getHeaders(). - setPriority(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getPriority() - setPropertiesHandler(Translator.BasicPropertiesHandler) - Method in class interlok.rabbitmq.BasicConsumer
-
How to handle the
Delivery#getProperties(). - setPropertyBuilder(Translator.BasicPropertiesBuilder) - Method in class interlok.rabbitmq.PublishToDefaultExchange
-
How to build the required
BasicPropertiesif required. - setPropertyBuilder(Translator.BasicPropertiesBuilder) - Method in class interlok.rabbitmq.StandardMessageProducer
-
How to build the required
BasicPropertiesif required. - setQueue(String) - Method in class interlok.rabbitmq.BasicConsumer
-
The queue to consume from.
- setQueue(String) - Method in class interlok.rabbitmq.PublishToDefaultExchange
-
The queue to publish to.
- setQueue(String) - Method in class interlok.rabbitmq.StandardMessageProducer
-
The queue to publish to.
- setQueueDeclaration(Declaration.QueueDeclaration) - Method in class interlok.rabbitmq.StandardMessageProducer
-
How the Queue will be declared prior to use.
- setReplyTo(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getReplyTo() - setTimestamp(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getTimestamp() - setType(BuiltinExchangeType) - Method in class interlok.rabbitmq.ExplicitExchange
-
The exchange type.
- setType(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getType() - setUserId(String) - Method in class interlok.rabbitmq.ConfiguredPropertiesBuilderFactory
-
Maps onto
com.rabbitmq.client.AMQP.BasicProperties#getUserId() - setUsername(String) - Method in class interlok.rabbitmq.BasicConnectionFactoryBuilder
-
The username used to connection to the broker.
- SimpleConnectionFactoryBuilder - Class in interlok.rabbitmq
-
A simple connection factory for RabbitMQ.
- SimpleConnectionFactoryBuilder() - Constructor for class interlok.rabbitmq.SimpleConnectionFactoryBuilder
- StandardMessageProducer - Class in interlok.rabbitmq
-
Publishes a message to RabbitMQ.
- StandardMessageProducer() - Constructor for class interlok.rabbitmq.StandardMessageProducer
- StandardPropertiesBuilderFactory - Class in interlok.rabbitmq
-
Implementation that uses values from
MetadataConstantsto populate theBasicProperties#Builder. - StandardPropertiesBuilderFactory() - Constructor for class interlok.rabbitmq.StandardPropertiesBuilderFactory
- start() - Method in class interlok.rabbitmq.BasicConsumer
- start() - Method in class interlok.rabbitmq.PublishToDefaultExchange
- start() - Method in class interlok.rabbitmq.StandardMessageProducer
- startConnection() - Method in class interlok.rabbitmq.RabbitMqConnection
- stop() - Method in class interlok.rabbitmq.BasicConsumer
- stop() - Method in class interlok.rabbitmq.PublishToDefaultExchange
- stop() - Method in class interlok.rabbitmq.StandardMessageProducer
- stopConnection() - Method in class interlok.rabbitmq.RabbitMqConnection
T
- TRADITIONAL - interlok.rabbitmq.PublishToDefaultExchange.Behaviour
-
Behave like a normal service and throw an exception on failure.
- Translator - Class in interlok.rabbitmq
-
Translating between
AdaptrisMessageand their RabbitMQ Equivalents. - Translator.BasicPropertiesBuilder - Interface in interlok.rabbitmq
-
Create
BasicPropertiesfrom anAdaptrisMessage - Translator.BasicPropertiesHandler - Interface in interlok.rabbitmq
-
Transfer the contents of
Delivery#getProperties()into theAdaptrisMessage - Translator.EnvelopeHandler - Interface in interlok.rabbitmq
-
Transfer the contents of
Delivery#getEnvelope()into theAdaptrisMessage - Translator.PropertiesBuilderFactory - Interface in interlok.rabbitmq
-
Creates a
BasicProperties.Builderobject fromAdaptrisMessage.
V
- valueOf(String) - Static method in enum interlok.rabbitmq.PublishToDefaultExchange.Behaviour
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum interlok.rabbitmq.PublishToDefaultExchange.Behaviour
-
Returns an array containing the constants of this enum type, in the order they are declared.
W
- withBrokerUrl(String) - Method in class interlok.rabbitmq.SimpleConnectionFactoryBuilder
- withBuilder(Translator.PropertiesBuilderFactory) - Method in class interlok.rabbitmq.MetadataToProperties
- withConnection(RabbitMqConnection) - Method in class interlok.rabbitmq.PublishToDefaultExchange
- withCredentials(String, String) - Method in class interlok.rabbitmq.BasicConnectionFactoryBuilder
- withDurable(Boolean) - Method in class interlok.rabbitmq.ExplicitExchange
- withEnvelopeHandler(Translator.EnvelopeHandler) - Method in class interlok.rabbitmq.BasicConsumer
- withErrorHandler(ExceptionHandlerImpl) - Method in class interlok.rabbitmq.RabbitMqConnection
- withFactoryBuilder(ConnectionFactoryBuilder) - Method in class interlok.rabbitmq.RabbitMqConnection
- withFilter(MetadataFilter) - Method in class interlok.rabbitmq.MetadataToProperties
- withName(String) - Method in class interlok.rabbitmq.ExplicitExchange
- withPrefix(String) - Method in class interlok.rabbitmq.PropertiesToMetadata
- withPropertiesHandler(Translator.BasicPropertiesHandler) - Method in class interlok.rabbitmq.BasicConsumer
- withPropertyBuilder(Translator.BasicPropertiesBuilder) - Method in class interlok.rabbitmq.StandardMessageProducer
- withQueue(String) - Method in class interlok.rabbitmq.BasicConsumer
- withQueue(String) - Method in class interlok.rabbitmq.PublishToDefaultExchange
- withQueue(String) - Method in class interlok.rabbitmq.StandardMessageProducer
- withType(BuiltinExchangeType) - Method in class interlok.rabbitmq.ExplicitExchange
- wrappedConnection() - Method in interface interlok.rabbitmq.ConnectionWrapper
- wrappedConnection() - Method in class interlok.rabbitmq.RabbitMqConnection
All Classes All Packages