Package org.objectweb.joram.mom.dest

Class QueueDeliveryTable

java.lang.Object

org.objectweb.joram.mom.dest.QueueDeliveryTable

All Implemented Interfaces:

Encodable, Serializable

public class QueueDeliveryTable
extends Object
implements Encodable, Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	QueueDeliveryTable.Factory

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
private HashMap<String,QueueDelivery>	deliveries
private static Logger	logger
private boolean	modified
private static long	serialVersionUID	define serialVersionUID for interoperability, fix with 5.15.0 value
private String	txName

Fields inherited from interface fr.dyade.aaa.common.encoding.Encodable

BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE

Constructor Summary

Constructors

Constructor	Description
QueueDeliveryTable()
QueueDeliveryTable(String txName)

Method Summary

Modifier and Type	Method	Description
private void	checkModified(QueueDelivery delivery)
void	decode(Decoder decoder)	Decodes the content of this object
void	delete()
void	encode(Encoder encoder)	Do not encode the transient messages.
QueueDelivery	get(String msgId)
int	getEncodableClassId()	Returns a unique class identifier.
int	getEncodedSize()	Returns the size of the byte array that results from the encoding of this object.
String[]	getMessageIds()	Return an array containing the message identifier of all deliveries in table.
static QueueDeliveryTable	load(String txName)
void	put(String msgId, QueueDelivery delivery)
QueueDelivery	remove(String msgId)
void	save()
int	size()

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

define serialVersionUID for interoperability, fix with 5.15.0 value

See Also:

Constant Field Values

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

txName

private transient String txName

deliveries

private HashMap<String,QueueDelivery> deliveries

modified

private boolean modified

Constructor Detail

QueueDeliveryTable

public QueueDeliveryTable()

QueueDeliveryTable

public QueueDeliveryTable(String txName)

Method Detail

load

public static QueueDeliveryTable load(String txName)
                               throws Exception

Throws:

Exception

getMessageIds

public String[] getMessageIds()

Return an array containing the message identifier of all deliveries in table.

Returns:

an array containing the message identifier of all deliveries in table.

get

public QueueDelivery get(String msgId)

checkModified

private void checkModified(QueueDelivery delivery)

remove

public QueueDelivery remove(String msgId)

put

public void put(String msgId,
                QueueDelivery delivery)

size

public int size()

save

public void save()
          throws IOException

Throws:

IOException

delete

public void delete()

getEncodableClassId

public int getEncodableClassId()

Description copied from interface: Encodable

Returns a unique class identifier.

Specified by:

getEncodableClassId in interface Encodable

Returns:

a unique class identifier

getEncodedSize

public int getEncodedSize()
                   throws Exception

Description copied from interface: Encodable

Returns the size of the byte array that results from the encoding of this object.

Specified by:

getEncodedSize in interface Encodable

Returns:

the size of the encoded byte array

Throws:

Exception - if an error occurs

encode

public void encode(Encoder encoder)
            throws Exception

Do not encode the transient messages.

Specified by:

encode in interface Encodable

Parameters:

encoder - the encoder to be used for the encoding

Throws:

Exception - if an error occurs

decode

public void decode(Decoder decoder)
            throws Exception

Description copied from interface: Encodable

Decodes the content of this object

Specified by:

decode in interface Encodable

Parameters:

decoder - the decoder to be used for the decoding

Throws:

Exception - if an error occurs