Modifier and Type | Class and Description |
---|---|
(package private) class |
DistributionDaemon.ComparatorMessage |
(package private) class |
DistributionDaemon.ComparatorString |
Modifier and Type | Field and Description |
---|---|
private String |
acklistTxName |
private Queue |
ackQueue |
private Destination |
dest |
private Queue |
distributeQueue |
private DistributionHandler |
distributionHandler
Holds the distribution logic.
|
static org.objectweb.util.monolog.api.Logger |
logger |
Constructor and Description |
---|
DistributionDaemon(DistributionHandler distributionHandler,
String destinationId,
String destinationName,
Destination dest) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
ackMessage(String id) |
void |
cleanAckList() |
protected void |
close()
Releases any resources attached to this daemon.
|
String |
getNextAck() |
private void |
incDeliveryCount(Message message)
Increments the message delivery count.
|
boolean |
isEmpty() |
(package private) boolean |
isHandling(String id) |
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
public static org.objectweb.util.monolog.api.Logger logger
private DistributionHandler distributionHandler
private Queue distributeQueue
private Queue ackQueue
private Destination dest
private String acklistTxName
public DistributionDaemon(DistributionHandler distributionHandler, String destinationId, String destinationName, Destination dest)
boolean isHandling(String id)
void ackMessage(String id)
public void run()
protected void shutdown()
Daemon
protected void close()
Daemon
public void push(Message msg)
public String getNextAck()
public void cleanAckList()
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 © 2015 ScalAgent D.T.. All Rights Reserved.