public class JMSPollingConsumer extends Object
Constructor and Description |
---|
JMSPollingConsumer(Properties jmsProperties,
long scanInterval,
String name) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
void |
execute()
This will be called by the task scheduler.
|
protected Properties |
getInboundProperites() |
javax.jms.Message |
poll()
Create connection with broker and retrieve the messages.
|
void |
registerHandler(JMSInjectHandler injectHandler)
Register a handler to implement injection of the retrieved message
|
public JMSPollingConsumer(Properties jmsProperties, long scanInterval, String name)
public void registerHandler(JMSInjectHandler injectHandler)
injectHandler
- public void execute()
public javax.jms.Message poll()
public void destroy()
protected Properties getInboundProperites()
Copyright © 2022 WSO2. All rights reserved.