Package org.frankframework.senders

Class IbisLocalSender

java.lang.Object
org.frankframework.senders.AbstractSender
org.frankframework.senders.AbstractSenderWithParameters
org.frankframework.senders.IbisLocalSender
All Implemented Interfaces:
ConfigurationAware, FrankElement, HasApplicationContext, HasName, HasPhysicalDestination, IConfigurable, IScopeProvider, ISender, ISenderWithParameters, IWithParameters, NameAware, IThreadCreator, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle
Direct Known Subclasses:
SendMessageJob.SendMessageJobSender
@DestinationType(ADAPTER) @Forward(name="*", description="Exit code") @Category(BASIC) public class IbisLocalSender extends AbstractSenderWithParameters implements HasPhysicalDestination, IThreadCreator, ConfigurationAware
Posts a message to another Frank!Framework-adapter in the same Frank!Framework instance. If the callee exits with an <exit> that has state PipeLine.ExitState.ERROR, an error is considered to happen in the caller which means that the exception forward is followed if it is present.

The IbisLocalSender is now considered to be legacy. The new way to call another adapter from your own adapter is by using the FrankSender.

Returns exit.code as forward name to SenderPipe provided that exit.code can be parsed as integer. For example, if the called adapter has an exit state with code 2, then the SenderPipe supports a forward with name 2 that is followed when the called adapter exits with the mentioned exit. This does not work if the code is for example c2.

An IbisLocalSender makes a call to a Receiver with either a WebServiceListener or a JavaListener.

Configuration of the Adapter to be called

A call to another Adapter in the same Frank!Framework instance is preferably made using the combination of an IbisLocalSender and a JavaListener. If, however, a Receiver with a WebServiceListener is already present, that can be used in some cases, too.

configuring IbisLocalSender and JavaListener

  • Define a SenderPipe with an IbisLocalSender
  • Set the attribute javaListener to yourServiceName
  • Do not set the attribute serviceName
In the Adapter to be called:
  • Define a Receiver with a JavaListener
  • Set the attribute name to yourServiceName
  • Do not set the attribute serviceName, except if the service is to be called also from applications other than this Frank!Framework-instance

configuring IbisLocalSender and WebServiceListener

  • Define a SenderPipe with an IbisLocalSender
  • Set the attribute serviceName to yourIbisWebServiceName
  • Do not set the attribute javaListener
In the Adapter to be called:
  • Define a Receiver with a WebServiceListener
  • Set the attribute name to yourIbisWebServiceName
Since:
4.2
Author:
Gerrit van Brakel
Parameters
All parameters are copied to the PipeLineSession of the service called.

  • Field Details

  • Constructor Details

    • IbisLocalSender

      public IbisLocalSender()

  • Method Details

    • configure

      public void configure() throws ConfigurationException
      Description copied from interface: IConfigurable
      Configure this component.

      configure() is called once at startup of the framework in the configure method of the owner of this IConfigurable. Purpose of this method is to check whether the static configuration of the object is correct. As much as possible class-instantiating should take place in the configure(), to improve performance.

      In the case of a container, this will propagate the configure signal to all components that apply.

      Specified by:
      configure in interface IConfigurable
      Overrides:
      configure in class AbstractSenderWithParameters
      Throws:
      ConfigurationException - in case it was not able to configure the component.

    • start

      public void start()
      Description copied from interface: ISender
      This method will be called to start the sender. After this method is called the sendMessage method may be called. Purpose of this method is to reduce creating connections to databases etc. in the sendMessage() method.
      Specified by:
      start in interface ISender
      Specified by:
      start in interface org.springframework.context.Lifecycle
      Overrides:
      start in class AbstractSender

    • getPhysicalDestinationName

      public String getPhysicalDestinationName()
      Specified by:
      getPhysicalDestinationName in interface HasPhysicalDestination

    • sendMessage

      @Nonnull public SenderResult sendMessage(@Nonnull Message message, @Nonnull PipeLineSession session) throws SenderException, TimeoutException
      Description copied from interface: ISender
      Send a message to some destination (as configured in the Sender object). This method may only be called after the configure() method is called.

      The following table shows the difference between synchronous and a-synchronous senders:

       synchronousa-synchronous
      ISender.isSynchronous() returnstruefalse
      return value of sendMessage() isthe reply-messagethe messageId of the message sent
      the correlationID specified with sendMessage()may be ignoredis sent with the message
      a {link TimeOutException}may be thrown if a timeout occurs waiting for a replyshould not be expected

      Multiple objects may try to call this method at the same time, from different threads. Implementations of this method should therefore be thread-safe, or synchronized.

      Specified by:
      sendMessage in interface ISender
      Throws:
      SenderException
      TimeoutException

    • setServiceName

      @Deprecated(forRemoval=true, since="7.9.0") public void setServiceName(String serviceName)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Name of the WebServiceListener that should be called

    • setJavaListener

      public void setJavaListener(String string)
      Name of the JavaListener that should be called (will be ignored when javaListenerSessionKey is set)

    • setJavaListenerSessionKey

      public void setJavaListenerSessionKey(String string)
      Name of the sessionKey which holds the name of the JavaListener that should be called

    • setReturnedSessionKeys

      public void setReturnedSessionKeys(String string)
      Comma separated list of keys of session variables that will be returned to caller, for correct results as well as for erroneous results. The set of available sessionKeys to be returned might be limited by the returnedSessionKeys attribute of the corresponding JavaListener.

    • setSynchronous

      public void setSynchronous(boolean b)
      If false, the call is made asynchronously. This implies isolated=true
      Default value
      true

    • setIsolated

      public void setIsolated(boolean b)
      If true, the call is made in a separate thread, possibly using separate transaction
      Default value
      false

    • setCheckDependency

      public void setCheckDependency(boolean b)
      If true, the sender waits upon open until the called JavaListener is opened
      Default value
      true

    • setDependencyTimeOut

      public void setDependencyTimeOut(int i)
      Maximum time (in seconds) the sender waits for the listener to start. A value of -1 indicates to wait indefinitely
      Default value
      60

    • setThrowJavaListenerNotFoundException

      public void setThrowJavaListenerNotFoundException(boolean b)
      If false, the xml-string "<error>could not find JavaListener [...]</error>" is returned instead of throwing a senderexception
      Default value
      true