Modifier and Type | Field and Description |
---|---|
private Queue |
ackQueue |
private Queue |
distributeQueue |
private DistributionHandler |
distributionHandler
Holds the distribution logic.
|
static org.objectweb.util.monolog.api.Logger |
logger |
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
private TxDestination |
txDest |
Constructor and Description |
---|
DistributionDaemon(DistributionHandler distributionHandler,
String destinationName,
TxDestination txDest) |
Modifier and Type | Method and Description |
---|---|
protected void |
close()
Releases any resources attached to this daemon.
|
List |
getAckList() |
private void |
incDeliveryCount(Message message)
Increments the message delivery count.
|
boolean |
isEmpty() |
private boolean |
isUndeliverable(Message message) |
private boolean |
isValid(Message message)
Returns
true if the message is valid. |
void |
push(Message msg) |
void |
run() |
protected void |
shutdown()
Interrupts a thread that waits for long periods.
|
finish, getName, interrupt, isCurrentThread, isRunning, setDaemon, setName, setPriority, setThreadGroup, start, stop, toString
private static final long serialVersionUID
public static org.objectweb.util.monolog.api.Logger logger
private DistributionHandler distributionHandler
private Queue distributeQueue
private Queue ackQueue
private TxDestination txDest
public DistributionDaemon(DistributionHandler distributionHandler, String destinationName, TxDestination txDest)
public void run()
protected void shutdown()
Daemon
protected void close()
Daemon
public void push(Message msg)
public List getAckList()
public boolean isEmpty()
private boolean isUndeliverable(Message message)
private boolean isValid(Message message)
true
if the message is valid.
The message is valid if not expired.private void incDeliveryCount(Message message)
Copyright © 2013 ScalAgent D.T.. All Rights Reserved.