Package org.frankframework.core

Class Adapter

java.lang.Object
org.frankframework.core.Adapter
All Implemented Interfaces:
IConfigurable, IConfigurationAware, IManagable, INamedObject, IScopeProvider, HasStatistics, org.springframework.beans.factory.Aware, org.springframework.beans.factory.NamedBean, org.springframework.context.ApplicationContextAware
@Category("Basic") public class Adapter extends Object implements IManagable, HasStatistics, org.springframework.beans.factory.NamedBean
The Adapter is the central manager in the framework. It has knowledge of both Receivers as well as the PipeLine and statistics. The Adapter is the class that is responsible for configuring, initializing and accessing/activating Receivers, Pipelines, statistics etc.
An Adapter receives a specific type of messages and processes them. It has Receivers that receive the messages and a PipeLine that transforms the incoming messages. Each adapter is part of a Configuration.
If an adapter can receive its messages through multiple channels (e.g. RESTful HTTP requests, incoming files, etc), each channel appears as a separate Receiver nested in the adapter. Each Receiver is also responsible for dealing with the result of its received messages; the result is the output of the PipeLine. The result consists of the transformed message and a state. The Frank!Framework distinguishes between exit states SUCCESS and ERROR. There is also a state REJECTED for messages that are not accepted by the Frank!Framework and that are not processed by the PipeLine. If the exit state is ERROR, the result message may not be usable by the calling system. This can be fixed by adding an errorMessageFormatter that formats the result message if the state is ERROR.

Adapters gather statistics about the messages they process.
Adapters can process messages in parallel. They are thread-safe.
Author:
Johan Verrips

  • Field Details

  • Constructor Details

    • Adapter

      public Adapter()

  • Method Details

    • getAdapter

      public Adapter getAdapter()
      Specified by:
      getAdapter in interface HasStatistics

    • configure

      public void configure() throws ConfigurationException
      Instruct the adapter to configure itself. The adapter will call the pipeline to configure itself, the pipeline will call the individual pipes to configure themselves.
      Specified by:
      configure in interface IConfigurable
      Throws:
      ConfigurationException
      See Also:

    • configureReceiver

      public void configureReceiver(Receiver<?> receiver) throws ConfigurationException
      Throws:
      ConfigurationException

    • configurationSucceeded

      public boolean configurationSucceeded()

    • warn

      protected void warn(String msg)
      send a warning to the log and to the messagekeeper of the adapter

    • addErrorMessageToMessageKeeper

      protected void addErrorMessageToMessageKeeper(String msg, Throwable t)
      send an error to the log and to the messagekeeper of the adapter

    • setLastExitState

      public void setLastExitState(String pipeName, long lastExitStateDate, String lastExitState)

    • getLastExitIsTimeoutDate

      public long getLastExitIsTimeoutDate(String pipeName)

    • formatErrorMessage

      public Message formatErrorMessage(String errorMessage, Throwable t, Message originalMessage, String messageID, INamedObject objectInError, long receivedTime)

    • getLastMessageDate

      @JmxAttribute(description="The date/time of the last processed message") public String getLastMessageDate()
      retrieve the date and time of the last message.

    • getLastMessageDateDate

      public Date getLastMessageDateDate()

    • getMessageKeeper

      public MessageKeeper getMessageKeeper()
      the MessageKeeper is for keeping the last messageKeeperSize messages available, for instance for displaying it in the webcontrol
      See Also:

    • getNumOfMessagesInError

      @JmxAttribute(description="# Messages in Error") public double getNumOfMessagesInError()
      The number of messages for which processing ended unsuccessfully.

    • getNumOfMessagesInProcess

      @JmxAttribute(description="# Messages in process") public int getNumOfMessagesInProcess()

    • getNumOfMessagesStartProcessingByHour

      public long[] getNumOfMessagesStartProcessingByHour()

    • getNumOfMessagesProcessed

      @JmxAttribute(description="# Messages Processed") public double getNumOfMessagesProcessed()
      Total of messages processed
      Returns:
      long total messages processed

    • getReceiverByName

      public Receiver<?> getReceiverByName(String receiverName)

    • getReceivers

      public Iterable<Receiver<?>> getReceivers()

    • getRunState

      public RunState getRunState()
      Description copied from interface: IManagable
      returns the runstate of the object. Possible values are defined by RunState.
      Specified by:
      getRunState in interface IManagable

    • getRunStateAsString

      @JmxAttribute(description="RunState") public String getRunStateAsString()

    • getStatsUpSince

      @JmxAttribute(description="Up Since") public String getStatsUpSince()
      return the date and time since active Creation date: (19-02-2003 12:16:53)
      Returns:
      String Date

    • getStatsUpSinceDate

      public Date getStatsUpSinceDate()

    • logToMessageLogWithMessageContentsOrSize

      public void logToMessageLogWithMessageContentsOrSize(org.apache.logging.log4j.Level level, String logMessage, String dataPrefix, Message data)

    • processMessageDirect

      public PipeLineResult processMessageDirect(String messageId, Message message, PipeLineSession pipeLineSession)
      Direct call to the Adapter PipeLine, foregoing any listeners and receivers. This method does an amount of setup which is otherwise done by the Receiver.
      This method does not throw any exceptions, and will always return a PipeLineResult. If an error occurred, the error information is in the PipeLineResult.
      Parameters:
      messageId - ID of the message
      message - Message to be processed
      pipeLineSession - PipeLineSession session in which message is to be processed
      Returns:
      The PipeLineResult from processing the message, or indicating what error occurred.

    • processMessageWithExceptions

      public PipeLineResult processMessageWithExceptions(String messageId, Message message, PipeLineSession pipeLineSession) throws ListenerException
      This method does the real processing of messages by the adapter. This method is to be called either from the Receiver, or from processMessageDirect(String, Message, PipeLineSession).
      NB: This method expects most setup to already have been done by the caller! LoggingContext and masking of sensitive information is among things that should be set up by the caller.
      This method will return a PipeLineResult with results of the processing. This might indicate an error if the message could not be processed successfully. If there was an exception from the PipeLine, a ListenerException might be thrown.
      Parameters:
      messageId - ID of the message
      message - Message to be processed
      pipeLineSession - PipeLineSession in which the message is to be processed
      Returns:
      PipeLineResult with result from processing the message in the PipeLine.
      Throws:
      ListenerException - If there was an exception, throws a ListenerException.

    • registerReceiver

      public void registerReceiver(Receiver<?> receiver)
      Receives incoming messages. If an adapter can receive messages through multiple channels, then add a receiver for each channel.

    • setErrorMessageFormatter

      public void setErrorMessageFormatter(IErrorMessageFormatter errorMessageFormatter)
      Formatter for errors that can occur in this adapter.

    • setPipeLine

      public void setPipeLine(PipeLine pipeline)
      The PipeLine.

    • getPipeLine

      public PipeLine getPipeLine()

    • setConfiguration

      public void setConfiguration(Configuration configuration)

    • startRunning

      public void startRunning()
      Start the adapter. The thread-name will be set to the adapter's name. The run method, called by t.start(), will call the startRunning method of the IReceiver. The Adapter will be a new thread, as this interface extends the Runnable interface. The actual starting is done in the run method.
      Specified by:
      startRunning in interface IManagable
      See Also:

    • stopRunning

      public void stopRunning()
      Stop the Adapter and close all elements like receivers, Pipeline, pipes etc. The adapter will call the IReceiver to stopListening

      Also the PipeLine.close() method will be called, closing all registered pipes.

      Specified by:
      stopRunning in interface IManagable
      See Also:

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • waitForNoMessagesInProcess

      public void waitForNoMessagesInProcess() throws InterruptedException
      Throws:
      InterruptedException

    • getBeanName

      public String getBeanName()
      Specified by:
      getBeanName in interface org.springframework.beans.factory.NamedBean

    • setName

      public void setName(String name)
      name of the adapter
      Specified by:
      setName in interface INamedObject

    • getName

      @JmxAttribute(description="Name of the Adapter") public String getName()
      Specified by:
      getName in interface IConfigurationAware
      Specified by:
      getName in interface INamedObject

    • setDescription

      public void setDescription(String description)
      some functional description of the Adapter

    • setAutoStart

      public void setAutoStart(boolean autoStart)
      AutoStart indicates that the adapter should be started when the configuration is started.
      Default value
      true

    • setReplaceNullMessage

      public void setReplaceNullMessage(boolean b)
      If true a null message is replaced by an empty message
      Default value
      false

    • setMessageKeeperSize

      public void setMessageKeeperSize(int size)
      number of message displayed in ibisconsole
      Default value
      10

    • setMsgLogLevel

      public void setMsgLogLevel(org.frankframework.core.Adapter.MessageLogLevel level)
      Defines behaviour for logging messages. Configuration is done in the MSG appender in log4j4ibis.properties.
      Default value
      INFO, unless overridden by property msg.log.level.default

    • setRequestReplyLogging

      @Deprecated public void setRequestReplyLogging(boolean requestReplyLogging)
      Deprecated.

    • setMsgLogHidden

      public void setMsgLogHidden(boolean b)
      If set to true, the length of the message is shown in the msg log instead of the content of the message
      Default value
      false

    • getApplicationContext

      public org.springframework.context.ApplicationContext getApplicationContext()
      Specified by:
      getApplicationContext in interface IConfigurationAware

    • setApplicationContext

      public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
      Specified by:
      setApplicationContext in interface org.springframework.context.ApplicationContextAware

    • getConfigurationClassLoader

      public ClassLoader getConfigurationClassLoader()
      Description copied from interface: IScopeProvider
      This ClassLoader is set upon creation of the object, used to retrieve resources configured by the Ibis application.
      Specified by:
      getConfigurationClassLoader in interface IScopeProvider
      Returns:
      returns the ClassLoader created by the ClassLoaderManager.

    • getDescription

      public String getDescription()

    • isAutoStart

      public boolean isAutoStart()

    • isReplaceNullMessage

      public boolean isReplaceNullMessage()

    • getMessageKeeperSize

      public int getMessageKeeperSize()

    • isMsgLogHidden

      public boolean isMsgLogHidden()

    • setTargetDesignDocument

      public void setTargetDesignDocument(String targetDesignDocument)

    • getTargetDesignDocument

      public String getTargetDesignDocument()

    • getConfiguration

      public Configuration getConfiguration()

    • getLastMessageProcessingState

      public String getLastMessageProcessingState()

    • setConfigurationMetrics

      public void setConfigurationMetrics(MetricsInitializer configurationMetrics)

    • isConfigurationSucceeded

      public boolean isConfigurationSucceeded()

    • getTaskExecutor

      public org.springframework.core.task.TaskExecutor getTaskExecutor()

    • setTaskExecutor

      public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)

    • getComposedHideRegex

      public String getComposedHideRegex()

    • getComposedHideRegexPattern

      public Pattern getComposedHideRegexPattern()