Package org.wso2.carbon.inbound.endpoint.protocol.jms

Class JMSPollingConsumer

java.lang.Object

org.wso2.carbon.inbound.endpoint.protocol.jms.JMSPollingConsumer

public class JMSPollingConsumer
extends Object

Constructor Summary

Constructors

Constructor	Description
JMSPollingConsumer(Properties jmsProperties, long scanInterval, String name)

Method Summary

Modifier and Type	Method	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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JMSPollingConsumer

public JMSPollingConsumer(Properties jmsProperties,
 long scanInterval,
 String name)

Method Details

registerHandler

public void registerHandler(JMSInjectHandler injectHandler)

Register a handler to implement injection of the retrieved message

Parameters:

injectHandler -

execute

public void execute()

This will be called by the task scheduler. If a cycle execution takes more than the schedule interval, tasks will call this method ignoring the interval. Timestamp based check is done to avoid that.

poll

public javax.jms.Message poll()

Create connection with broker and retrieve the messages. Then inject according to the registered handler

destroy

public void destroy()

getInboundProperites

protected Properties getInboundProperites()