nl.nn.adapterframework.extensions.ifsa.jms

Class IfsaListener

java.lang.Object

nl.nn.adapterframework.extensions.ifsa.jms.IfsaFacade

nl.nn.adapterframework.extensions.ifsa.jms.IfsaListener

All Implemented Interfaces:

HasPhysicalDestination, IConfigurable, IConfigurationAware, IKnowsDeliveryCount<com.ing.ifsa.IFSAMessage>, IListener<com.ing.ifsa.IFSAMessage>, INamedObject, IScopeProvider, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

PullingIfsaProviderListener, PushingIfsaProviderListener

public abstract class IfsaListener
extends IfsaFacade
implements IListener<com.ing.ifsa.IFSAMessage>, IKnowsDeliveryCount<com.ing.ifsa.IFSAMessage>

Field Summary

Fields

Modifier and Type	Field and Description
static String	THREAD_CONTEXT_BIFNAME_KEY
static String	THREAD_CONTEXT_ORIGINAL_RAW_MESSAGE_KEY

Fields inherited from class nl.nn.adapterframework.extensions.ifsa.jms.IfsaFacade

log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	IfsaListener()

Method Summary

Modifier and Type	Method and Description
protected String	displayHeaders(com.ing.ifsa.IFSAMessage message)
Message	extractMessage(RawMessageWrapper<com.ing.ifsa.IFSAMessage> rawMessage, Map<String,Object> context) Extracts message string from raw message.
Map<String,Object>	extractMessageProperties(com.ing.ifsa.IFSAMessage message)
int	getDeliveryCount(RawMessageWrapper<com.ing.ifsa.IFSAMessage> rawMessage)

Methods inherited from class nl.nn.adapterframework.extensions.ifsa.jms.IfsaFacade

cleanUpAfterException, closeReplyReceiver, closeService, closeSession, configure, createSender, createSession, getAckMode, getApplicationId, getExpiry, getExpiry, getLogPrefix, getMessageProtocol, getMessageProtocolEnum, getMessagingSource, getName, getPhysicalDestinationName, getProviderSelector, getReplyReceiver, getServiceId, getServiceQueue, getServiceReceiver, getTimeOut, isJmsTransacted, isProvider, isRequestor, isSessionsArePooled, openService, sendMessage, sendReply, setAckMode, setAcknowledgeMode, setApplicationId, setMessageProtocol, setName, setServiceId, setTimeOut, toString, useSelectorsForProviders

Methods inherited from class java.lang.Object

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

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

afterMessageProcessed, close, configure, open

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

getName, setName

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

THREAD_CONTEXT_ORIGINAL_RAW_MESSAGE_KEY

public static final String THREAD_CONTEXT_ORIGINAL_RAW_MESSAGE_KEY

See Also:

Constant Field Values

THREAD_CONTEXT_BIFNAME_KEY

public static final String THREAD_CONTEXT_BIFNAME_KEY

See Also:

Constant Field Values

Constructor Detail

IfsaListener

protected IfsaListener()

Method Detail

displayHeaders

protected String displayHeaders(com.ing.ifsa.IFSAMessage message)

extractMessageProperties

public Map<String,Object> extractMessageProperties(com.ing.ifsa.IFSAMessage message)

extractMessage

public Message extractMessage(@Nonnull
                              RawMessageWrapper<com.ing.ifsa.IFSAMessage> rawMessage,
                              @Nonnull
                              Map<String,Object> context)
                       throws ListenerException

Extracts message string from raw message. May also extract other parameters from the message and put those in the threadContext.

Specified by:

extractMessage in interface IListener<com.ing.ifsa.IFSAMessage>

Parameters:

rawMessage - The RawMessageWrapper from which to extract the Message.

context - Context to populate. Either a PipeLineSession or a Map threadContext depending on caller.

Returns:

input message for adapter.

Throws:

ListenerException

getDeliveryCount

public int getDeliveryCount(RawMessageWrapper<com.ing.ifsa.IFSAMessage> rawMessage)

Specified by:

getDeliveryCount in interface IKnowsDeliveryCount<com.ing.ifsa.IFSAMessage>