org.seedstack.jms.pollers

Class SimpleMessagePoller

java.lang.Object

org.seedstack.jms.pollers.SimpleMessagePoller

All Implemented Interfaces:

Runnable, MessagePoller

public class SimpleMessagePoller
extends Object
implements MessagePoller, Runnable

MessagePoller implementing a simple polling strategy that waits at most 30 seconds using MessageConsumer.receive(long) and then loop over. When a message is received, the MessageListener is invoked and the session is committed. If an exception occurs the session is rollbacked, the ExceptionListener is invoked if any, the polling thread is shutdown and scheduled for restart in 10 seconds.

Constructor Summary

Constructors

Constructor and Description
SimpleMessagePoller()

Method Summary

Modifier and Type	Method and Description
void	run()
void	setExceptionListener(javax.jms.ExceptionListener exceptionListener)
void	setMessageConsumer(javax.jms.MessageConsumer messageConsumer)
void	setMessageListener(javax.jms.MessageListener messageListener)
void	setSession(javax.jms.Session session)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleMessagePoller

public SimpleMessagePoller()

Method Detail

setSession

public void setSession(javax.jms.Session session)

Specified by:

setSession in interface MessagePoller

setMessageConsumer

public void setMessageConsumer(javax.jms.MessageConsumer messageConsumer)

Specified by:

setMessageConsumer in interface MessagePoller

setExceptionListener

public void setExceptionListener(javax.jms.ExceptionListener exceptionListener)

Specified by:

setExceptionListener in interface MessagePoller

setMessageListener

public void setMessageListener(javax.jms.MessageListener messageListener)

Specified by:

setMessageListener in interface MessagePoller

start

public void start()

Specified by:

start in interface MessagePoller

stop

public void stop()

Specified by:

stop in interface MessagePoller

run

public void run()

Specified by:

run in interface Runnable