public class PullingIfsaProviderListener extends IfsaFacade implements IPullingListener, 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
log
Constructor and Description |
---|
PullingIfsaProviderListener() |
Modifier and Type | Method and Description |
---|---|
void |
afterMessageProcessed(PipeLineResult plr,
Object rawMessage,
Map threadContext)
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 threadContext)
Finalizes a message receiving thread.
|
void |
configure()
Checks if messageProtocol and serviceId (only for Requestors) are specified
|
Message |
extractMessage(Object rawMessage,
Map threadContext)
Extracts string from message obtained from
getRawMessage(Map) . |
String |
getIdFromRawMessage(Object rawMessage,
Map threadContext)
Extracts ID-string from message obtained from
getRawMessage(Map) . |
protected String |
getIdFromWrapper(IMessageWrapper wrapper,
Map threadContext) |
protected Message |
getMessageFromWrapper(IMessageWrapper wrapper,
Map threadContext) |
Object |
getRawMessage(Map 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 threadContext) |
void |
open()
Prepares the listener for receiving messages.
|
Map |
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) |
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
getName, setName
getApplicationContext, getName
getConfigurationClassLoader
setApplicationContext
getDomain
protected javax.jms.QueueSession getSession(Map 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
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
ListenerException
public Map openThread() throws ListenerException
IPullingListener
openThread
in interface IPullingListener
ListenerException
public void close() throws ListenerException
IListener
close
in interface IListener
ListenerException
public void closeThread(Map threadContext) throws ListenerException
IPullingListener
IListener.close()
is called.closeThread
in interface IPullingListener
ListenerException
public void afterMessageProcessed(PipeLineResult plr, Object rawMessage, Map threadContext) throws ListenerException
IListener
afterMessageProcessed
in interface IListener
ListenerException
protected String getIdFromWrapper(IMessageWrapper wrapper, Map threadContext)
protected Message getMessageFromWrapper(IMessageWrapper wrapper, Map threadContext)
public String getIdFromRawMessage(Object rawMessage, Map threadContext) throws ListenerException
getRawMessage(Map)
.
Puts also the following parameters in the threadContext:
getIdFromRawMessage
in interface IListener
ListenerException
public Object getRawMessage(Map threadContext) throws ListenerException
getRawMessage
in interface IPullingListener
ListenerException
public Message extractMessage(Object rawMessage, Map threadContext) throws ListenerException
getRawMessage(Map)
. May also extract
other parameters from the message and put those in the threadContext.extractMessage
in interface IListener
ListenerException
protected boolean canGoOn()
public void SetRunStateEnquirer(RunStateEnquirer enquirer)
SetRunStateEnquirer
in interface RunStateEnquiring
Copyright © 2023 Frank!Framework. All rights reserved.