nl.nn.adapterframework.receivers

Class JavaListener

java.lang.Object

nl.nn.adapterframework.receivers.JavaListener

All Implemented Interfaces:

HasPhysicalDestination, IConfigurable, IConfigurationAware, IListener<String>, INamedObject, IPushingListener<String>, IScopeProvider, nl.nn.adapterframework.dispatcher.RequestProcessor, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

@Category(value="Basic")
public class JavaListener
extends Object
implements IPushingListener<String>, nl.nn.adapterframework.dispatcher.RequestProcessor, HasPhysicalDestination

Use this listener to receive messages from other adapters or a scheduler within the same Frank-application or from other components residing in the same JVM. JavaListeners can receive calls made via de ibis-servicedispatcher, which should be located on the JVM classpath to receive calls from other components in the JVM. If you want to call an adapter in the same Frank-application, consider using the IbisLocalSender.
To understand what this listener does exactly, please remember that the Frank!Framework is a Java application. The JavaListener listens to Java method calls. You can issue Java method calls using a IbisJavaSender (external call) or IbisLocalSender (internal call). For more information see the ibis-servicedispatcher project.

Author:

Gerrit van Brakel

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
JavaListener()

Method Summary

Modifier and Type	Method and Description
void	afterMessageProcessed(PipeLineResult processResult, Object rawMessage, Map<String,Object> context) Called to perform actions (like committing or sending a reply) after a message has been processed by the Pipeline.
void	close() Close all resources used for listening.
void	configure() configure() is called once at startup of the framework in the configure() method of the owner of this listener.
Message	extractMessage(String rawMessage, Map<String,Object> context) Extracts string from message obtained from IPullingListener.getRawMessage(Map).
String	getIdFromRawMessage(String rawMessage, Map<String,Object> context) Extracts ID-string from message obtained from IPullingListener.getRawMessage(Map).
static JavaListener	getListener(String name) Returns JavaListener registered under the given name
static Set<String>	getListenerNames()
String	getPhysicalDestinationName()
void	open() Prepares the listener for receiving messages.
String	processRequest(String correlationId, String rawMessage, HashMap context)
void	setExceptionListener(IbisExceptionListener listener) Set a (single) listener that will be notified of any exceptions.
void	setHttpWsdl(boolean httpWsdl) If true, the WSDL of the service provided by this listener will available for download
void	setIsolated(boolean b) Deprecated.
void	setLocal(String name) Deprecated.
void	setName(String name) Internal name of the listener, as known to the adapter.
void	setReturnedSessionKeys(String string) Comma separated list of keys of session variables that should be returned to caller, for correct results as well as for erronous results.
void	setServiceName(String jndiName) External Name of the listener.
void	setSynchronous(boolean b) Deprecated.
void	setThrowException(boolean throwException) Should the JavaListener throw a ListenerException when it occurs or return an error message

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface nl.nn.adapterframework.core.IPushingListener

setHandler

Methods inherited from interface nl.nn.adapterframework.core.INamedObject

getName

Methods inherited from interface nl.nn.adapterframework.core.IConfigurationAware

getApplicationContext, getName

Methods inherited from interface nl.nn.adapterframework.core.IScopeProvider

getConfigurationClassLoader

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface nl.nn.adapterframework.core.HasPhysicalDestination

getDomain

Field Detail

log

protected org.apache.logging.log4j.Logger log

Constructor Detail

JavaListener

public JavaListener()

Method Detail

configure

public void configure()
               throws ConfigurationException

Description copied from interface: IListener

configure() is called once at startup of the framework in the configure() method of the owner of this listener. Purpose of this method is to reduce creating connections to databases etc. in the IPullingListener.getRawMessage(Map) method. As much as possible class-instantiating should take place in the configure() or open() method, to improve performance.

Specified by:

configure in interface IConfigurable

Specified by:

configure in interface IListener<String>

Throws:

ConfigurationException

open

public void open()
          throws ListenerException

Description copied from interface: IListener

Prepares the listener for receiving messages. open() is called once each time the listener is started.

Specified by:

open in interface IListener<String>

Throws:

ListenerException

close

public void close()
           throws ListenerException

Description copied from interface: IListener

Close all resources used for listening. Called once once each time the listener is stopped.

Specified by:

close in interface IListener<String>

Throws:

ListenerException

processRequest

public String processRequest(String correlationId,
                             String rawMessage,
                             HashMap context)
                      throws ListenerException

Specified by:

processRequest in interface nl.nn.adapterframework.dispatcher.RequestProcessor

Throws:

ListenerException

getListener

public static JavaListener getListener(String name)

Returns JavaListener registered under the given name

getListenerNames

public static Set<String> getListenerNames()

setExceptionListener

public void setExceptionListener(IbisExceptionListener listener)

Description copied from interface: IPushingListener

Set a (single) listener that will be notified of any exceptions. The listener should use this listener to notify the receiver of any exception that occurs outside the processing of a message.

Specified by:

setExceptionListener in interface IPushingListener<String>

afterMessageProcessed

public void afterMessageProcessed(PipeLineResult processResult,
                                  Object rawMessage,
                                  Map<String,Object> context)
                           throws ListenerException

Description copied from interface: IListener

Called to perform actions (like committing or sending a reply) after a message has been processed by the Pipeline.

Specified by:

afterMessageProcessed in interface IListener<String>

Throws:

ListenerException

getIdFromRawMessage

public String getIdFromRawMessage(String rawMessage,
                                  Map<String,Object> context)
                           throws ListenerException

Description copied from interface: IListener

Extracts ID-string from message obtained from IPullingListener.getRawMessage(Map). May also extract other parameters from the message and put those in the context.
Common entries in the session context are:

• id: messageId, identifies the current transportation of the message
• cid: correlationId, identifies the processing of the message in the global chain
• tsReceived: timestamp of reception of the message, formatted as yyyy-MM-dd HH:mm:ss.SSS
• tsSent: timestamp of sending of the message (only when available), formatted as yyyy-MM-dd HH:mm:ss.SSS

Specified by:

getIdFromRawMessage in interface IListener<String>

Returns:

Correlation ID string.

Throws:

ListenerException

extractMessage

public Message extractMessage(String rawMessage,
                              Map<String,Object> context)
                       throws ListenerException

Description copied from interface: IListener

Extracts string from message obtained from IPullingListener.getRawMessage(Map). May also extract other parameters from the message and put those in the threadContext.

Specified by:

extractMessage in interface IListener<String>

Returns:

input message for adapter.

Throws:

ListenerException

getPhysicalDestinationName

public String getPhysicalDestinationName()

Specified by:

getPhysicalDestinationName in interface HasPhysicalDestination

setName

@Mandatory
public void setName(String name)

Internal name of the listener, as known to the adapter. An IbisLocalSender refers to this name in its javaListener-attribute.

Specified by:

setName in interface INamedObject

setServiceName

public void setServiceName(String jndiName)

External Name of the listener. An IbisJavaSender refers to this name in its serviceName-attribute.

setLocal

@Deprecated
public void setLocal(String name)

Deprecated.

setIsolated

@Deprecated
public void setIsolated(boolean b)

Deprecated.

setSynchronous

@Deprecated
public void setSynchronous(boolean b)

Deprecated.

setReturnedSessionKeys

public void setReturnedSessionKeys(String string)

Comma separated list of keys of session variables that should be returned to caller, for correct results as well as for erronous results. If not set (not even to an empty value), all session keys can be returned.

Default value

all session keys can be returned

setThrowException

public void setThrowException(boolean throwException)

Should the JavaListener throw a ListenerException when it occurs or return an error message

Default value

true

setHttpWsdl

public void setHttpWsdl(boolean httpWsdl)

If true, the WSDL of the service provided by this listener will available for download

Default value

false