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.MessageProtocolJMSFacade.AcknowledgeMode, JMSFacade.DeliveryMode, JMSFacade.DestinationType, JMSFacade.SubscriberTypemessagingSource| Constructor and Description |
|---|
FxfListener() |
| Modifier and Type | Method and Description |
|---|---|
void |
afterMessageProcessed(PipeLineResult plr,
Object rawMessageOrWrapper,
Map<String,Object> threadContext)
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 |
getMessageProperties, getResultFromxPath, getxPathLogMap, isSynchronous, retrieveIdFromMessage, setCopyAEProperties, setForceMessageIdAsCorrelationId, setMessageProtocol, setUseReplyTo, setxPathLoggingKeys, transactionalAllowed, transactionalRequiredclose, decreaseThreadCount, getCurrentThreadCount, getDeliveryCount, getListenerPortConnector, getMaxThreadCount, increaseThreadCount, isThreadCountControllable, isThreadCountReadable, open, setCacheMode, setDestinationName, setPollGuardIntervaladdParameter, extractMessage, getIdFromRawMessage, getParameterList, messageWillBeRedeliveredOnExitStateError, prepareReply, prepareReply, sendReply, setReplyDeliveryMode, setReplyDestinationName, setReplyEncodingStyleURI, setReplyMessageTimeToLive, setReplyMessageType, setReplyNamespaceURI, setReplyPriority, setReplySoapAction, setSender, setSoap, setSoapHeaderSessionKey, setTimeout, setTimeOutcheckTransactionManagerValidity, closeSession, createMessage, createSession, extractMessage, extractMessageBody, getAcknowledgeModeEnum, getConnectionFactoryInfo, getConnectionFactoryName, getContext, getDestination, getDestination, getJmsMessagingSource, getLogPrefix, getManagedConnectionFactory, getMessageConsumer, getMessageConsumer, getMessageConsumerForCorrelationId, getMessageProducer, getMessagingSource, getMessagingSourceFactory, getPhysicalDestinationName, getPhysicalDestinationShortName, getPhysicalDestinationShortName, isSessionsArePooled, 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, useJms102getContext, getJndiEnv, setAuthentication, setCredentials, setInitialContextFactoryName, setJmsRealm, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixesclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitcheckTransactionManagerValidity, getExceptionListener, getHandler, getReceiver, setReceiversetExceptionListener, setHandlerextractMessage, getIdFromRawMessagegetName, setNamegetApplicationContext, getNamegetConfigurationClassLoadersetApplicationContextgetDomainisTransactedpublic void configure()
throws ConfigurationException
IListenerconfigure() 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 IConfigurableconfigure in interface IListener<javax.jms.Message>configure in class EsbJmsListenerConfigurationExceptionpublic void afterMessageProcessed(PipeLineResult plr, Object rawMessageOrWrapper, Map<String,Object> threadContext) throws ListenerException
IListenerafterMessageProcessed in interface IListener<javax.jms.Message>afterMessageProcessed in class EsbJmsListenerListenerExceptionpublic 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.