Package org.objectweb.joram.mom.dest.amqp

Class AmqpAcquisition.ConnectionUpdater

java.lang.Object

fr.dyade.aaa.common.Daemon

org.objectweb.joram.mom.dest.amqp.AmqpAcquisition.ConnectionUpdater

All Implemented Interfaces:

Runnable

Enclosing class:

AmqpAcquisition

private static class AmqpAcquisition.ConnectionUpdater
extends Daemon

Daemon used to periodically update the pool of connections known by the acquisition destinations.

Field Summary

Fields

Modifier and Type	Field	Description
private List<AmqpAcquisition>	listeners
private long	period

Fields inherited from class fr.dyade.aaa.common.Daemon

canStop, group, logmon, priority, running, thread

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConnectionUpdater(long updatePeriod)	Constructs a ConnectionUpdater thread.

Method Summary

Modifier and Type	Method	Description
protected void	addUpdateListener(AmqpAcquisition listener)
void	close()	Releases the daemon's resources.
protected void	removeUpdateListener(AmqpAcquisition listener)
void	run()	The daemon's loop.
void	shutdown()	Shuts the daemon down.

Methods inherited from class fr.dyade.aaa.common.Daemon

finish, getName, interrupt, isCurrentThread, isRunning, setDaemon, setName, setPriority, setThreadGroup, start, stop, toString

Methods inherited from class java.lang.Object

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

Field Detail

listeners

private List<AmqpAcquisition> listeners

period

private long period

Constructor Detail

ConnectionUpdater

protected ConnectionUpdater(long updatePeriod)

Constructs a ConnectionUpdater thread.

Method Detail

run

public void run()

The daemon's loop.

shutdown

public void shutdown()

Shuts the daemon down.

Specified by:

shutdown in class Daemon

close

public void close()

Releases the daemon's resources.

Specified by:

close in class Daemon

addUpdateListener

protected void addUpdateListener(AmqpAcquisition listener)

removeUpdateListener

protected void removeUpdateListener(AmqpAcquisition listener)