public class QueueDeliveryTable extends Object implements Encodable, Serializable
Modifier and Type | Class and Description |
---|---|
(package private) class |
QueueDeliveryTable.DeliveryIterator |
static class |
QueueDeliveryTable.Factory |
Modifier and Type | Field and Description |
---|---|
private HashMap<String,QueueDelivery> |
deliveries |
static org.objectweb.util.monolog.api.Logger |
logger |
private boolean |
modified |
private String |
txName |
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
Constructor and Description |
---|
QueueDeliveryTable() |
QueueDeliveryTable(String txName) |
Modifier and Type | Method and 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.
|
Iterator<Map.Entry<String,QueueDelivery>> |
iterator() |
static QueueDeliveryTable |
load(String txName) |
void |
put(String msgId,
QueueDelivery delivery) |
QueueDelivery |
remove(String msgId) |
void |
save() |
int |
size() |
public static org.objectweb.util.monolog.api.Logger logger
private transient String txName
private HashMap<String,QueueDelivery> deliveries
private boolean modified
public QueueDeliveryTable()
public QueueDeliveryTable(String txName)
public static QueueDeliveryTable load(String txName) throws Exception
Exception
public QueueDelivery get(String msgId)
private void checkModified(QueueDelivery delivery)
public QueueDelivery remove(String msgId)
public void put(String msgId, QueueDelivery delivery)
public int size()
public Iterator<Map.Entry<String,QueueDelivery>> iterator()
public void save() throws IOException
IOException
public void delete()
public int getEncodableClassId()
Encodable
getEncodableClassId
in interface Encodable
public int getEncodedSize() throws Exception
Encodable
getEncodedSize
in interface Encodable
Exception
- if an error occursCopyright © 2018 ScalAgent D.T.. All Rights Reserved.