Uses of Class
org.frankframework.core.ListenerException

Packages that use ListenerException

Package	Description
org.frankframework.core
org.frankframework.http
org.frankframework.http.cxf
org.frankframework.jdbc
org.frankframework.jms
org.frankframework.management.bus.dto
org.frankframework.pipes
org.frankframework.processors
org.frankframework.receivers
org.frankframework.senders
org.frankframework.util

Uses of ListenerException in org.frankframework.core

Methods in org.frankframework.core that throw ListenerException

Modifier and Type	Method	Description
void	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.
RawMessageWrapper<M>	IMessageBrowser.browseMessage(String storageKey)	Retrieves the message, but does not delete.
RawMessageWrapper<M>	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	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.
Message	IListener.extractMessage(RawMessageWrapper<M> rawMessage, Map<String,Object> context)	Extracts data from message obtained from IPullingListener.getRawMessage(Map) or IPushingListener.wrapRawMessage(Object, PipeLineSession).
String	IMessageBrowsingIteratorItem.getCommentString()
IMessageBrowsingIteratorItem	IMessageBrowser.getContext(String storageKey)	Retrieves the message context as an iteratorItem.
String	IMessageBrowsingIteratorItem.getCorrelationId()
Date	IMessageBrowsingIteratorItem.getExpiryDate()
String	IMessageBrowsingIteratorItem.getHost()
String	IMessageBrowsingIteratorItem.getId()
Date	IMessageBrowsingIteratorItem.getInsertDate()
IMessageBrowsingIterator	IMessageBrowser.getIterator()	Gets an enumeration of messages.
IMessageBrowsingIterator	IMessageBrowser.getIterator(Date startTime, Date endTime, IMessageBrowser.SortOrder order)
String	IMessageBrowsingIteratorItem.getLabel()
RawMessageWrapper<S>	ITransactionalStorage.getMessage(String storageKey)	Retrieves and deletes the message.
int	IMessageBrowser.getMessageCount()
String	IMessageBrowsingIteratorItem.getOriginalId()
RawMessageWrapper<M>	ICorrelatedPullingListener.getRawMessage(String correlationId, Map<String,Object> threadContext)	Retrieves messages from queue or other channel, but retrieves only messages with the specified correlationId.
RawMessageWrapper<M>	IPullingListener.getRawMessage(Map<String,Object> threadContext)	Retrieves messages from queue or other channel, but does no processing on it.
String	IMessageBrowsingIteratorItem.getType()
boolean	IMessageBrowsingIterator.hasNext()
boolean	IPeekableListener.hasRawMessageAvailable()
IMessageBrowsingIteratorItem	IMessageBrowsingIterator.next()
Map<String,Object>	IPullingListener.openThread()	Prepares a thread for receiving messages.
PipeLineResult	Adapter.processMessageWithExceptions(String messageId, Message message, PipeLineSession pipeLineSession)	This method does the real processing of messages by the adapter.
void	IMessageHandler.processRawMessage(IListener<M> origin, RawMessageWrapper<M> message, PipeLineSession session, boolean duplicatesAlreadyChecked)	Will use listener to perform IListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) and IListener.afterMessageProcessed(org.frankframework.core.PipeLineResult, org.frankframework.receivers.RawMessageWrapper<M>, org.frankframework.core.PipeLineSession)
Message	IMessageHandler.processRequest(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session)	Alternative to functions above, will NOT use IListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>).
RawMessageWrapper<M>	IPushingListener.wrapRawMessage(M rawMessage, PipeLineSession session)	Wrap a raw message in a MessageWrapper.

Uses of ListenerException in org.frankframework.http

Methods in org.frankframework.http that throw ListenerException

Modifier and Type	Method	Description
Message	RestServiceDispatcher.dispatchRequest(String restPath, String uri, jakarta.servlet.http.HttpServletRequest httpServletRequest, String contentType, String request, PipeLineSession context, jakarta.servlet.http.HttpServletResponse httpServletResponse)	Dispatch a request.
Message	PushingListenerAdapter.processRequest(Message rawMessage, PipeLineSession session)
Message	RestListener.processRequest(Message message, PipeLineSession session)
Message	WebServiceListener.processRequest(Message message, PipeLineSession session)

Uses of ListenerException in org.frankframework.http.cxf

Methods in org.frankframework.http.cxf that throw ListenerException

Modifier and Type	Method	Description
String	NamespaceUriProvider.findNamespaceUri()

Uses of ListenerException in org.frankframework.jdbc

Methods in org.frankframework.jdbc that throw ListenerException

Modifier and Type	Method	Description
void	JdbcListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession)
RawMessageWrapper<M>	AbstractJdbcMessageBrowser.browseMessage(String storageKey)
protected RawMessageWrapper<M>	JdbcListener.changeProcessState(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason)
RawMessageWrapper<M>	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	AbstractJdbcMessageBrowser.containsCorrelationId(String correlationId)
boolean	AbstractJdbcMessageBrowser.containsMessageId(String originalMessageId)
void	AbstractJdbcMessageBrowser.deleteMessage(String storageKey)
protected boolean	JdbcListener.execute(Connection conn, String query, List<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)
Message	JdbcListener.extractMessage(RawMessageWrapper<M> rawMessage, Map<String,Object> context)
Message	MessageStoreListener.extractMessage(RawMessageWrapper<Serializable> rawMessageWrapper, Map<String,Object> context)
IMessageBrowsingIteratorItem	AbstractJdbcMessageBrowser.getContext(String storageKey)
IMessageBrowsingIterator	AbstractJdbcMessageBrowser.getIterator()
IMessageBrowsingIterator	AbstractJdbcMessageBrowser.getIterator(Date startTime, Date endTime, IMessageBrowser.SortOrder order)
protected String	JdbcListener.getKeyFromRawMessage(RawMessageWrapper<M> rawMessage)
RawMessageWrapper<S>	JdbcTransactionalStorage.getMessage(String storageKey)
int	AbstractJdbcMessageBrowser.getMessageCount()
protected RawMessageWrapper<M>	JdbcListener.getRawMessage(Connection conn, Map<String,Object> threadContext)
RawMessageWrapper<M>	JdbcListener.getRawMessage(Map<String,Object> threadContext)
protected RawMessageWrapper<String>	SimpleJdbcListener.getRawMessage(Connection conn, Map<String,Object> threadContext)
RawMessageWrapper<String>	SimpleJdbcListener.getRawMessage(Map<String,Object> threadContext)
boolean	JdbcListener.hasRawMessageAvailable()
protected boolean	JdbcListener.hasRawMessageAvailable(Connection conn)
Map<String,Object>	JdbcListener.openThread()
Map<String,Object>	SimpleJdbcListener.openThread()

Uses of ListenerException in org.frankframework.jms

Methods in org.frankframework.jms that throw ListenerException

Modifier and Type	Method	Description
void	AbstractJmsListener.afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession session)
void	PullingJmsListener.afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession)
J	AbstractJmsMessageBrowser.browseJmsMessage(String messageId)
RawMessageWrapper<M>	JmsBrowser.browseMessage(String messageId)
RawMessageWrapper<S>	JmsTransactionalStorage.browseMessage(String storageKey)
void	JmsQueueBrowserIterator.close()
void	PullingJmsListener.closeThread(Map<String,Object> threadContext)
boolean	AbstractJmsMessageBrowser.containsCorrelationId(String correlationId)
boolean	AbstractJmsMessageBrowser.containsMessageId(String originalMessageId)
boolean	JmsTransactionalStorage.containsMessageId(String originalMessageId)
void	AbstractJmsMessageBrowser.deleteMessage(String messageId)
protected jakarta.jms.Message	AbstractJmsMessageBrowser.doBrowse(String selectorKey, String selectorValue)
protected jakarta.jms.Message	AbstractJmsMessageBrowser.doBrowse(Map<String,String> selectors)
Message	AbstractJmsListener.extractMessage(RawMessageWrapper<jakarta.jms.Message> rawMessage, Map<String,Object> context)	Extracts data from message obtained from IPullingListener.getRawMessage(Map).
String	JmsMessageBrowserIteratorItem.getCommentString()
IMessageBrowsingIteratorItem	AbstractJmsMessageBrowser.getContext(String messageId)
String	JmsMessageBrowserIteratorItem.getCorrelationId()
Date	JmsMessageBrowserIteratorItem.getExpiryDate()
String	JmsMessageBrowserIteratorItem.getHost()
String	JmsMessageBrowserIteratorItem.getId()
Date	JmsMessageBrowserIteratorItem.getInsertDate()
IMessageBrowsingIterator	AbstractJmsMessageBrowser.getIterator()
IMessageBrowsingIterator	AbstractJmsMessageBrowser.getIterator(Date startTime, Date endTime, IMessageBrowser.SortOrder order)
J	AbstractJmsMessageBrowser.getJmsMessage(String messageId)
String	JmsMessageBrowserIteratorItem.getJMSMessageID()
long	JmsMessageBrowserIteratorItem.getJMSTimestamp()
String	JmsMessageBrowserIteratorItem.getLabel()
RawMessageWrapper<S>	JmsTransactionalStorage.getMessage(String storageKey)
int	AbstractJmsMessageBrowser.getMessageCount()
String	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)
String	JmsMessageBrowserIteratorItem.getText()
String	JmsMessageBrowserIteratorItem.getType()
Map<String,Object>	PullingJmsListener.openThread()
Message	AbstractJmsListener.prepareReply(Message rawReply, Map<String,Object> threadContext)
Message	AbstractJmsListener.prepareReply(Message rawReply, Map<String,Object> threadContext, String soapHeader)
protected void	PullingJmsListener.releaseReceiver(jakarta.jms.MessageConsumer receiver, String correlationId)
protected void	AbstractJmsListener.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

Constructors in org.frankframework.management.bus.dto that throw ListenerException

Modifier	Constructor	Description
	StorageItemDTO(IMessageBrowsingIteratorItem item)

Uses of ListenerException in org.frankframework.pipes

Methods in org.frankframework.pipes that throw ListenerException

Modifier and Type	Method	Description
protected PipeRunResult	AsyncSenderWithListenerPipe.postSendAction(PipeRunResult sendResult, String correlationID, PipeLineSession session)
protected PipeRunResult	MessageSendingPipe.postSendAction(PipeRunResult sendResult, String correlationID, PipeLineSession session)
protected PipeRunResult	MessageSendingPipe.sendMessageWithRetries(Message input, Message originalMessage, PipeLineSession session)

Uses of ListenerException in org.frankframework.processors

Methods in org.frankframework.processors that throw ListenerException

Modifier and Type	Method	Description
Message	CoreListenerProcessor.getMessage(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession)
Message	ListenerProcessor.getMessage(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession)

Uses of ListenerException in org.frankframework.receivers

Methods in org.frankframework.receivers that throw ListenerException

Modifier and Type	Method	Description
void	JavaListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession)
RawMessageWrapper<M>	Receiver.changeProcessState(RawMessageWrapper<M> message, ProcessState toState, String reason)	Change message process state, via the listener of the receiver.
Message	ServiceDispatcher.dispatchRequest(String serviceName, Message message, PipeLineSession session)	Dispatch a request Message to a service by its configured name.
Message	JavaListener.extractMessage(RawMessageWrapper<M> rawMessage, Map<String,Object> context)
protected boolean	Receiver.isDeliveryRetryLimitExceededBeforeMessageProcessing(RawMessageWrapper<M> rawMessageWrapper, PipeLineSession session, boolean manualRetry)	returns true if message should not be processed when it is delivered.
protected void	Receiver.openAllResources()
void	Receiver.processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession session, boolean retryStatusAlreadyChecked)	This method processes the raw message from the listener.
Message	FrankListener.processRequest(Message message, PipeLineSession session)
String	JavaListener.processRequest(String correlationId, String rawMessage, HashMap context)
Message	JavaListener.processRequest(Message message, PipeLineSession session)
Message	Receiver.processRequest(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session)	Process the received message with IMessageHandler.processRequest(IListener, RawMessageWrapper, Message, PipeLineSession).
Message	ServiceClient.processRequest(Message message, PipeLineSession session)	Method to implement for processing a request.
void	Receiver.retryMessage(String storageKey)

Uses of ListenerException in org.frankframework.senders

Methods in org.frankframework.senders that throw ListenerException

Modifier and Type	Method	Description
SenderResult	IsolatedServiceCaller.callServiceIsolated(ServiceClient service, Message message, PipeLineSession session, ThreadLifeCycleEventListener<?> threadLifeCycleEventListener)

Uses of ListenerException in org.frankframework.util

Methods in org.frankframework.util that throw ListenerException

Modifier and Type	Method	Description
boolean	MessageBrowsingFilter.matchAny(IMessageBrowsingIteratorItem iterItem)
boolean	MessageBrowsingFilter.matchMessage(IMessageBrowsingIteratorItem iterItem)