Package io.goobi.viewer.controller.mq

Class DefaultQueueListener

java.lang.Object

io.goobi.viewer.controller.mq.DefaultQueueListener

public class DefaultQueueListener
extends Object

Constructor Summary

Constructors

Constructor	Description
DefaultQueueListener(MessageQueueManager messageBroker, String queueType)

Method Summary

Modifier and Type	Method	Description
void	close()
LocalDateTime	getLastLoopCircle()
String	getQueueType()
void	interruptTask()
boolean	isShouldStop()
void	register()
void	restartLoop()

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultQueueListener

public DefaultQueueListener(MessageQueueManager messageBroker,
 String queueType)

Parameters:

messageBroker -

queueType -

Method Details

register

public void register()
              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

isShouldStop

public boolean isShouldStop()

getLastLoopCircle

public LocalDateTime getLastLoopCircle()

restartLoop

public void restartLoop()
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getQueueType

public String getQueueType()

interruptTask

public void interruptTask()

close

public void close()