All Classes and Interfaces
Class
Description
Abstract base class for adding sequence numbers into metadata.
The behaviour of the sequence number generator when the number exceeds that specified by the number format.
Abstract implementation of AdaptrisMarshaller.
Wrapper around an OAUTH token.
Utility class to convert a meaningful string into a javax.jms.Session
constant.
Service which processes asynchronous acknowledgements for messages stored
using
StoreMessageForRetryServiceTest.ConnectionErrorHandler implementation that actively attempts messages via JMS to detect outages.
Main class in
core package.AdapterLifecycleEvent indicating that close has been invoked.Implementation of
AdapterComponentCheckerMBean for use by the GUI to check components.MBean for the UI to ask the adapter to test configuration.
Base interface that exposes management functionality for an Adapter component.
The interface which has all the methods that provide the functionality to create,
save or sync the adapter.
AdapterLifecycleEvent indicating that init has been invoked.
Contains behaviour common to all
Events in the framework
which relate to an Adapter's lifecycle.Base implementation of
AdapterManagerMBean.MBean specification that allows control of a single adapter.
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.
This factory also allows the DataBinder to be configured to output to a given format eg JSON/XML.
A registry of Adapters that are available for management.
Responsible for authenticating against network resources when requested.
Base interface that exposes management functionality for an Adapter component.
AdapterLifecycleEvent indicating that ShutdownHandler has been invoked.AdapterLifecycleEvent indicating that start has been invoked.Concrete implementations of this
Event contains details of the Adapter configuration.AdapterLifecycleEvent indicating that stop has been invoked.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 of
AdaptrisConnection.
Defines methods required to 'marshal' Java objects to XML.
Represents a message in the framework.
Implementations of
AdaptrisMessageConsumer
obtain data, convert it into an AdaptrisMessage and pass
the message to the registered AdaptrisMessageListener.
Implementation of behaviour common to
AdaptrisMessageConsumers.
Implementations of
AdaptrisMessageEncoder create representations
of whole AdaptrisMessages, including metadata and unique ID.
Partial implementation of behaviour commom to all
AdaptrisMessageEncoder instances.
A
static factory which returns implementations of
AdaptrisMessage.
Standard implementation of
AdaptrisMessage interface.
Applies arbitrary processing to
AdaptrisMessages.
Implementations of
AdaptrisMessageProducer produce messages to a destination (such as a JMS Queue or file system
directory).
Implementation of behaviour common to
AdaptrisMessageProducers.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 to
AdaptrisMessageConsumer and
AdaptrisMessageProducer.
Implementation of behaviour common to
AdaptrisMessageConsumer and AdaptrisMessageProducer.This is the root container class for any exceptions that occur in the
security library.
Add a mapped diagnostic context via
MDC.put(String, String).Add a formatted metadata item to a Message.
Add a mapped diagnostic context via
MDC.put(String, String).
Implementation of
Service that adds static metadata to be added to a message.Implementation of
CommandOutputCapture that saves the output of the system command to a metadata value
Implementation of
Service that adds a static NamespaceContext to object metadata for use by other services.Add a new payload to the message.
Adds timestamp information as metadata.
Service implementation that adds entries to a cache based on its configured CacheEntryEvaluators.Version of
AddToCacheService that doesn't use CacheEntryEvaluator.
ActiveMQ implementation of
VendorImplementation.Non-Exhaustive list that matches various ActiveMQConnectionFactory methods.
A
DatabaseConnection instance that provides connection pooling via c3p0.
Splits incoming
AdaptrisMessages into several using an implementation of MessageSplitter.Consumer interface for performing aggregation.
Base class for
AggregatingConsumer implementations.Marker interface for all implementations of
AggregatingConsumer to use.Base class for
AggregatingConsumeService implementations providing common functionality.AggregatingConsumer implementation that allows you to read a separate message from
the filesystem that is correlated in some way to the current message.Implentation of
AggregatingConsumeService that allows you to consume a related message from a directory based on some
criteria.AggregatingConsumer implementation that allows you to read a separate message from
an FTP filesystem that is correlated in some way to the current message.Implentation of
AggregatingConsumeService that allows you to consume a related
message via FTP based on some criteria.Implentation of
AggregatingConsumeService 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.Alias in a keystore.
Abstract class for connections that have the ability to retry connections.
Translate the all the rows of the result set into metadata.
Sort the list of files alphabetically.
Sort the list of files alphabetically in reverse order
Deprecated.
Identity verification always fails.
Always match.
This RestartStrategy will always return true upon requiresRestart().
ApacheFtpClientImpl<T extends org.apache.commons.net.ftp.FTPClient>
Base implementation of
FileTransferClient that uses the apache
commons net FTP implementation.Implementation of
FsWorker that appeneds to the file for any write operations.Implementation of
MessageAggregator that just appends payloads.Utility for parsing unix style arguments.
Perform a best guess routine on the JMSMessage when translating to an AdaptrisMessage.
javax.jms.Message types that are supported by this translator.
Simply convert to and from base58.
Simply convert to and from base64.
Base64 decods an item of metadata.
Base64 Decode the message.
Base64 encode an item of metadata.
Base 64 Encode the message.
Basic JMX component mbean interface.
ActiveMQ implementation of
VendorImplementation.Factory which will return an instance of org.eclipse.jetty.security.authentication.BasicAuthenticator
Translates between
AdaptrisMessage and javax.jms.MessagesThis is the abstract class for all implementations that make use of Jetty to receive messages.
Splits incoming
AdaptrisMessages into several AdaptrisMessages using an implementation of
MessageSplitter.Used with
XmlValidationService to validate an XML message against a schema.Binary Stream Statement Parameter.
A blacklisting classloader factory.
Column Translator implementation for handling BLOB types
Translates between
AdaptrisMessage and BlobMessage.Proxy class for creating BlobTransferPolicy objects
Blocking strategy for starting channels.
Allows you to iterate over a multipart returning each part as a
MimeBodyPart.Column Translator implementation for handling boolean types
MetadataElement key and value set as property of javax.jms.Message
using setBooleanProperty(String key, boolean value).Boolean Statement Parameter.This class holds the necessary information for startup and provides a extra method for getting the available adapter
configuration.
Branch support for HTTP via interrogation of the HTTP status.
Implementation of
ServiceCollection which allows branching services to select the next service to apply.Service that wraps other services allowing them to be branching.
Contains behaviour common to
BranchingServices.Column Translator implementation for handling byte array types.
A Datasource wrapping an arbitary array of bytes.
Wraps a metadata value as a byte[]
Wraps an object metadata value as a byte[]
Returns the message payload as as byte array.
Allows you to iterate over a multipart returning each part as a byte array.
This
DataOutputParameter is used when you want to write data to the AdaptrisMessage payload.Implementation of
CacheValueTranslator that retrieves / sets the payload of the message.Byte Payload Statement Parameter.
Translates between
AdaptrisMessage and javax.jms.BytesMessages.Abstract Base class for converting strings into bytes and vice versa.
Interface that defines basic general cache operations for use within the adapter.
A Connection to a cache instance.
Extension of
StandardJndiImplementation that caches destinations in between calls.Evaluates cache keys and values for the various cache services.
Interface for EventListeners on the cache.
Implementation that implements
CacheEventListener and logs all the events.Get the key from the message.
A Connection to a cache instance.
Base class that provides common functions used by all cache services
Interface that defines a two way interaction - one to retrieve a value from an
AdaptrisMessage and another to inject a
value into one.Helper to avoid multiple executions of
DefaultPreProcessorLoader.load(BootstrapProperties).A 'case' for
Switch.Condition that is always true.
List implementation for use with castor marshal/unmarshalling.
Wraps any exception encountered during certificate operations.
The interface for the creation of certificates.
Another factory for building certificates.
A wrapper around a certificate object.
Factory to build Certificate Handlers.
Container class with enough information to create a certificate.
Convenience wrapper for verifiying Certificate chains.
Creating Certificate Signing Requests.
Changes the character encoding associated with a message.
Links two
AdaptrisConnection implementations and has a WorkflowListConnectionErrorHandler which shutdowns the channel where there is a problem.Strategy for handling channel lifecycle within a
ChannelList.
Container for a collection of
Channel objectsBase implementation of
ChannelManagerMBean.Interface specifying controls for a single channel.
AdapterLifecycleEvent indicating a Channel restart.Deprecated.
since 4.2.0
Character Stream Statement Parameter.
Simply convert bytes into strings using the configured encoding.
Service implementation that checks if specific key(s) exist in the cache and retrieves.Service implementation that checks if specific key(s) exist in the cache.
Branching
Service implementation which checks the value stored against a configured metadata key against a list of
previously received values.
Branching
Service implementation which checks the value stored against a configured metadata key against a list of
previously received values.Basic interface of MBeans that contain child member components.
Basic interface of MBeans that contain child member components.
Clear the contents of the specified cache.
Clears any exception stored against
CoreConstants.OBJ_METADATA_EXCEPTION.Remove all mapped diagnostic context via
MDC.clear().AcknowledgementHandler implementation that handles acknowledging messages when in CLIENT_ACKNOWLEDGE mode.Additional settings on the
FTPClient.Additional settings on the
FTPSClient.ClientSettings.Setter<T extends org.apache.commons.net.ftp.FTPClient>
Column Translator implementation for handling CLOB types
Implementation of ServiceCollection that creates a new clone of AdaptrisMessage for each configured
service.
Represents closed
StateManagedComponents and implements permitted transitions.Translate a column in a ResultSet into a String for processing.
Write a column into an Output stream.
Interface for providing command line arguments to the
SystemCommandExecutorServiceInterface for building a process.
Interface for capturing output from a process.
FTP Client implementation.#
FTP/SSL client.
Used with
MetadataComparisonService.Defines standard lifecycle operations for components in the framework.
Extensions on the standard component lifecycle.
Base class for all component managers.
Defines the state transition requests that can be made to a
StateManagedComponent.
Default implementation of
ComponentState.A
FileFilter that contains other filters.IdentityBuilder implementation that wraps a list of builders.Composite keystore which manages keystores of different types.
MetadataFilter implementation that wraps a list of filters.Implementation of
RequestHeaderProvider that uses nested providers to add headers to a HttpURLConnection.Implementation of
ResponseHeaderHandler that uses nested handlers to extract headers from a HttpURLConnection.ResponseHeaderProvider implementation that uses a nested set of providers to private HTTP response headers.
This
Condition allows you to specify a boolean evaluated expression, with static values
and resolved metadata values.
This
Condition targets message metadata.Condition that is never true.
This
Condition targets the message payload.Interface for managing JSCH/SSH configuration specifics.
Provides the ability for the UI to have notes associated with an configuration item.
Deprecated.
AdapterConfigManager is now available, the only reason why this still exists is to avoid breaking sonic-mf
Implementations of this interface will perform actions on the xml configuration before
the configuration is unmarshalled.
An abstract implementation of the
ConfigPreProcessorJetty Security Handler Wrapper which allows the configuration
of different Login Service and Authenticators.
ServiceLoader interface that allows for config checks to be performed.ServiceLoader interface that allows for config checks to be reported on.Build an
HttpConstants.AUTHORIZATION header from static data.Provides a static content type.
ExceptionGenerator implementation that generates the exception from static configuration.Abstract class for presenting arbitary configuation as KeystoreLocation
objects.
Private key password provider which explicitly configures the password in configuration
ReplacementSource implementation which returns the passed in value.Implementation of
RequestHeaderProvider that applies configured values as headers to a HttpURLConnection.Static implementation of
RequestMethodProvider.ResponseHeaderProvider implementation that provides a static configured set of headers.Build an SQL Statement for
JdbcDataQueryService from static configuration.ConfiguredStatementCreator.
Static implementation of
HttpStatusProvider that uses HttpStatusProvider.HttpStatus to derive the correct code.Allows the wrapping of a configured URL as a KeystoreLocation
Authenticate using the standard
PasswordAuthentication method with a static username and passwordXpathObjectQuery implementation that returns a NodeList.XpathObjectQuery implementation that returns a NodeXpathQuery implementation that retuns a single text item from the configured xpath.
Abstract base class for XpathQuery implementations that are statically configured.
An interface that represents a
Service that contains a connection.
Implementations of this class encapsualte behaviour that is invoked when an
Exception relating to a connection is encountered.
Behaviour common to
ConnectionErrorHandlers.
This
DataInputParameter is used when you want to configure data directly in the Interlok configuration.
Constants relating to retrying messages.
Constants and lots of them.
Constants.
This implementation of @{link ValueTranslator} uses a static String value, that can be used as a
parameter for Jmx operations.
Used with
MetadataComparisonService.Used with
MetadataComparisonService.Interface to provide a
Content-Type header for the HTTP request or response.Interface for validating arbitary XML content against the relevant
schema.
Simple Data Conversion methods.
Implementation of
Service that copies Object metadata to standard metadata, overwriting standard metadata.Copies metadata from one key to another.
Constants for the
core package.
Standard
Exception in the core package
and sub-packages.The base class for all security services.
Provides a
JMSCorrelationId for the
javax.jms.Message.Service that creates a URL query string from the specified metadata keys.
Abstract class containing configuration for JDBC Connection classes.
DataStore abstract class.
DataStoreException.
Column Translator implementation for handling date types
Builds a DateFormat instance for use with
ReformatDateService and AddTimestampMetadataService.Builds a DateFormat instance for use with
ReformatDateService and AddTimestampMetadataService.Contains convenience method to format date strings into Date objects.
Custom date formats over and above
SimpleDateFormat.A
Date extension to StatementParameter.Constructs a C3P0 connection pool with various debug settings enabled.
Interface for decoding properties.
Decodes the payload and updates the in flight message with the decoded output.
Wraps any exception during decryption.
Perform decryption.
Deprecated.
AdaptrisMessage implementation created by DefaultMessageFactoryDefault strategy for starting channels.
Default implementation of
CommandBuilder
Basic implementation of
EventHandler.
Implementation of
FailedMessageRetrier that does not allow duplicate workflows.JMX Interface for
DefaultFailedMessageRetrierConvenience for getting the default marshalling system currently available in the adapter.
The default factory which returns implementations of
AdaptrisMessage.MessageLogger implementation that that logs unique-id and metadata.
Constructs a C3P0 connection pool for use with
JdbcPooledConnection and
PluggableJdbcPooledConnection.Default implementation of
ProducerSessionFactory.Default
ServiceExtractor implementation that treats the entire payload as the service.Default CallableStatementCreator.
Default strategy for starting workflows.
Contains behaviour common to PTP and PAS JMS message producers.
Utility class to convert a meaningful string into a javax.jms.DeliveryMode
constant.
An OutputStream that goes nowhere.
Metadata Filter implementation that removes all metadata which have an empty value.
ResponseHeaderHandler implementation that discards the headers from the HTTP response.Metadata Filter implementation that removes all metadata where the value exceeds the configured
length.
Allows simple configuration of a
DocumentBuilderFactory.Column Translator implementation for handling double types
Double Statement Parameter.Simulate a do-while loop.
Class which checks the value of a configured metadata key against a list of previously received values.
Abstract super-class of the two
Services which handle duplicate message checking.Build a
HttpConstants.AUTHORIZATION (Basic only) from configuration (or metadata).Allows you to dynamically connect to different
JMXServiceURLs and execute JMX Operations.Provides a template for
PollingTrigger.Marker interface so that not all services can be configured.
Implementation of
Service which dynamically obtains and applies a
Service to an AdaptrisMessage based on the
contents of the message.
A Service instance that references a Service made available via
SharedComponentList.getServices().Format element metadata as a string.
Key and value element formatter.
Default element formatter.
The EmbeddedConnection makes use of the existing Jetty Engine that has been enabled as part of the bootstrap process.
A no-op identity builder.
Just the supported Base64 styles which are available via
Base64Standard supported encodings
Encodes the in flight message and sets the payload to the encoded output.
Wraps any exception encountered during encryption operations.
Container class with encryption algorithm information.
Perform encryption only.
Base case for performing encryption and signing.
Perform encryption and signing.
Used with
MetadataComparisonService.Used with
MetadataComparisonService.
This
Operator simply tests two values for equality.Used with
MetadataComparisonService.Used with
MetadataComparisonService.Exact value match implementation of MetadataValueMatcher for
MetadataValueBranchingService.ErrorHandlerRegister
Contains behaviour common to all
Events in the framework.
Static factory which creates
Events.
Defines behaviour related to sending and receiving
Events using
other standard framework components.Marker interface indicating that this component needs to be made aware of the
EventHandler.
Contains behaviour common to implementations of
EventHandler.
All concrete subclasses of
Event should define there own 'name
space' or hierarchical name, thus allowing interested parties to subscribe
for Events selectively.Implementation of
StatusEvaluator for use with BranchingHttpRequestService.Serializes the exception as a String.
Use with
ExceptionReportService to write the exception as part of an xml document.ExceptionGenerator implementation that generates the exception from metadata.ExceptionGenerator implementation that generates the exception from metadata.Interface for generating an exception from an
AdaptrisMessage object.Wraps services so that errors are intercepted and processed by a different service.
Helper class that assists converting exceptions.
Object that wraps all the information for an exception report.
Interface for generating an XML report from an exception for use with
ExceptionReportServiceService that takes an exception in object metadata and serializes that into the AdaptrisMessage payload.
Use with
ExceptionReportService to write the exception as part of the message.Metadata filter implementation that removes metadata where the key matches
^JMS.*$.Implementation of CallableStatementExecutor will use the
PreparedStatement.execute() method.Implementation of CallableStatementExecutor will use the
PreparedStatement.executeQuery() method.Implementation of CallableStatementExecutor will use the
PreparedStatement.executeUpdate() method.Condition that checks whether a key exists in a
CacheCache implementation backed by
net.jodah:expiringmap hosted on
github.ExpirationListener implementation that notifies any configured CacheEventListener that are configured.Used with
XmlValidationService to validate an XML message against a schema.Extract additional metadata values from an item of metadata.
Interface that allows you to configure the ConnectionFactory that is returned from a
StandardJndiImplementation.
Component which consumes AdaptrisMessages and, based on message
metadata, resubmits them to the Workflow which processed them
originally.
Component which consumes
AdaptrisMessages and, based on message metadata, resubmits them to the
Workflow which processed them originally.Class that is used to configure a failover database connection.
A wrapper around a JDBC Connection.
Datasource that has a connection capable of failover to an alternate
database.
An
AdaptrisConnection implementation for a failover database connection.JmsConnection implementation that wraps a list of concrete JMSConnection instances to provide failover.
Wraps an instance of
Semaphore and adds
'mut-ex' behaviour.
Represents a message in the framework which is backed by a file on the
filesystem.
Message factory that returns an AdaptrisMessage Implementation that is backed by a pair of files.
Implementation of
AdaptrisMessageEncoder that stores payload and metadata as a mime-encoded multipart message.DataInputParameter implementation that reads from a file.DataInputParameter implementation that writes to a file.MessageWrapper implementation that wraps an external file as an InputStream.DataInputParameter implementation that returns an input stream to a file.
Creates a file name for an
AdaptrisMessage.MessageWrapper implementation that wraps an external file as an OutputStream.Interface that allows FsConsumer style implementations to sort the list of files before processing.
Writes data into local storage for retry.
Common interface for all FTP client flavours.
Abstract implementation of FileTransferClient.
Class containing common configuration for all FTP Connection types.
Common data/methods for file transfer connections that use username/password
Exception encapsulating an file transfer error.
Filtered start strategy for
SharedComponentListImplementation of
Service which allows find and replace operations on the message payload.A unit of configuration for doing find and replace.
Translate the first row of the result set into metadata.
Implementation of
Poller which polls at a configurable fixed interval.MetadataFilter that just uses the configured KeyValuePairSet as the metadata.Flatten any nested
MimeBodyParts inside the payload.Column Translator implementation for handling float types
Float Statement Parameter.A for-each implementation that iterates over the payloads in a multi-payload message
MultiPayloadAdaptrisMessage.Abstract column Translator implementation for handling column types that might need to have formatting applied to it.
Implementation of FileNameCreator that uses
String.format(String, Object...).Service that creates something suitable to send as
application/x-www-url-form-encoded
from metadata.Takes a application/x-www-url-form-encoded payload and extracts it as metadata.
Build a jetty server from a failsafe XML configuration
File system implementation of
AdaptrisMessageConsumer based on the com.adaptris.fs package.
Abstract implementation of
AdaptrisMessageConsumer based on the com.adaptris.fs package.
Root of all custom
Exceptions in the fs package
and sub-packages.
Subclass of
FsException indicating that a file has not be found.
Subclass of
FsException indicating that a file has not be found.
Implementation of
Poller which listens for file events.AdaptrisMessageProducer implementation that writes to the file system.
Defines basic file system operations.
Class containing configuration for both FTP Consumers and producers.
Abstract implementation of FTPConnection both vanilla and SSL.
FTP implementation of the AdaptrisMessageConsumer interface.
Abstract FTP Implementation of the
AdaptrisMessageConsumer implementation.Represents the DATA mode.
FTP specific exceptions
Extension to
FileTransferClient specifically for FTP.Ftp implementation of the AdaptrisMessageProducer interface.
FTP implementation of the AdaptrisMessageConsumer interface.
Allows connections to FTP (Explicit) SSL connections.
MessageLogger implementation that that logs unique-id, metadata, payload, and events.
Implementation of Poller which polls at a random interval with a normal distribution.
Service implementation that generates a unique item of metadata.
Variation of
GetOauthToken that automatically caches the AccessToken in the cache of your choosing.Simplified framework for retrieving OAUTH tokens from verious 3rd party resources (such as Salesforce, or Google).
GetServiceByName.
Version of
RetrieveFromCacheService that doesn't use CacheEntryEvaluator.Creates a GUID using
UUID.randomUUID().Generates a unique id that is still globally unique similar to
GuidGenerator but contains
a date/time component.Unzip the given payload.
Gzip the given payload.
Allows you to configure a
HashLoginService for use with Jetty.Interface for handling behaviour for HTTP headers.
Abstract
HeaderHandler implementation that provides a prefix.
Standard
Adapter heartbeat event.A utility class to perform a hexdump of a given number of bytes.
ReplacementSource implementation which assumes that the value is a byte sequence represented as a sequence of hexadecimal
numbers (2 characters per byte).Simply converts to and from a Hex String
This class will decode hex encoded metadata value(s) using the specified character encoding
Constructs a HikariCP connection pool for use with
PluggableJdbcPooledConnection.Contains host configuration for use with
PerHostConfigBuilder.HttpAuthenticator is an interface designed to facilitate HttpAuthentication in various ways.
Concrete implementation of JettyConnection that allows HTTP traffic.
Standard
HttpConfiguration properties for use with HttpConnection.setHttpConfiguration(KeyValuePairSet).Standard
ServerConnector properties for use with HttpConnection.setServerConnectorProperties(KeyValuePairSet).Direct HTTP support as a service rather wrapped via
StandaloneProducer or StandaloneRequestor.Direct HTTP support as a service rather than wrapped via
StandaloneProducer or StandaloneRequestor.Concrete implementation of JettyConnection that allows HTTPs traffic.
Properties for
SecureRequestCustomizer.Properties for
SslContextFactory.Builder class for a
HttpStatusProvider.Status.Interface for providing a HTTP Status.
Default status code definitions.
HttpURLConnectionAuthenticator is an interface designed to facilitate HttpAuthentication in various ways.
Used in conjunction with
IdentityBuilder.Interface for ID Generation.
Ignore all exceptions coming nested services, including Timeouts
XmlTransformParameter implementation that returns a null map.MessageAggregator implementation that creates a new mime part for each message that needs
to be joined up.MessageAggregator implementation that creates single XML using each message that needs to be joined up.Null implementation of
CommandOutputCaptureIgnores case match implementation of MetadataValueMatcher for
MetadataValueBranchingService.WorkflowInterceptor implementation that exposes acts as the source for
MessageInFlightMBean.
Represents initialised
StateManagedComponents and implements permitted transitions.A statically configured SSH
ConfigRepository with global defaults for all hosts.In memory cache of items that have been processed.
Specifically presents an embedded encoded Certificate string as a KeystoreLocation object.
Builds a MIME Body part by rendering a byte array as the content of the part.
Represents a single INOUT parameter for a Stored Procedure.
This class contains the INOUT parameters that a stored procedure will require to be executed.
Represents a single IN parameter for a Stored Procedure.
This class contains the IN parameters that a stored procedure will require to be executed.
Convenience helper to see if configuration is considered an expression
Forces IO to happen from the message inputstream to outputstream.
Merge implementation that appends the result to a parent node derived from an Xpath.
Column Translator implementation for handling integer types
MetadataElement key and value set as property of javax.jms.Message
using setIntProperty(String key, int value).Integer Statement Parameter.Integer based value match implementation of MetadataValueMatcher for
MetadataValueBranchingService.Management MBean definition for publishing JMX notifications.
This
Operator simply tests that the given value evaluates to null or an empty string.FileFilter that accepts files that are files that just uses
org.apache.commons.io.filefilter.FileFileFilter under the covers.
This
Operator tests whether a specified value matches any value in a list
This
Operator simply tests a single value is null.Check the content and ensure it is not null.
Capture Data from a AdaptrisMessage and store it in a JDBC-compliant database.
Stored Procedure parameter implementation
Implementation of
AdaptrisConnectionImp for JDBC.Stored Procedure parameter implementation, can be used only for IN Stored Procedure parameters.
Capture Data from a AdaptrisMessage and store it in a JDBC-compliant database.
Base implementation for capturing data from an AdaptrisMessage and storing it in a jdbc database.
Perform a triggered JDBC query and the results of this query that can be stored in the AdaptrisMessage.
A
Date extension to StatementParameter.A
Time extension to StatementParameter.A
Timestamp extension to StatementParameter.Allows you to configure a
org.eclipse.jetty.security.JDBCLoginService as the login service to use with Jetty.Base behaviour of inserting Objects directly into a db.
Handles simple type conversions for the fields in the map that needs to be inserted into the DB.
Base behaviour for upserting objects directly into a db.
Stored Procedure parameter implementation, can be used for all IN, INOUT and OUT Stored Procedure parameters.
Stored Procedure parameter implementation, can be used for all IN, INOUT and OUT Stored Procedure parameters.
A
DatabaseConnection instance that provides connection pooling via c3p0.Capture Data from a AdaptrisMessage and store it in a JDBC-compliant database.
JDBC-based implementation of
RetryStore.
Provides database connection for JDBC-based
Service implementations.Implementation of
ServiceCollection that creates a Connection instance at the start of
the execution of
the service list and stores it in object metadata.Base implementation for interacting with a database with configurable parameters.
StoredProcedure Producer implementation; executes a stored procedure within your chosen database vendor.
Stored Procedure parameter implementation.
Helper methods used internally to support JDBC operations within the framework.
Stored Procedure parameter implementation, can be used only for IN Stored Procedure parameters.
Allows you to handle a single HTTP request across 2 workflows within the same Interlok instance.
Interface for factory to create Jetty Authenticators
This class is the base class that all Jetty based Connections extend.
IdentityVerifier implementation that uses the same file as HashLoginServiceFactory to perform identity
verification.Interface to create Jetty LoginService instance
This is the standard class that receives documents via HTTP.
WorkflowInterceptor that automatically returns a 503 if it knows there is nothing available to handle the inbound message in the
parent workflow.
WorkflowInterceptor implementation that allows a Jetty Consumer to be part of a
PoolingWorkflow.Send a response via HTTP as a service rather than having to wrap in a
StandaloneProducer.Condition implementation that evaulates based on the JettyURI and HTTP method.Used with
JettyRoutingService to help decide which branch to execute.Use as part of a
BranchingServiceCollection to branch based on the jetty URI and method.This class can be used for configuring and starting a Jetty webserver for the adapter.
Interface for registering servlets by the various jetty connection implementations.
Class that contains information that about the jetty request/response.
Interface specifying common configuration for JMS Workers
JMS 2.0 Producer implementation that extends all features of
JmsProducer, 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 implements
ExceptionListener.
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.
Concrete
JmsPollingConsumerImpl implementation that can target queues or topics via an
RFC6167 style destination.Abstract implementation of
AdaptrisPollingConsumer for queues and topics.JMS Producer implementation that can target queues or topics via an RFC6167 style destination.
Implementation of
CacheValueTranslator that retrieves and sets the JMSReplyTo destination of a message.JMS synchronous consumer implementation that can target queues or topics via an RFC6167 style
endpoint.
Subclass of
StandardWorkflow for use with JMS consumers.Helper for JMX
Allows you to make a remote call on a JMX operation.
Base abstract implementation for all JMX services.
Base abstract implementation for all JMX services.
Implementation of the
ManagementComponent interface for JSR160.
A
WorkflowInterceptor that simply caches all messages that have completed running through
the workflow.
Allows you to make a remote call on a JMX operation and wait until the result from the JMX operation is "true"
Text justification.
Wraps any exceptions encountered during keystore operations.
Factory for creating Keystore Proxy objects.
Wrapper that is used handle the IO to a keystore.
Used to read and write from a keystore.
A key value pair.
A Collection of of KeyValuePair instances.
An collection of KeyValuePair instances.
An
List of KeyValuePair instances.
A Set of
KeyValuePair instances.
File system implementation of
AdaptrisMessageConsumer with large message support.
File system implementation of
AdaptrisMessageProducer with large message support.Workflow that does not store the original message for error-handling purposes.
ExceptionGenerator implementation that generates the exception from the last known exception.Timestamp Generator implementation that returns the last
Date a message passed through the service.Sort the list of files by their last modified attribute
Sort the list of files by their last modified attribute in reverse order.
Abstract
FileFilter that accepts files based on the last modified time of the file.Legacy private key password provider based on the property file 'security.properties'.
AdapterLifecycleEvent indicating that this Adapter's license is about to expire.Helper class that assists in managing component lifecycles.
Split an AdaptrisMessage object by line.
Compare the content against some specified list.
WorkflowInterceptor implementation that adds a mapped diagnostic context via
org.slf4j.MDC#put(String, String).Utility for generating logging messages.
Log some arbitrary information.
Abstract configuration for bundled
org.eclipse.jetty.security.LoginService implementations.Proxy class that allows us to add "roles" as a custom attribute to the
ServletRequest.
Service which logs the
AdaptrisMessage to the configured logger for debugging purposes.MetadataElement key and value set as property of javax.jms.Message
using setLongProperty(String key, long value).Long Statement Parameter.XStream Mapper that aids in name format conversion and handling of implicit
collections.
A
MessageCache implementation that uses an ArrayBlockingQueue to hold the messages.Simple
ThreadFactory implementation for use within the adapter.Interface for management components that exist outside of the standard adapter lifecycle.
Simple factory that creates management components.
Translates between
AdaptrisMessage and javax.jms.MapMessage.Changes the value of a specific metadata key based on a regular expression match of the value associated with the key.
MetadataFilter implementation that modifies keys matching a specific regular expression to another key name.Build the identity from metadata which is mapped to specific values.
Resolver that maps URLs to another URL and caches the results.
Extension to
InlineItemCache that stores the procssed items to disk.
This
Operator simply tests two values for using String.matches(String).Merge the ResultSet contents into an existing XML Payload.
Interface for creating a single
AdaptrisMessage instance from multiple
Messages.Abstract implementation of
MessageAggregator.Interceptor that emits a
Notification under based on message count being higher or lower
than the given message count.Implementation of
ProducerSessionFactory that creates a new session/producer based the number of messages.
This RestartStrategy monitors the number of messages processed and if this number passes
our maximum threshold, then this strategy will return true upon requiresRestart().
MessageErrorDigest that contains a fixed size list of the last n errors.
A Digester for handling and recording any errors during the standard workflow processing.
Implemented by classes which generate message lifecycle events.
Attempts to use the
InterlokMessage.getUniqueId() as the JMSCorrelationID and vice versa.Management bean interface for messages in flight.
Container for message lifecycle events (
MleMarkers)
for implementations of AdaptrisMessage.WorkflowInterceptor implementation that exposes metrics via JMX.
WorkflowInterceptor implementation that captures metrics about messages that match a given metadata criteria.
Abstract WorkflowInterceptor implementation that exposes metrics via JMX.
Management bean interface for message statistics.
Implementation of
ProducerSessionFactory that creates a new session/producer based on message size.Interface for creating multiple messages from a single
AdaptrisMessage instance.Partial implementation of MessageSplitter that handles
MessageSplitter.splitMessage(AdaptrisMessage).
Abstract base class for splitting messages based on some criteria.
A message statistic stored by a
MessageMetricsInterceptorImpl instances.Interceptor that emits a
Notification if the number of messages has exceeded the
specified threshold in the current timeslice.
Interface that translate
AdaptrisMessages to the various type of
javax.jms.Messages, and vice versa.
Super class of classes that translate
AdaptrisMessages to the
various type of javax.jms.Messages, and vice versa.Write the token to metadata.
Service to append multiple metadata keys together to form a new key.
Build an
HttpConstants.AUTHORIZATION header from metadata.
Behaviour common to
Services which branch based on
AdaptrisMessage metadata.Implementation of
CacheValueTranslator that maps values to / from metadata on the message.A container class for handling a
Collection of MetadataElement instance.Provides the metadata value associated with the specified key as a command line argument
Compare two items of metadata returning the result of the comparison.
Implementation of
Service that compares two items of metadata.Provides a content type derived from metadata.
Contains behaviour common to the
MetadataConverters.
Implementation of
CorrelationIdSource which uses the value stored against a configureable metadata key as the
JMSCorrelationId
.WorkflowInterceptor implementation that exposes metrics about metadata values via JMX.
This
DataInputParameter is used when you want to source data from the AdaptrisMessage metadata.This
DataOutputParameter is used when you want to write some data to the AdaptrisMessage
metadata.Implementation of
MessageSplitter which creates multiple instances of the same document based on a metadata key.
A key-value pair of
String metadata.Service which sets the ID of the Service to apply next based on whether any value is present against
any configured metadata key.
Implementation of
FileNameCreator which obtains the file name
to use from message metadata.Interface for finding matching metadata on a AdaptrisMessage.
Implementation of
Service that filters metadata keys based on a MetadataFilter.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.
Hashes the metadata value stored against a metadata key.
HeaderHandler implementation that stores HTTP headers as standard metadata.Build the identity from metadata
Types of metadata.
Implementation of AbstractJdbcSequenceNumberService where the identity is derived from metadata.
Identity verification based on matching metadata keys against other metadata keys.
MessageWrapper implementation wraps a metadata value as an InputStream.MetadataLogger implementation that that logs metadata keys only
Implementation of
ReformatMetadataKey that uses WordUtils.capitalizeFully(String) to
capitalize each word in the key.Implementation of
ReformatMetadataKey that converts keys to lower case.Implementation of
ReformatMetadataKey that converts keys to upper case.ParameterHandler implementation that stores headers as standard metadata.Implementation of
ProducerSessionFactory that creates a new session/producer based on message size.Interface that handles metadata reformatting.
ReplacementSource implementation which returns the metadata value when the replacement value is treated as a metadata
key.Implementation of
RequestHeaderProvider that applies AdaptrisMessage metadata as
headers to a HttpURLConnection.Implementation of
RequestMethodProvider that can derive the method from AdaptrisMessage metadata.
This resolver allows you to specify a prefixed ($$) metadata key in configuration whose metadata value will be used as the actual metadata item key lookup.
ResponseHeaderProvider implementation that providers HTTP response headers from metadata.Abstract class for translating result sets into metadata.
Build an SQL Statement for
JdbcDataQueryService from metadata.A metadata statistic stored by concrete implementations
MetadataMetricsInterceptorImplManagement bean interface for metadata totals statistics.
Implementation of
HttpStatusProvider that can derive the status and text from AdaptrisMessage metadata.This
DataInputParameter is used when you want to read some data from metadata.This
DataOutputParameter is used when you want to write some data to AdaptrisMessage
metadata.Enumeration of where the two types of metadata.
Takes a metadata value and sets that as the payload.
Enumeration of where the two types of metadata.
WorkflowInterceptor implementation that exposes metrics about integer metadata values via JMX.
Authenticate using the standard
PasswordAuthentication method with a username and password derived from metadata.
Implementation of
Service which sets the unique ID of the next Service to apply based on
values of AdaptrisMessage metadata.Takes a metadata value and escapes double quote.
Takes a metadata value and escapes single quote.
Interface for use in
MetadataValueBranchingService.Takes a metadata value and converts it to lower case.
Takes a metadata value and converts it to upper case.
This implementation of
ValueTranslator will pull a metadata value from the
AdaptrisMessage to be used as a Jmx operation parameter.XpathQuery implementation that retuns a
NodeList from an xpath derived from metadata.XpathQuery implementation that retuns a
Node from an xpath derived from metadata.Deprecated.
Use ConfiguredXpathQuery with %message{metadata} syntax to extract XPath from metadata.
Deprecated.
Use ConfiguredXpathQueryImpl with %message{metadata} syntax to extract XPath from metadata.
Abstract WorkflowInterceptor implementation that captures historical data.
Common behaviour for all metrics MBeans.
MessageAggregator implementation that creates a new mime part for each message that needs
to be joined up.Just some constants that are used by Mime.
Implementation of
AdaptrisMessageEncoder that stores AdaptrisMessage payload and metadata as a
mime-encoded multipart message.Utility for handling MIME messages.
Choose a specific mime part from an existing multipart message to become the payload of the AdaptrisMessage.
Choose one or more mime parts from an existing multipart message and add them as metadata of the AdaptrisMessage.
Implementation of
MessageSplitter which allows a single AdaptrisMessage that contains multiple mime
parts to be split into AdaptrisMessage[].ServiceExtractor implementation that uses a PartSelector to extract where the service is.MessageLogger implementation that that logs unique-id only
Records information about activities (generally
Service implementations) performed on a AdaptrisMessage during a
workflow.Extends the non-deleting FS consumer, and after processing stores files in
a separate directory.
XpathQuery implementation that retuns a multiple text items from the configured xpath.
Deprecated.
Use MultiItemConfiguredXpathQuery with %message{metadata} syntax to extract XPath from metadata.
Constructs a multipart MIME payload from various sources.
Implementation of
RequestHeaderProvider that applies multipart MIME message headers as headers to a HttpURLConnection.This
DataInputParameter is used when you want to source data from the AdaptrisMessage multipart MIME
payload.Handle creation of multipart mime output.
Interface for Adaptris messages that support multiple payloads, referenced by
an ID/key.
The standard implementation of multi-payload messages;
MultiPayloadAdaptrisMessage implementation created by
MultiPayloadMessageFactory.This
MultiPayloadDataInputParameter is used when you want to
source data from the MultiPayloadAdaptrisMessage
payload.This
MultiPayloadDataOutputParameter is used when you want to
insert data into the MultiPayloadAdaptrisMessage payload.Combine multiple standard Adaptris messages into a single
multi-payload Adaptris message.
The multi-payload message factory which returns an implementations of
MultiPayloadAdaptrisMessage.Multi-payload message MIME encoder.
Split a multi-payload Adaptris message into its various payloads
and return a list of standard Adaptris messages.
This
MultiPayloadDataInputParameter is used when you want to
source data from the MultiPayloadAdaptrisMessage
payload.This
MultiPayloadDataOutputParameter is used when you want to
insert data into the MultiPayloadAdaptrisMessage payload.This
MultiPayloadDataInputParameter is used when you want to
source data from the MultiPayloadAdaptrisMessage
payload.This
MultiPayloadDataOutputParameter is used when you want to
insert data into the MultiPayloadAdaptrisMessage payload.Implementation of
Service which provides transformation of XML payloads contained within the new multi-payload message.Implementation of
Workflow that contains multiple producers.MySQL CallableStatement generator.
ParameterApplicator implementation that allows referencing by name.FileFilter accepts files based on the last modified time of the file.Implementation of
FsWorker that uses java.nio to perform put and get operations.Entry point into an adapter from the command line.
No Authentication required.
ProcessedItemCache implementation that doesn't cache.Ignores exception so long as some messages were considered successful based on a metadata key.
Non Blocking start strategy for channels.
A simple non-blocking
ThreadPool implementation for use with Quartz.
File system implementation of
AdaptrisMessageConsumer based on the com.adaptris.fs package.AcknowledgementHandler implementation that does nothing.Base Implementation of a no-op connection.
ExtraFactoryConfiguration implementation that does nothing.HeaderHandler implementation that ignores HTTP headers.Metadata Filter implementation that does no filtering.
ParameterHandler implementation that ignores HTTP parameters.ResponseHeaderProvider implementation that does not add any HTTP response headers.Ignores the result set completely.
A
MessageSplitter implementation that doesn't actually split.No Proxy connection.
Implementation of
RequestHeaderProvider that adds no additional headersImplementation of CallableStatementExecutor will use the
PreparedStatement.execute() method.This is a dummy for marshalling purposes.
Do no sorting at all.
This
Operator simply tests that the given value does not evaluate to null or an empty string.
This
Operator simply tests two values for non-equality.
This
Operator Test whether a specified value doesn't match with any value from the listMakes sure that the content is not in the specified list.
This
Operator simply tests a single value is not null.Check the content and ensure it is null.
Implementation of
Cache that does nothing.No Op connection
Implementation of
ConnectionErrorHandler for use with polling consumers where you do not want an Exception thrown
back to run to re-init the Channel.Returns a null as the content-type.
Interface for handling null parameters.
Default implementation od
CorrelationIdSource which does nothing.Special implementation of
MessageAggregator that does not aggregate messages.
Null implementation of
AdaptrisMessageConsumer.Default null implementation of
MessageErrorDigester.
Null implementation of
AdaptrisMessageProducer.Implementation of the
OutOfStateHandler which does no checks.PartSelector implementation that just selects an arbitrary part.Implementation of NullConverter that simply returns the value passed in.
Null implementation of Processing Exceptions.
Deprecated.
since 4.2.0
Null implementation of
Service.Implementation of NullConverter that throws an UnsupportedOperationException if null is the param.
Implementation of NullConverter that converts null to the empty string ''.
Translates between
javax.jms.ObjectMessages and AdaptrisMessages and vice versa.Implementation of
CacheValueTranslator that retrieves and sets the arbitrary object metadata of a message.HeaderHandler implementation stores HTTP headers as object metadata.XmlTransformParameter implementation that makes object metadata available as transform parametersParameterHandler implementation stores HTTP headers as object metadata.
This implementation of
ValueTranslator will pull an object metadata value from the
AdaptrisMessage to be used as a Jmx operation parameter.Breadth first object tree traversal to find all the matches within a tree.
Timestamp Generator implementation that mimics the default behaviour
available in
AddTimestampMetadataService.FileFilter accepts files based on the last modified time of the file..MaxLoopBehaviour implementation that does nothing.MaxLoopBehaviour implementation that marks a message with metadata that stop processing.MaxLoopBehaviour implementation that throws a ServiceException.
Behaviour for
javax.jms.MessageListener.onMessage is identical for polling and listening implementations.Builds a
ConfigRepository based on an OpenSSH configuration file.
Operators are used with
Condition's in configuration such as ConditionMetadata and ConditionPayload.Oracle CallableStatement generator.
Metadata Filter implementation that returns keys in order defined.
Implementations will be able to test if a
StateManagedComponent is in the expected state.
Abstract implementation of the
OutOfStateHandler.This class represents a single OUT parameter for a Stored Procedure.
This class contains the OUT parameters that a stored procedure will require to be executed.
Core interface for handling encrypted/signed payloads.
Implementation of
FsWorker that uses overwrites the file if it already exists.Implementation of
CommandOutputCapture that overwrites the existing message with the output.Replaces the current payload with a report of the schema violations.
Interface defining how parameters are applied to SQL statements.
Interface for handling HTTP Parameters.
Abstract
ParameterHandler implementation that provides a prefix.This class represents a list of data types that may be used as Stored Procedure parameter IN, OUT and INOUT parameter values.
Basic interface of MBeans that contain child member components.
Basic interface of MBeans that contain child member components.
Select a specific MimeBodyPart from a Mime Multipart.
Select a mime part with a selector and add it to a metadata
JMS Publish-and-subscribe implementation of
AdaptrisMessageConsumer.
PAS implementation of
JmsPollingConsumer.AdaptrisMessageProducer implementation for Topic based JMS.Handles simple encryption and decryption of passwords that may be stored in XML configuration.
Primary interface for handling password encoding and decoding.
Metadata Filter implementation that decodes all values that match the specified key.
Decodes a password using
Password.decode(String)Metadata Filter implementation that encodes all values that match the specified key.
Wraps any exceptions encountered during Password operations.
Interface for
PathBuilder.Replaces the payload with something built from a template and optional metadata keys.
Create a hash of the payload based on the configurable algorithm and stores it as metadata.
MessageWrapper implementation wraps the payload as an InputStream.MessageLogger implementation that that logs unique-id, metadata and payload.
MessageWrapper implementation wraps the payload as an OutputStream.Decrypt part of a message using a configurable path.
Encrypt part of a message using a configurable path.
This
DataInputParameter is used when you want to source data from the AdaptrisMessage payload.This
DataOutputParameter is used when you want to write data to the AdaptrisMessage payload.Takes the entire payload and writes it out to metadata (either object or normal metadata).
This implementation of
ValueTranslator will pull the string payload value from the
AdaptrisMessage to be used as a Jmx operation parameter.A statically configured SSH
ConfigRepository that supports different configuration on a per host basis.Implementation of
ProducerSessionFactory that creates a new session every time is produced.Basic IdGenerator implementation
Concrete
JdbcPooledConnectionImpl that allows you to plug in connection pool
implementations.
Schedules polling for
AdaptrisPollingConsumers.
Partial implementation of
Poller.
Periodically sends a template message to trigger a
WorkflowHow to generate the template that will be sent to the workflow.
Used with
AdvancedJdbcPooledConnection to configure the underlying c3po datasource.Implementation of the Splitter and Aggregator enterprise integration pattern.
Extension to
AdvancedMessageSplitterService that uses a underlying thread and object pool to execute the service on each
split message.A Workflow that pools ServiceCollections.
ExceptionGenerator implementation that generates the exception from metadata.Create a string similar to
SELECT my_stored_procedure(?,?,?)Proxy class for creating ActiveMQPrefetchPolicy objects
XStream version of
AdaptrisMarshaller that supports additional config pre-processors when
unmarshalling.Deprecated.
XML output formatter used by XStream to marshal objects.
Interface for providing the private key password within adapter configuration.
An entry in the
ProcessedItemCache that marks a file that was already processed when using a
NonDeletingFsConsumer.Simple interface to track items that have been processed for
NonDeletingFsConsumerUsed by
MarshallingItemCache to persist ProcessedItem entries to disk.Standard interface for handling errors during processing of a message.
Exception thrown by AdaptrisMessageProducers.Deprecated.
since 4.2.0
Deprecated.
since 4.2.0
Convenience class that only supports produce rather than request.
Wrapper around a
MessageProducer and Session.Handles the creation of a JMS Session and MessageProducer for
JmsProducerImpl instances.Partial implementation of
ProducerSessionFactory
This statistic manager allows you to configure a marshaller and a stand alone producer.
Resolves any properties that are stored using a scheme and decodes using the specified
Decoder implementation.Adds proxy support for connecting to an SFTP server
ProxyNonClosingSqlConnection is a simple wrapper around a SqlConnection
Pseudo Random IdGenerator implementation
JMS Queue implementation of
AdaptrisMessageConsumer
Queue implementation of
JmsPollingConsumerImpl.AdaptrisMessageProducer implementation for Queue based JMS.
Implementation of
Poller which provides cron style scheduled polling based on the Quartz project.
This implementation of the
OutOfStateHandler will simply throw an OutOfStateException every time when a
StateManagedComponent 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).
Implementation of
StatusEvaluator for use with BranchingHttpRequestService.Provides a static content type.
Static implementation of
HttpStatusProvider that allows a numeric status code.Read a file from a specific path into the message payload.
Implementation of
Service that reads metadata from the filesystem.Proxy class for creating RedeliveryPolicy objects
Reformats the date and time stored against a metadata key.
Implementation of
Service that reformats matching metadata.Implementation of
Service that reformats matching metadata keys.Regular Expression based implementation of
MetadataFilterMatch the content against a regular expression.
Performs a Regular Expression based Query on a supplied String.
Service which information from the message payload and sets it as metadata.
This service allows you to configure an regular expression which will be executed on source data, the result of which can be
saved to multiple locations.
Match against a number of configured regular expressions.
Match the metadata value against a regular expression for
MetadataValueBranchingService.FTP implementation which does not have any guarantees as to the atomicity of operations.
Ftp producer implementation.
Metadata Filter implementation that removes all metadata.
Service that retrieves an item from the cache and then removes it
Simplified version of
RemoveFromCacheService that doesn't retrieve the value for
insertion into the message.Remove a mapped diagnostic context via
MDC.remove(String).Interface for handling how find and replace operations occur for
FindAndReplaceService.
Implementation of
Service that adds a performs a simple find and replace on the specified metadata value.Merge implementation that replaces a node derived from an Xpath.
Merge implementation that simply replaces the original.
Special implementation of
MessageAggregator that replaces the original payload with the first aggregated message.Encapsulates the FTP server reply
Supports reporting of what's in the retry store.
Interface to generate http request headers.
Interface for providing a HTTP method.
Valid methods as defined by RFC2616 & RFC5789 (PATCH method).
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 of
Workflow to handle synchronous replies.XmlTransformParameter implementation that filters resolvable
expressions making matches available as String parameters.Simple resolver that caches URLs that it has previously encountered.
Interface used to delegate authentication for network resources.
Simply allows access to the protected
Authenticator methods.Allows different HTTP implementations to offer different matching mechanisms for authentication purposes.
Interface to handle the headers from the HTTP response.
Interface to generate http response headers.
Concrete implementation of
ResponseHeaderHandler which adds all the HTTP headers from the
response as metadata to the AdaptrisMessage.Concrete implementation of
ResponseHeaderHandler which adds all the HTTP headers from the
response as object metadata to the AdaptrisMessage.Deprecated.
since 3.10.2
Restart strategy for
StatelessServiceWrapper.Interface used to format output from a
JdbcDataQueryServiceBase implementation for converting a ResultSet into an AdaptrisMessage.
Service that looks up an object from the cache using the configured
CacheEntryEvaluator instances.FailedMessageRetrier implementation that retries upon demand.
This service wrapper, will attempt to run the wrapped service and should the service fail with
a
ServiceException we will attempt to retry the service according to your configuration.MessageErrorHandler implementation that allows automatic retries for a problem message.
Abstract MessageErrorHandler implementation that allows automatic retries for
a problem message.
Service which obtains messages from the retry store that meet the appropriate
criteria and retries them.
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.
Partial implementation of behaviour common to retry services.
Delete a message from the configured retry store.
List messages in the configured retry store.
Write a message for retry with
RetryFromJetty.Abstract class representing a service that checks X509Certificates against an external source for revocations.
RootProcessingExceptionHandler which allows you to register a Digester for aggregating information about all the errors that have
occurred.
Base interface for components that have statistics and similar information that need exposing during normal runtime.
Overrides standard
GuidGenerator behaviour using GuidGenerator.safeUUID() for IdGenerator.create(Object)
instead.Resolver implementation that resolves and escapes XML content.
Object model representation of all an individual schema violation for rendering purposes.
Object model representation of all the schema violations for rendering purposes.
A security constraint which allows you to place restrictions on a number of paths.
Interface for handling encryption, signing and verification requests.
Factory for creating output specific security services.
Security Utilities.
PartSelector implementation that selects by the Content-Id header of the MimeBodyPart.PartSelector implementation that parses a specific header examining the value to see if it matches the configured regular
expression.Selects a MimeBodyPart based on its position within the Multipart.
ParameterApplicator implementation that applies parameters sequentially.The SerializableAdaptrisMessage simply represents an AdaptrisMessage that can be serialized.
Implementations of
Service apply aribtrary functionality to
AdaptrisMessages.
Defines behaviour common to collections of
Services.
Behaviour common to
ServiceCollections.Exception thrown by Services.Default
ServiceErrorHandler that captures exceptions thrown and rethrows the first
exception when requested.Interface for use with
DynamicServiceExecutor.Extract the service to execute from a cache
Extract the service to execute from a database
Extract the service to execute based on the configured
DataInputParameterExtract the service to execute based on the configured URL.
Implementation of default / common behaviour for
Services.Implementation of
ServiceCollection with an ordered list of Services.A marker interface for Services that wrap other services.
Wrapper class around a servlet for jetty.
SftpAuthenticationProvider that wraps other SftpAuthenticationProvider instances.Provides SSH File Transfer Protocol implementation of FileTransferClient
Exception wrapping any specific SFTP Exception.
SftpAuthenticationProvider using keys.SftpAuthenticationProvider using a password.Strategy for handling connection lifecycle within a
SharedComponentList.A common store for components.
A connection instance that references a connection made available via
SharedComponentList.
A Service instance that references a Service made available via
SharedComponentList.Allows you to short cut
JettyPoolingWorkflowInterceptor behaviour in a PoolingWorkflow.Short Statement Parameter.
Runnable implementation to be used as a Shutdown Hook.
Wraps any exception during signing.
Perform Signing.
A simple bean util class that allows us to call setters that have a
primitive param.Entry point into an adapter from the commandline.
Simply convert using the default platform encoding.
SimpleDataStore.
ExceptionReportGenerator implementation that inserts the entire stack trace of the exception as the configured element.ExtraFactoryConfiguration implementation using reflection to configure fields on the ConnectionFactory.Variation of PlainIdGenerator which uses the hostname instead of a random sequence of bytes.
Compare the content against some specified list.
Implementation of NamespaceContext that is based on a number of key value pairs.
Serializes a
Notification into an simple text message.Implement of
Output that simply wraps a byte arrayTakes the first result set, and the specified column (optional) and makes that the payload.
Class which splits batched files in a singel
AdaptrisMessage into individual ones based on a regular expression
match.Simple sequence number generator that uses a file to store the next sequence number.
The behaviour of the sequence number generator when the number exceeds that specified by the number format.
Sort the list of files by their size.
Branching
Service which sets the unique ID of the next Service to apply based on the size of the
AdaptrisMessage.MessageSplitter implementation that splits by size.Sort the list of files by their size in reverse order
FileFilter accepts files based on whether the size of the file is greater than the specified value.FileFilter accepts files based on whether the size of the file is greater or equal to the specified value.FileFilter accepts files based on whether the size of the file is less than the specified value.FileFilter accepts files based on whether the size of the file is less than or equal to the specified value..An OutputStream that flushes out to a slf4j logger.
Interceptor that emits a
Notification if a message has exceeded the specified threshold
for processing within a workflow.
Implementation of
MessageSplitter which allows a single AdaptrisMessage that contains a metadata key
that is considered to contain multiple elements to be split.Translate the ResultSet contents into some number of XML messages.
Wrapper class for a
AdaptrisMessageConsumer and a AdaptrisConnection.
Wrapper for a
AdaptrisConnection and a AdaptrisMessageProducer for convenience.StandaloneProducer extension that allows request reply functionality within a service
Event containing
Adapter start-up information..Default
HttpProducer implementation that uses HttpURLConnection available in a
standard java runtime.VendorImplementation that gets a ConnectionFactory from the configured JNDI Store.Record any error'd adaptris messages and make these available through JMX.
Exposes all the records handled by
StandardMessageErrorDigester and exposes them via JMX.ProcessingExceptionHandler implementation that contains a single service to apply when a message fails.
Implementation of
AdaptrisMessageProducer writes to the HttpServletResponse object metadata
provided by the Jetty engine.SFTP Connection class that connects via a configurable
SftpAuthenticationProvider.Implementation of
FsWorker that uses standard java.io to perform put and get operations.
Standard implementation of
Workflow.
Represents started
StateManagedComponents and implements permitted transitions.Used with
MetadataComparisonService.Used with
MetadataComparisonService.
Stateless service wrapper, wraps any configured service and allows you to set a strategy on when to restart the service before
allowing it to execute.
Specifies methods for components which manage state transitions.
Extension to
StateManagedComponent used for fine grained state transitions.Encapsulates a parameter that is used by the JdbcDataCaptureService.
Defines all the static query types supported by a Statement Parameter.
Implementation of
CacheValueTranslator that could be useful for resolving the key when checking or retrieving from a
cache.Returns a fixed value for this command line argument.
Implementation of AbstractJdbcSequenceNumberService where the identity is statically configured.
Provides a static template for
PollingTrigger.
This marshaller is designed for
InterceptorStatistic and is used exclusively with the ProducingStatisticManager.For use with
BranchingHttpRequestService.Abstract implementation of
StatusEvaluator.
Represents stopped
StateManagedComponents and implements permitted transitions.This service will cause the message to not be processed any further and will also request that the Workflows producer not be
called.
Service which stores unacknowledged messages for future retry.
Service implementation which stores the value held against a configured metadata key in a persistent list, generally
for use by CheckMetadataValueService.Some utility methods associated with input streams.
Column Translator implementation for handling string types
MetadataElement key and value set as property of javax.jms.Message
using setStringProperty(String key, String value).XmlTransformParameter implementation that filters metadata making matches available as String parameters.Implementation of
CacheValueTranslator that retrieves / sets the payload of the message.
This
DataInputParameter is used when you want to source data from the AdaptrisMessage payload.This
DataOutputParameter is used when you want to write data to the AdaptrisMessage payload.Partial implementation of MessageSplitter that splits Strings based payloads.
String Statement Parameter.This class will encode a metadata value into its equivalent hex encoded metadata value(s) using the specified character
encoding
The StxTransformerFactory is responsible for creating the
Transformer.Base implementation for converting a ResultSet into an AdaptrisMessage.
Represents how column names are formatted.
A switch statement in configuration.
Switch the message payload from one payload to another.
Branching Service which determines the next Service to apply according to
SyntaxIdentifiers, as used by
SyntaxRoutingService.Interface used by SyntaxRoutingService.
Extracts data from an AdaptrisMessage and stores it against metadata.
Service that runs the specified system executable with the provided arguments, optionally
capturing the output.
Set additional system properties from properties stored in the bootstrap.properties file.
Translates between
AdaptrisMessage and javax.jms.TextMessages.Workflow that executes services in the current thread.
The throttling interceptor will attempt to limit the number of messages that are processed by an adapter over a given time slot.
Throws an exception based on a configurable set of criteria.
Column Translator implementation for handling time types
Implementation of
ProducerSessionFactory that creates a new session/producer based an inactivity timer.
This RestartStrategy monitors the last usage of the service and if the last usage
passes an inactivity period, then this strategy will return true upon requiresRestart().
Class that describes a time unit for use within the adapter.
Configure the behaviour that should occur when the max mait time is exceeded
A Timeslice used by
ThrottlingInterceptor.Abstract base for implementation of
TimeSliceCacheProviderinterface for caching timeslices.
The default implementation that handles the current time slice persistence.
A singleton that will manage all caches and for each cache will maintain the current time slice.
Column Translator implementation for handling timestamp types
A
Timestamp extension to StatementParameter.Time extension to StatementParameter.Represents the FTP Transfer type.
Extension of the standard FsConsumer that traverses all subdirectories for files that match the filter expression.
Trim a metadata values of leading and trailing whitespace.
MessageLogger & MetadataLogger implementation that that logs unique-id
and metadata but truncates metadata at the configured length.
Abstract class preserving backwards config compatibility from
StatementParameter.Class UnbufferedLineInputStream.
Workaround for a Sun JVM bug whereby it does not handle streams that have a UTF-8 BOM.
This is the class that handles almost everything required for startup.
Iterator implementation.
Wrapper class around the
URLConnection.getHeaderFields() for insertion into object metadata.URLDecoder.decode(String, String) on metadata values.URLEncoder.encode(String, String) on metadata values.A Simple URL parser, that can parse any given URL into it's constituent parts.
Partial implementation with common or default behaviour.
Implementation of MetadataValueMatcher for
MetadataValueBranchingService which returns the serviceKey as identifier of
the next Service to apply.Changes the character encoding associated with a message.
Service that removes UTF8 byte order marks that may be present.
Verify that a message has all the required metadata keys set.
Provides some utilities for javax validation style checking.
A Stage within the validation.
Implementations of this interface can be used to supply parameters to Jmx operation calls.
Constants controlling behaviour when integrating against a version control system.
Abstract factory that insulates vendor-specific code from the rest of the
com.adaptris.core.jms package.
Partial implementation with common or default behaviour.
Wraps any exception during verify of signatures.
A simple service that allows you to verify that the message contents and/or metadata passes muster.
Basic Version control System interface.
Class to report module version numbers.
Connect via a HTTP proxy
Adds proxy support for connecting to an SFTP server
Connect via a SOCKS4 proxy
Connect via a SOCKS5 proxy
Uses
SchemaViolations to render schema violations into something meaningful.Uses
SchemaViolations and adds it as standard metadata.Uses
SchemaViolations and adds it as object metadata.
This implementation of the
OutOfStateHandler will simply wait on the current Thread for the StateManagedComponent
to be in the correct/expected state.
Implementation of
Service for testing which sleeps for a configurable period.Reports on warnings from various ConfigurationChecks based on a system property.
Workflows link an AdaptrisMessageConsumer, a
ServceCollection and an AdaptrisMessageProducer.Partial implementation of
Workflow.Interface for intercepting messages as they enter and exit a workflow.
Abstract WorkflowInterceptor implementation.
Strategy for handling workflow lifecycle within a
WorkflowList.
Container for a collection of
Workflows.Base implementation of
WorkflowManagerMBean.Interface specifying controls for a single workflow.
Strategy for starting workflows that retries a workflow init or start a number of times.
Strategy for starting workflows that retries a workflow init or start a number of times.
A Workflow that has a object pool of ServiceCollections
Implementation of
Service that writes metadata to the filesystem.Used with
XmlValidationService to validate that a message is in fact XML.MessageAggregator implementation that creates single XML using each message that needs to be joined up.ExceptionReportGenerator implementation that renders the exception as XML.Helper class for handling XML within an AdaptrisMessage
Serializes a
Notification into an XML message.Translate the ResultSet contents into an XML Payload.
Base class for translating ResultSet contents into an XML Payload.
ExceptionReportGenerator implementation that renders the exception as XML including the
stacktraceUsed with
XmlValidationService to validate an XML message against various rules.Responsible for applying transforms.
Interface for handling parameters passed into an XML transform.
XmlTransformParameter implementation allows multiple nested implementations.
Implementation of
Service which provides transformation of XML payloads.Class which provides convenience methods for various aspects of XML usage.
Service which validates an input XML document.
Wrapper around
XPath/Extracts and inserts values from message payload using defined Xpaths
String.Implementation of
CacheValueTranslator that retrieves a value from the supplied AdaptrisMessage using an XPath.
Implementation of
MessageSplitter which creates multiple instances of the same XML document based on an XPath.
Implementation of
MessageSplitter which splits an XML document based on an XPath.Base interface for generating metadata from an xpath.
Store values extracted from message payload using
XpathQuery as metadata.SyntaxIdentifier implementation using XPATH.
Store values extracted from message payload using
XpathQuery as object metadata.Interface for creating metadata from an Xpath.
Interface for creating string metadata from an Xpath.
Abstract base class for Metadata Xpath Queries.
This service allows you to configure an xpath expression which will be executed on source xml, the result of which can be saved
to multiple locations.
SyntaxIdentifier implementation using XPATH.
The XsltTransformerFactory is responsible for creating the
Transformer.Implementation of the
AdapterConfigManager interface for XStream.JSON implementation of
AdaptrisMarshaller using XStream.XStream version of
AdaptrisMarshallerAbstract XStream version of
AdaptrisMarshallerGeneral Utilities used by various XStream related classes
MessageAggregator implementation that creates single zip using each message as a file in the zip.Message factory that creates file backed messages from ZIP files.
ThrowExceptionServiceinstead which will give you a better exception message.