M
- the raw message typepublic interface IPullingListener<M> extends IListener<M>
Modifier and Type | Method and Description |
---|---|
void |
closeThread(Map<String,Object> threadContext)
Finalizes a message receiving thread.
|
RawMessageWrapper<M> |
getRawMessage(Map<String,Object> threadContext)
Retrieves messages from queue or other channel, but does no processing on it.
|
Map<String,Object> |
openThread()
Prepares a thread for receiving messages.
|
afterMessageProcessed, close, configure, extractMessage, open
getName, setName
getApplicationContext, getName
getConfigurationClassLoader
@Nonnull Map<String,Object> openThread() throws ListenerException
null
, must be a mutable map type.ListenerException
void closeThread(@Nonnull Map<String,Object> threadContext) throws ListenerException
IListener.close()
is called.ListenerException
RawMessageWrapper<M> getRawMessage(@Nonnull Map<String,Object> threadContext) throws ListenerException
synchronized
.
Any thread-specific properties should be stored in and retrieved from the threadContext.
ListenerException
Copyright © 2023 Frank!Framework. All rights reserved.