public class PullingIfsaProviderListener extends IfsaListener implements IPullingListener<com.ing.ifsa.IFSAMessage>, INamedObject, RunStateEnquiring
IPullingListener
that acts as an IFSA-service.
There is no need or possibility to set the ServiceId as the Provider will receive all messages
for this Application on the same serviceQueue.
The following session keys are set for each message:
ifsa.provider.useSelectors=false
THREAD_CONTEXT_BIFNAME_KEY, THREAD_CONTEXT_ORIGINAL_RAW_MESSAGE_KEY
log
Constructor and Description |
---|
PullingIfsaProviderListener() |
Modifier and Type | Method and Description |
---|---|
void |
afterMessageProcessed(PipeLineResult plr,
RawMessageWrapper<com.ing.ifsa.IFSAMessage> rawMessageWrapper,
PipeLineSession pipeLineSession)
Called to perform actions (like committing or sending a reply) after a message has been processed by the
Pipeline.
|
protected boolean |
canGoOn() |
void |
close()
Close all resources used for listening.
|
void |
closeThread(Map<String,Object> threadContext)
Finalizes a message receiving thread.
|
void |
configure()
Checks if messageProtocol and serviceId (only for Requestors) are specified
|
RawMessageWrapper<com.ing.ifsa.IFSAMessage> |
getRawMessage(Map<String,Object> threadContext)
Retrieves messages to be processed by the server, implementing an IFSA-service, but does no processing on it.
|
protected javax.jms.QueueReceiver |
getReceiver(Map threadContext,
javax.jms.QueueSession session) |
protected javax.jms.QueueSession |
getSession(Map<String,Object> threadContext) |
void |
open()
Prepares the listener for receiving messages.
|
Map<String,Object> |
openThread()
Prepares a thread for receiving messages.
|
protected void |
releaseReceiver(javax.jms.QueueReceiver receiver) |
protected void |
releaseSession(javax.jms.Session session) |
void |
SetRunStateEnquirer(RunStateEnquirer enquirer) |
RawMessageWrapper<com.ing.ifsa.IFSAMessage> |
wrapRawMessage(javax.jms.Message rawMessage,
Map<String,Object> threadContext) |
displayHeaders, extractMessage, extractMessageProperties, getDeliveryCount
cleanUpAfterException, closeReplyReceiver, closeService, closeSession, 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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
extractMessage
getName, setName
getApplicationContext, getName
getConfigurationClassLoader
setApplicationContext
getDomain
protected javax.jms.QueueSession getSession(Map<String,Object> threadContext) throws ListenerException
ListenerException
protected void releaseSession(javax.jms.Session session) throws ListenerException
ListenerException
protected javax.jms.QueueReceiver getReceiver(Map threadContext, javax.jms.QueueSession session) throws ListenerException
ListenerException
protected void releaseReceiver(javax.jms.QueueReceiver receiver) throws ListenerException
ListenerException
public void configure() throws ConfigurationException
IfsaFacade
configure
in interface IConfigurable
configure
in interface IListener<com.ing.ifsa.IFSAMessage>
configure
in class IfsaFacade
ConfigurationException
public void open() throws ListenerException
IListener
open()
is called once each time the listener is started.open
in interface IListener<com.ing.ifsa.IFSAMessage>
ListenerException
@Nonnull public Map<String,Object> openThread() throws ListenerException
IPullingListener
openThread
in interface IPullingListener<com.ing.ifsa.IFSAMessage>
null
, must be a mutable map type.ListenerException
public void close() throws ListenerException
IListener
close
in interface IListener<com.ing.ifsa.IFSAMessage>
ListenerException
public void closeThread(@Nonnull Map<String,Object> threadContext) throws ListenerException
IPullingListener
IListener.close()
is called.closeThread
in interface IPullingListener<com.ing.ifsa.IFSAMessage>
ListenerException
public void afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<com.ing.ifsa.IFSAMessage> rawMessageWrapper, PipeLineSession pipeLineSession) throws ListenerException
IListener
afterMessageProcessed
in interface IListener<com.ing.ifsa.IFSAMessage>
ListenerException
public RawMessageWrapper<com.ing.ifsa.IFSAMessage> getRawMessage(@Nonnull Map<String,Object> threadContext) throws ListenerException
getRawMessage
in interface IPullingListener<com.ing.ifsa.IFSAMessage>
ListenerException
public RawMessageWrapper<com.ing.ifsa.IFSAMessage> wrapRawMessage(javax.jms.Message rawMessage, Map<String,Object> threadContext) throws ListenerException
ListenerException
protected boolean canGoOn()
public void SetRunStateEnquirer(RunStateEnquirer enquirer)
SetRunStateEnquirer
in interface RunStateEnquiring
Copyright © 2023 Frank!Framework. All rights reserved.