Uses of Class
org.frankframework.core.ListenerException
Package
Description
-
Uses of ListenerException in org.frankframework.core
Modifier and TypeMethodDescriptionvoid
IListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession) Called to perform actions (like committing or sending a reply) after a message has been processed by the Pipeline.IMessageBrowser.browseMessage
(String storageKey) Retrieves the message, but does not delete.IHasProcessState.changeProcessState
(RawMessageWrapper<M> message, ProcessState toState, String reason) Change the processState of the message to the specified state, if that state is supported.void
IListener.close()
Close all resources used for listening.void
IMessageBrowsingIterator.close()
void
IPullingListener.closeThread
(Map<String, Object> threadContext) Finalizes a message receiving thread.boolean
IMessageBrowser.containsCorrelationId
(String correlationId) boolean
IMessageBrowser.containsMessageId
(String originalMessageId) Check if the storage contains message with the given original messageId (as passed to storeMessage).void
IMessageBrowser.deleteMessage
(String storageKey) Deletes the message.IListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) Extracts data from message obtained fromIPullingListener.getRawMessage(Map)
orIPushingListener.wrapRawMessage(Object, PipeLineSession)
.IMessageBrowsingIteratorItem.getCommentString()
IMessageBrowser.getContext
(String storageKey) Retrieves the message context as an iteratorItem.IMessageBrowsingIteratorItem.getCorrelationId()
IMessageBrowsingIteratorItem.getExpiryDate()
IMessageBrowsingIteratorItem.getHost()
IMessageBrowsingIteratorItem.getId()
IMessageBrowsingIteratorItem.getInsertDate()
IMessageBrowser.getIterator()
Gets an enumeration of messages.IMessageBrowser.getIterator
(Date startTime, Date endTime, IMessageBrowser.SortOrder order) IMessageBrowsingIteratorItem.getLabel()
ITransactionalStorage.getMessage
(String storageKey) Retrieves and deletes the message.int
IMessageBrowser.getMessageCount()
IMessageBrowsingIteratorItem.getOriginalId()
ICorrelatedPullingListener.getRawMessage
(String correlationId, Map<String, Object> threadContext) Retrieves messages from queue or other channel, but retrieves only messages with the specified correlationId.IPullingListener.getRawMessage
(Map<String, Object> threadContext) Retrieves messages from queue or other channel, but does no processing on it.IMessageBrowsingIteratorItem.getType()
boolean
IMessageBrowsingIterator.hasNext()
boolean
IPeekableListener.hasRawMessageAvailable()
IMessageBrowsingIterator.next()
void
IListener.open()
Prepares the listener for receiving messages.IPullingListener.openThread()
Prepares a thread for receiving messages.Adapter.processMessageWithExceptions
(String messageId, Message message, PipeLineSession pipeLineSession) IAdapter.processMessageWithExceptions
(String messageId, Message message, PipeLineSession pipeLineSession) void
IMessageHandler.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> message, PipeLineSession session, boolean duplicatesAlreadyChecked) Will use listener to performIListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>)
andIListener.afterMessageProcessed(org.frankframework.core.PipeLineResult, org.frankframework.receivers.RawMessageWrapper<M>, org.frankframework.core.PipeLineSession)
void
IMessageHandler.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> message, PipeLineSession session, long waitingTime, boolean duplicatesAlreadyChecked) Same asIMessageHandler.processRawMessage(IListener,RawMessageWrapper,PipeLineSession, boolean)
, but now updates IdleStatistics tooIMessageHandler.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Alternative to functions above, will NOT useIListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>)
.IPostboxListener.retrieveRawMessage
(String messageSelector, Map<String, Object> threadContext) Retrieves the first message found from queue or other channel, that matches the specifiedmessageSelector
.void
IListenerConnector.start()
Start Listener-port to which the Listener is connected.void
IListenerConnector.stop()
Stop Listener-port to which the Listener is connected.IPushingListener.wrapRawMessage
(M rawMessage, PipeLineSession session) Wrap a raw message in a MessageWrapper. -
Uses of ListenerException in org.frankframework.http
Modifier and TypeMethodDescriptionRestServiceDispatcher.dispatchRequest
(String restPath, String uri, jakarta.servlet.http.HttpServletRequest httpServletRequest, String contentType, String request, PipeLineSession context, jakarta.servlet.http.HttpServletResponse httpServletResponse, jakarta.servlet.ServletContext servletContext) Dispatch a request.void
HttpListener.open()
Deprecated.void
PushingListenerAdapter.open()
void
RestListener.open()
void
WebServiceListener.open()
PushingListenerAdapter.processRequest
(Message rawMessage, PipeLineSession session) RestListener.processRequest
(Message message, PipeLineSession session) WebServiceListener.processRequest
(Message message, PipeLineSession session) -
Uses of ListenerException in org.frankframework.http.cxf
-
Uses of ListenerException in org.frankframework.http.rest
Modifier and TypeMethodDescriptionvoid
ApiListener.open()
void
ApiDispatchConfig.register
(ApiListener.HttpMethod method, ApiListener listener) void
ApiServiceDispatcher.registerServiceClient
(ApiListener listener) -
Uses of ListenerException in org.frankframework.jdbc
Modifier and TypeMethodDescriptionvoid
JdbcListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession) JdbcMessageBrowser.browseMessage
(String storageKey) protected RawMessageWrapper<M>
JdbcListener.changeProcessState
(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason) JdbcListener.changeProcessState
(RawMessageWrapper<M> rawMessage, ProcessState toState, String reason) protected RawMessageWrapper<M>
JdbcTableListener.changeProcessState
(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason) void
JdbcListener.closeThread
(Map<String, Object> threadContext) void
SimpleJdbcListener.closeThread
(Map<String, Object> threadContext) boolean
JdbcMessageBrowser.containsCorrelationId
(String correlationId) boolean
JdbcMessageBrowser.containsMessageId
(String originalMessageId) void
JdbcMessageBrowser.deleteMessage
(String storageKey) protected boolean
JdbcListener.execute
(Connection conn, String query, String... parameters) protected void
SimpleJdbcListener.execute
(Connection conn, String query) protected void
SimpleJdbcListener.execute
(Connection conn, String query, String parameter) protected ResultSet
SimpleJdbcListener.executeQuery
(Connection conn, String query) JdbcListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) MessageStoreListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) JdbcMessageBrowser.getContext
(String storageKey) JdbcMessageBrowser.getIterator()
JdbcMessageBrowser.getIterator
(Date startTime, Date endTime, IMessageBrowser.SortOrder order) protected String
JdbcListener.getKeyFromRawMessage
(RawMessageWrapper<M> rawMessage) JdbcTransactionalStorage.getMessage
(String storageKey) int
JdbcMessageBrowser.getMessageCount()
protected RawMessageWrapper<M>
JdbcListener.getRawMessage
(Connection conn, Map<String, Object> threadContext) JdbcListener.getRawMessage
(Map<String, Object> threadContext) protected RawMessageWrapper<String>
SimpleJdbcListener.getRawMessage
(Connection conn, Map<String, Object> threadContext) SimpleJdbcListener.getRawMessage
(Map<String, Object> threadContext) boolean
JdbcListener.hasRawMessageAvailable()
protected boolean
JdbcListener.hasRawMessageAvailable
(Connection conn) void
JdbcListener.open()
void
SimpleJdbcListener.open()
JdbcListener.openThread()
SimpleJdbcListener.openThread()
-
Uses of ListenerException in org.frankframework.jms
Modifier and TypeMethodDescriptionvoid
JmsListenerBase.afterMessageProcessed
(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession session) void
PullingJmsListener.afterMessageProcessed
(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession) JmsMessageBrowser.browseJmsMessage
(String messageId) JmsBrowser.browseMessage
(String messageId) JmsTransactionalStorage.browseMessage
(String storageKey) void
JmsQueueBrowserIterator.close()
void
PullingJmsListener.closeThread
(Map<String, Object> threadContext) boolean
JmsMessageBrowser.containsCorrelationId
(String correlationId) boolean
JmsMessageBrowser.containsMessageId
(String originalMessageId) boolean
JmsTransactionalStorage.containsMessageId
(String originalMessageId) void
JmsMessageBrowser.deleteMessage
(String messageId) protected jakarta.jms.Message
protected jakarta.jms.Message
JmsListenerBase.extractMessage
(RawMessageWrapper<jakarta.jms.Message> rawMessage, Map<String, Object> context) Extracts data from message obtained fromIPullingListener.getRawMessage(Map)
.JmsMessageBrowserIteratorItem.getCommentString()
JmsMessageBrowser.getContext
(String messageId) JmsMessageBrowserIteratorItem.getCorrelationId()
JmsMessageBrowserIteratorItem.getExpiryDate()
JmsMessageBrowserIteratorItem.getHost()
JmsMessageBrowserIteratorItem.getId()
JmsMessageBrowserIteratorItem.getInsertDate()
JmsMessageBrowser.getIterator()
JmsMessageBrowser.getIterator
(Date startTime, Date endTime, IMessageBrowser.SortOrder order) JmsMessageBrowser.getJmsMessage
(String messageId) JmsMessageBrowserIteratorItem.getJMSMessageID()
long
JmsMessageBrowserIteratorItem.getJMSTimestamp()
JmsMessageBrowserIteratorItem.getLabel()
JmsTransactionalStorage.getMessage
(String storageKey) int
JmsMessageBrowser.getMessageCount()
JmsMessageBrowserIteratorItem.getOriginalId()
RawMessageWrapper<jakarta.jms.Message>
PullingJmsListener.getRawMessage
(String correlationId, Map<String, Object> threadContext) RawMessageWrapper<jakarta.jms.Message>
PullingJmsListener.getRawMessage
(Map<String, Object> threadContext) Retrieves messages from queue or other channel, but does no processing on it.protected jakarta.jms.MessageConsumer
PullingJmsListener.getReceiver
(Map<String, Object> threadContext, jakarta.jms.Session session, String correlationId) protected jakarta.jms.Session
PullingJmsListener.getSession
(Map<String, Object> threadContext) JmsMessageBrowserIteratorItem.getText()
JmsMessageBrowserIteratorItem.getType()
void
JmsListenerBase.open()
void
PushingJmsListener.open()
PullingJmsListener.openThread()
JmsListenerBase.prepareReply
(Message rawReply, Map<String, Object> threadContext) protected void
PullingJmsListener.releaseReceiver
(jakarta.jms.MessageConsumer receiver, String correlationId) RawMessageWrapper<jakarta.jms.Message>
PullingJmsListener.retrieveRawMessage
(String messageSelector, Map<String, Object> threadContext) protected void
JmsListenerBase.sendReply
(PipeLineResult plr, jakarta.jms.Destination replyTo, String replyCid, long timeToLive, boolean ignoreInvalidDestinationException, PipeLineSession pipeLineSession, Map<String, Object> properties) protected void
PullingJmsListener.sendReply
(PipeLineResult plr, jakarta.jms.Destination replyTo, String replyCid, long timeToLive, boolean ignoreInvalidDestinationException, PipeLineSession pipeLineSession, Map<String, Object> properties) RawMessageWrapper<jakarta.jms.Message>
PushingJmsListener.wrapRawMessage
(jakarta.jms.Message rawMessage, PipeLineSession session) -
Uses of ListenerException in org.frankframework.management.bus.dto
-
Uses of ListenerException in org.frankframework.processors
Modifier and TypeMethodDescriptionCoreListenerProcessor.getMessage
(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession) ListenerProcessor.getMessage
(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession) -
Uses of ListenerException in org.frankframework.receivers
Modifier and TypeMethodDescriptionvoid
FileRecordListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<String> rawMessage, PipeLineSession pipeLineSession) Deprecated.void
JavaListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession) protected String
FileRecordListener.archiveFile
(File file) Deprecated.Moves a file to another directory and places a UUID in the name.Receiver.changeProcessState
(RawMessageWrapper<M> message, ProcessState toState, String reason) void
FileRecordListener.close()
Deprecated.void
JavaListener.close()
void
FileRecordListener.closeThread
(Map<String, Object> threadContext) Deprecated.ServiceDispatcher.dispatchRequest
(String serviceName, Message message, PipeLineSession session) Dispatch a requestMessage
to a service by its configured name.JavaListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) FileRecordListener.getRawMessage
(Map<String, Object> threadContext) Deprecated.Retrieves a single record from a file.void
FileRecordListener.open()
Deprecated.void
JavaListener.open()
protected void
Receiver.openAllResources()
FileRecordListener.openThread()
Deprecated.void
Receiver.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession session, boolean duplicatesAlreadyChecked) void
Receiver.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession session, long waitingDuration, boolean duplicatesAlreadyChecked) JavaListener.processRequest
(String correlationId, String rawMessage, HashMap context) JavaListener.processRequest
(Message message, PipeLineSession session) Receiver.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Process the received message withReceiver.processRequest(IListener, RawMessageWrapper, Message, PipeLineSession)
.ServiceClient.processRequest
(Message message, PipeLineSession session) Method to implement for processing a request.void
ServiceDispatcher.registerServiceClient
(String name, ServiceClient listener) void
Receiver.retryMessage
(String storageKey) -
Uses of ListenerException in org.frankframework.senders
Modifier and TypeMethodDescriptionIsolatedServiceCaller.callServiceIsolated
(ServiceClient service, Message message, PipeLineSession session, ThreadLifeCycleEventListener threadLifeCycleEventListener) -
Uses of ListenerException in org.frankframework.unmanaged
-
Uses of ListenerException in org.frankframework.util
Modifier and TypeMethodDescriptionboolean
MessageBrowsingFilter.matchAny
(IMessageBrowsingIteratorItem iterItem) boolean
MessageBrowsingFilter.matchMessage
(IMessageBrowsingIteratorItem iterItem)