Package com.adaptris.core.jms
package com.adaptris.core.jms
Provides JMS functionality within Interlok
-
ClassDescriptionUtility class to convert a meaningful string into a javax.jms.Session constant.
ConnectionErrorHandler
implementation that actively attempts messages via JMS to detect outages.Implentation ofAggregatingConsumeService
that allows you to consume a related message from a queue based on some criteria.AggregatingConsumer
implementation that allows you to read a separate message(s) from a queue that need to be aggregated with the current message.Perform a best guess routine on the JMSMessage when translating to an AdaptrisMessage.javax.jms.Message types that are supported by this translator.Translates betweenAdaptrisMessage
andjavax.jms.Messages
MetadataElement
key and value set as property ofjavax.jms.Message
usingsetBooleanProperty(String key, boolean value)
.Translates betweenAdaptrisMessage
andjavax.jms.BytesMessages
.AcknowledgementHandler
implementation that handles acknowledging messages when in CLIENT_ACKNOWLEDGE mode.Provides aJMSCorrelationId
for thejavax.jms.Message
.Default implementation ofProducerSessionFactory
.Contains behaviour common to PTP and PAS JMS message producers.Utility class to convert a meaningful string into a javax.jms.DeliveryMode constant.JmsConnection implementation that wraps a list of concrete JMSConnection instances to provide failover.MetadataElement
key and value set as property ofjavax.jms.Message
usingsetIntProperty(String key, int value)
.Interface specifying common configuration for JMS WorkersJMS 2.0 Producer implementation that extends all features ofJmsProducer
, but allows us to send messages asynchronously.JMS 1.1 standard JMS connection.Simple interface that provides configuration information for sub components.Standard implementation of ConnectionErrorHandler which implementsExceptionListener
.Constants used in this package.JMS Consumer implementation that can target queues or topics via an RFC6167 style destination.Contains behaviour common to PTP and PAS JMS message consumers.A JMS Destination as specified by a limited parse of an RFC6167 style string.ConcreteJmsPollingConsumerImpl
implementation that can target queues or topics via an RFC6167 style destination.Abstract implementation ofAdaptrisPollingConsumer
for queues and topics.JMS Producer implementation that can target queues or topics via an RFC6167 style destination.JMS synchronous consumer implementation that can target queues or topics via an RFC6167 style endpoint.Subclass ofStandardWorkflow
for use with JMS consumers.MetadataElement
key and value set as property ofjavax.jms.Message
usingsetLongProperty(String key, long value)
.Translates betweenAdaptrisMessage
andjavax.jms.MapMessage
.Implementation ofProducerSessionFactory
that creates a new session/producer based the number of messages.Attempts to use theInterlokMessage.getUniqueId()
as theJMSCorrelationID
and vice versa.Implementation ofProducerSessionFactory
that creates a new session/producer based on message size.Interface that translateAdaptrisMessage
s to the various type ofjavax.jms.Message
s, and vice versa.Super class of classes that translateAdaptrisMessage
s to the various type ofjavax.jms.Message
s, and vice versa.Contains behaviour common to theMetadataConverters
.Implementation ofCorrelationIdSource
which uses the value stored against a configureable metadata key as theJMSCorrelationId
.Class that abstracts the handling of AdaptrisMessage metadata and JMS Headers away from the MessageTypeTranslator.Interface that abstracts the handling of AdaptrisMessage metadata and JMS Headers away from the MessageTypeTranslator.Implementation ofProducerSessionFactory
that creates a new session/producer based on message size.AcknowledgementHandler
implementation that does nothing.Default implementation odCorrelationIdSource
which does nothing.Translates betweenjavax.jms.ObjectMessage
s andAdaptrisMessage
s and vice versa.Behaviour forjavax.jms.MessageListener.onMessage
is identical for polling and listening implementations.JMS Publish-and-subscribe implementation ofAdaptrisMessageConsumer
.PAS implementation ofJmsPollingConsumer
.AdaptrisMessageProducer
implementation for Topic based JMS.Implementation ofProducerSessionFactory
that creates a new session every time is produced.Wrapper around aMessageProducer
andSession
.Handles the creation of a JMS Session and MessageProducer forJmsProducerImpl
instances.Partial implementation ofProducerSessionFactory
JMS Queue implementation ofAdaptrisMessageConsumer
Queue implementation ofJmsPollingConsumerImpl
.AdaptrisMessageProducer
implementation for Queue based JMS.MetadataElement
key and value set as property ofjavax.jms.Message
usingsetStringProperty(String key, String value)
.Translates betweenAdaptrisMessage
andjavax.jms.TextMessages
.Implementation ofProducerSessionFactory
that creates a new session/producer based an inactivity timer.Partial implementation with common or default behaviour.Abstract factory that insulates vendor-specific code from the rest of thecom.adaptris.core.jms
package.Partial implementation with common or default behaviour.