public class FxfListener extends EsbJmsListener
Configuration (where deviating from EsbJmsListener):
attributes | description | default |
---|---|---|
destinationName | name of the JMS destination (queue or topic) to use | "jms/FileTransferAction" |
jmsRealm | "qcf_tibco_p2p_ff" | |
messageProtocol | protocol of ESB service to be called. Possible values
| "FF" |
EsbJmsListener.MessageProtocol
JMSFacade.AcknowledgeMode, JMSFacade.DeliveryMode, JMSFacade.DestinationType, JMSFacade.SubscriberType
messagingSource
Constructor and Description |
---|
FxfListener() |
Modifier and Type | Method and Description |
---|---|
void |
afterMessageProcessed(PipeLineResult plr,
RawMessageWrapper<javax.jms.Message> rawMessageWrapper,
PipeLineSession pipeLineSession)
Called to perform actions (like committing or sending a reply) after a message has been processed by the
Pipeline.
|
void |
configure()
configure() is called once at startup of the framework in the configure() method
of the owner of this listener. |
void |
setCreateProcessedDirectory(boolean b)
(only used when
moveProcessedFile=true ) when set to true , the directory to move processed files in is created if it does not exist |
void |
setFxfFileSessionKey(String fxfFileSessionKey)
name of the session key to store the name of the received file in
|
void |
setMoveProcessedFile(boolean b)
If set to
true , the received file is moved after being processed |
void |
setProcessedSiblingDirectory(String processedSiblingDirectory)
(only used when
moveProcessedFile=true ) sibling directory (related to the parent directory of the file to process) where files are stored after being processed |
extractMessageProperties, getMessageProperties, getResultFromxPath, getxPathLogMap, isSynchronous, setCopyAEProperties, setForceMessageIdAsCorrelationId, setMessageProtocol, setUseReplyTo, setxPathLoggingKeys, transactionalAllowed, transactionalRequired
close, decreaseThreadCount, getCurrentThreadCount, getDeliveryCount, getListenerPortConnector, getMaxThreadCount, increaseThreadCount, isThreadCountControllable, isThreadCountReadable, open, setCacheMode, setDestinationName, setPollGuardInterval, wrapRawMessage
addParameter, extractMessage, getParameterList, messageWillBeRedeliveredOnExitStateError, prepareReply, prepareReply, sendReply, setReplyDeliveryMode, setReplyDestinationName, setReplyEncodingStyleURI, setReplyMessageTimeToLive, setReplyMessageType, setReplyNamespaceURI, setReplyPriority, setReplySoapAction, setSender, setSoap, setSoapHeaderSessionKey, setTimeout, setTimeOut
checkTransactionManagerValidity, closeSession, createMessage, createSession, extractMessage, extractMessageBody, getAcknowledgeModeEnum, getConnectionFactoryInfo, getConnectionFactoryName, getContext, getDestination, getDestination, getJmsMessagingSource, getLogPrefix, getManagedConnectionFactory, getMessageConsumer, getMessageConsumer, getMessageConsumerForCorrelationId, getMessageProducer, getMessagingSource, getMessagingSourceFactory, getPhysicalDestinationName, getPhysicalDestinationShortName, getPhysicalDestinationShortName, isSessionsArePooled, logMessageDetails, send, send, send, send, send, send, send, sendByQueue, sendByTopic, setAckMode, setAcknowledgeMode, setAuthAlias, setCorrelationIdMaxLength, setCorrelationIdToHex, setCorrelationIdToHexPrefix, setDestinationType, setJmsTransacted, setLookupDestination, setMessageCorrelationID, setMessageSelector, setMessageTimeToLive, setPersistent, setQueueConnectionFactoryName, setSubscriberType, setTopicConnectionFactoryName, setTransacted, toString, useJms102
getContext, getJndiEnv, setAuthentication, setCredentials, setInitialContextFactoryName, setJmsRealm, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
checkTransactionManagerValidity, getExceptionListener, getHandler, getReceiver, setReceiver
setExceptionListener, setHandler
extractMessage
getName, setName
getApplicationContext, getName
getConfigurationClassLoader
setApplicationContext
getDomain
isTransacted
public void configure() throws ConfigurationException
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.configure
in interface IConfigurable
configure
in interface IListener<javax.jms.Message>
configure
in class EsbJmsListener
ConfigurationException
public void afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<javax.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession) throws ListenerException
IListener
afterMessageProcessed
in interface IListener<javax.jms.Message>
afterMessageProcessed
in class EsbJmsListener
ListenerException
public void setFxfFileSessionKey(String fxfFileSessionKey)
public void setMoveProcessedFile(boolean b)
true
, the received file is moved after being processedpublic void setProcessedSiblingDirectory(String processedSiblingDirectory)
moveProcessedFile=true
) sibling directory (related to the parent directory of the file to process) where files are stored after being processedpublic void setCreateProcessedDirectory(boolean b)
moveProcessedFile=true
) when set to true
, the directory to move processed files in is created if it does not existCopyright © 2023 Frank!Framework. All rights reserved.