Package org.objectweb.joram.mom.dest

Class DistributionDaemon

java.lang.Object

fr.dyade.aaa.common.Daemon

org.objectweb.joram.mom.dest.DistributionDaemon

All Implemented Interfaces:

Runnable

public class DistributionDaemon
extends Daemon

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	DistributionDaemon.ComparatorMessage
(package private) class	DistributionDaemon.ComparatorString

Field Summary

Fields

Modifier and Type	Field	Description
private String	acklistTxName
private Queue	ackQueue
private static boolean	DEBUG
private Destination	dest
private Queue	distributeQueue
private DistributionHandler	distributionHandler	Holds the distribution logic.
private static Logger	logger

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

canStop, group, logmon, priority, running, thread

Constructor Summary

Constructors

Constructor	Description
DistributionDaemon(DistributionHandler distributionHandler, String destinationId, String destinationName, Destination dest)

Method Summary

Modifier and Type	Method	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 fullMessage)	Be careful, the message must be completely loaded (body).
void	run()
protected void	shutdown()	Interrupts a thread that waits for long periods.

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

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

distributionHandler

private DistributionHandler distributionHandler

Holds the distribution logic.

distributeQueue

private Queue distributeQueue

ackQueue

private Queue ackQueue

dest

private Destination dest

acklistTxName

private String acklistTxName

Constructor Detail

DistributionDaemon

public DistributionDaemon(DistributionHandler distributionHandler,
                          String destinationId,
                          String destinationName,
                          Destination dest)

Method Detail

isHandling

boolean isHandling(String id)

ackMessage

void ackMessage(String id)

run

public void run()

shutdown

protected void shutdown()

Description copied from class: Daemon

Interrupts a thread that waits for long periods. In some cases, we must use application specific tricks. For example, if a thread is waiting on a known socket, we have to close the socket to cause the thread to return immediately. Unfortunately, there really isn't any technique that works in general.

Specified by:

shutdown in class Daemon

close

protected void close()

Description copied from class: Daemon

Releases any resources attached to this daemon. Be careful, its method should be called more than one time.

Specified by:

close in class Daemon

push

public void push(Message fullMessage)

Be careful, the message must be completely loaded (body).

Parameters:

fullMessage -

Throws:

Exception

getNextAck

public String getNextAck()

cleanAckList

public void cleanAckList()

isEmpty

public boolean isEmpty()

isUndeliverable

private boolean isUndeliverable(Message message)

isValid

private boolean isValid(Message message)

Returns true if the message is valid. The message is valid if not expired.

incDeliveryCount

private void incDeliveryCount(Message message)

Increments the message delivery count.