private static class AmqpAcquisition.ConnectionUpdater extends Daemon
Modifier and Type | Field and Description |
---|---|
private List<AmqpAcquisition> |
listeners |
private long |
period |
Modifier | Constructor and Description |
---|---|
protected |
AmqpAcquisition.ConnectionUpdater(long updatePeriod)
Constructs a
ConnectionUpdater thread. |
Modifier and Type | Method and 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.
|
finish, getName, interrupt, isCurrentThread, isRunning, setDaemon, setName, setPriority, setThreadGroup, start, stop, toString
private List<AmqpAcquisition> listeners
private long period
protected AmqpAcquisition.ConnectionUpdater(long updatePeriod)
ConnectionUpdater
thread.public void run()
protected void addUpdateListener(AmqpAcquisition listener)
protected void removeUpdateListener(AmqpAcquisition listener)
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.