Package com.adaptris.core
package com.adaptris.core
The main Interlok package.
-
ClassDescriptionAbstract implementation of AdaptrisMarshaller.Main class in
core
package.Contains behaviour common to allEvents
in the framework which relate to anAdapter
's lifecycle.Factory Class that creates the required Marshaller ie the DataBinder instance that allows us to marshal & unmarshal our objects eg XStream, Castor etc
This factory also allows the DataBinder to be configured to output to a given format eg JSON/XML.Concrete implementations of thisEvent
contains details of theAdapter
configuration.XStream Marshaller Specific Factory class.Base interface for components in the framework.Represents a connection to an application or of a protocol type.Contains behaviour common to implementations ofAdaptrisConnection
.Defines methods required to 'marshal' Java objects to XML.Represents a message in the framework.Implementations ofAdaptrisMessageConsumer
obtain data, convert it into anAdaptrisMessage
and pass the message to the registeredAdaptrisMessageListener
.Implementation of behaviour common toAdaptrisMessageConsumer
s.Implementations ofAdaptrisMessageEncoder
create representations of wholeAdaptrisMessage
s, including metadata and unique ID.Partial implementation of behaviour commom to allAdaptrisMessageEncoder
instances.Astatic
factory which returns implementations ofAdaptrisMessage
.Standard implementation ofAdaptrisMessage
interface.Applies arbitrary processing toAdaptrisMessage
s.Implementations ofAdaptrisMessageProducer
produce messages to a destination (such as a JMS Queue or file system directory).Implementation of behaviour common toAdaptrisMessageProducer
s.New interface so that we can re-use producer style functionality without all the additional requirements surrounds AdaptrisMessageWorker.Base interface for translating messages to and from AdaptrisMessage instances.Defines behaviour common toAdaptrisMessageConsumer
andAdaptrisMessageProducer
.Implementation of behaviour common toAdaptrisMessageConsumer
andAdaptrisMessageProducer
.Add a new payload to the message.Abstract class for connections that have the ability to retry connections.Implementation ofServiceCollection
which allowsbranching
services to select the next service to apply.Contains behaviour common toBranchingService
s.Links twoAdaptrisConnection
implementations and has aWorkflowList
ConnectionErrorHandler
which shutdowns the channel where there is a problem.Strategy for handling channel lifecycle within aChannelList
.Container for a collection ofChannel
objectsDeprecated.since 4.2.0Implementation of ServiceCollection that creates a new clone of AdaptrisMessage for each configured service.Represents closedStateManagedComponent
s and implements permitted transitions.Defines standard lifecycle operations for components in the framework.Extensions on the standard component lifecycle.Defines the state transition requests that can be made to aStateManagedComponent
.Default implementation ofComponentState
.Provides the ability for the UI to have notes associated with an configuration item.An interface that represents aService
that contains a connection.Implementations of this class encapsualte behaviour that is invoked when anException
relating to a connection is encountered.Behaviour common toConnectionErrorHandler
s.Constants for thecore
package.StandardException
in thecore
package and sub-packages.Deprecated.AdaptrisMessage
implementation created byDefaultMessageFactory
Default strategy for starting channels.Basic implementation ofEventHandler
.Implementation ofFailedMessageRetrier
that does not allow duplicate workflows.JMX Interface forDefaultFailedMessageRetrier
Convenience for getting the default marshalling system currently available in the adapter.The default factory which returns implementations ofAdaptrisMessage
.MessageLogger implementation that that logs unique-id and metadata.Default strategy for starting workflows.Provides a template forPollingTrigger
.Marker interface so that not all services can be configured.A Service instance that references a Service made available viaSharedComponentList.getServices()
.ErrorHandlerRegister
Contains behaviour common to allEvent
s in the framework.Static factory which createsEvent
s.Defines behaviour related to sending and receivingEvent
s using other standard framework components.Marker interface indicating that this component needs to be made aware of the EventHandler.Contains behaviour common to implementations ofEventHandler
.All concrete subclasses ofEvent
should define there own 'name space' or hierarchical name, thus allowing interested parties to subscribe forEvent
s selectively.Component which consumes AdaptrisMessages and, based on message metadata, resubmits them to the Workflow which processed them originally.Component which consumesAdaptrisMessage
s and, based on message metadata, resubmits them to theWorkflow
which processed them originally.Creates a file name for anAdaptrisMessage
.Implementation ofPoller
which polls at a configurable fixed interval.Implementation of FileNameCreator that usesString.format(String, Object...)
.Implementation of Poller which polls at a random interval with a normal distribution.StandardAdapter
heartbeat event.Represents initialisedStateManagedComponent
s and implements permitted transitions.Implemented by classes which generate message lifecycle events.Container for message lifecycle events (MleMarker
s) for implementations ofAdaptrisMessage
.A container class for handling aCollection
ofMetadataElement
instance.A key-value pair ofString
metadata.Implementation ofFileNameCreator
which obtains the file name to use from message metadata.Implementation ofAdaptrisMessageEncoder
that storesAdaptrisMessage
payload and metadata as a mime-encoded multipart message.MimeEncoderImpl<T,S> Records information about activities (generallyService
implementations) performed on aAdaptrisMessage
during a workflow.Interface for Adaptris messages that support multiple payloads, referenced by an ID/key.The standard implementation of multi-payload messages;MultiPayloadAdaptrisMessage
implementation created byMultiPayloadMessageFactory
.The multi-payload message factory which returns an implementations ofMultiPayloadAdaptrisMessage
.Multi-payload message MIME encoder.Implementation ofWorkflow
that contains multiple producers.Base Implementation of a no-op connection.This is a dummy for marshalling purposes.No Op connectionImplementation ofConnectionErrorHandler
for use with polling consumers where you do not want an Exception thrown back to run to re-init the Channel.Null implementation ofAdaptrisMessageConsumer
.Null implementation ofAdaptrisMessageProducer
.Implementation of theOutOfStateHandler
which does no checks.Null implementation of Processing Exceptions.Deprecated.since 4.2.0Null implementation ofService
.Implementations will be able to test if aStateManagedComponent
is in the expected state.Abstract implementation of theOutOfStateHandler
.Schedules polling forAdaptrisPollingConsumer
s.Partial implementation ofPoller
.Periodically sends a template message to trigger aWorkflow
How to generate the template that will be sent to the workflow.A Workflow that pools ServiceCollections.Standard interface for handling errors during processing of a message.Exception
thrown byAdaptrisMessageProducer
s.Deprecated.since 4.2.0Deprecated.since 4.2.0Convenience class that only supports produce rather than request.Implementation ofPoller
which provides cron style scheduled polling based on the Quartz project.This implementation of theOutOfStateHandler
will simply throw anOutOfStateException
every time when aStateManagedComponent
is not in the correct/expected state.Implementation of Poller which polls at a random interval with a delay between each execution of up-to the configured poll interval (in ms).Abstract Request Reply enabled producer that may be extended by concrete sub-classes.Abstract Request Reply enabled producer that may be extended by concrete sub-classes.Implementation ofWorkflow
to handle synchronous replies.Deprecated.since 3.10.2MessageErrorHandler implementation that allows automatic retries for a problem message.Abstract MessageErrorHandler implementation that allows automatic retries for a problem message.An implementation of StandaloneProducer that on encountering an error producing a message, waits for a configurable period, re-initialises the underlying components, then tries to produce once one more.RootProcessingExceptionHandler which allows you to register a Digester for aggregating information about all the errors that have occurred.Resolver implementation that resolves and escapes XML content.The SerializableAdaptrisMessage simply represents an AdaptrisMessage that can be serialized.Implementations ofService
apply aribtrary functionality toAdaptrisMessage
s.Defines behaviour common to collections ofService
s.Behaviour common toServiceCollection
s.Exception
thrown byService
s.Implementation of default / common behaviour forService
s.Implementation ofServiceCollection
with an ordered list ofService
s.A marker interface for Services that wrap other services.Strategy for handling connection lifecycle within aSharedComponentList
.A common store for components.A connection instance that references a connection made available viaSharedComponentList
.A Service instance that references a Service made available viaSharedComponentList
.Wrapper class for aAdaptrisMessageConsumer
and aAdaptrisConnection
.Wrapper for aAdaptrisConnection
and aAdaptrisMessageProducer
for convenience.StandaloneProducer extension that allows request reply functionality within a serviceProcessingExceptionHandler implementation that contains a single service to apply when a message fails.Standard implementation ofWorkflow
.Represents startedStateManagedComponent
s and implements permitted transitions.Specifies methods for components which manage state transitions.Extension toStateManagedComponent
used for fine grained state transitions.Provides a static template forPollingTrigger
.Represents stoppedStateManagedComponent
s and implements permitted transitions.Switch the message payload from one payload to another.Workflow that executes services in the current thread.This implementation of theOutOfStateHandler
will simply wait on the current Thread for theStateManagedComponent
to be in the correct/expected state.Workflow
s link anAdaptrisMessageConsumer
, aServceCollection
and anAdaptrisMessageProducer
.Partial implementation ofWorkflow
.Interface for intercepting messages as they enter and exit a workflow.Strategy for handling workflow lifecycle within aWorkflowList
.Container for a collection ofWorkflow
s.A Workflow that has a object pool of ServiceCollectionsJSON implementation ofAdaptrisMarshaller
using XStream.XStream version ofAdaptrisMarshaller
Abstract XStream version ofAdaptrisMarshaller