com.hazelcast.collection.impl.txnqueue

Class TxQueueItem

java.lang.Object

com.hazelcast.collection.impl.queue.QueueItem

com.hazelcast.collection.impl.txnqueue.TxQueueItem

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable, Comparable<QueueItem>

public class TxQueueItem
extends QueueItem

Transactional Queue Item.

Field Summary

Fields inherited from class com.hazelcast.collection.impl.queue.QueueItem

container, creationTime, data, itemId

Constructor Summary

Constructors

Constructor and Description
TxQueueItem()
TxQueueItem(QueueContainer container, long itemId, Data data)
TxQueueItem(QueueItem item)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	getId() Returns type identifier for this class.
String	getTransactionId()
int	hashCode()
boolean	isPollOperation()
void	readData(ObjectDataInput in) Reads fields from the input stream
TxQueueItem	setPollOperation(boolean pollOperation)
TxQueueItem	setTransactionId(String transactionId)
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class com.hazelcast.collection.impl.queue.QueueItem

compareTo, getContainer, getCreationTime, getData, getFactoryId, getItemId, setData, setItemId

Methods inherited from class java.lang.Object

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

Constructor Detail

TxQueueItem

public TxQueueItem()

TxQueueItem

public TxQueueItem(QueueItem item)

TxQueueItem

public TxQueueItem(QueueContainer container,
                   long itemId,
                   Data data)

Method Detail

getTransactionId

public String getTransactionId()

setTransactionId

public TxQueueItem setTransactionId(String transactionId)

isPollOperation

public boolean isPollOperation()

setPollOperation

public TxQueueItem setPollOperation(boolean pollOperation)

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Overrides:

writeData in class QueueItem

Parameters:

out - output

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Overrides:

readData in class QueueItem

Parameters:

in - input

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the input stream has been closed.

getId

public int getId()

Description copied from interface: IdentifiedDataSerializable

Returns type identifier for this class. It should be unique per DataSerializableFactory.

Specified by:

getId in interface IdentifiedDataSerializable

Overrides:

getId in class QueueItem

Returns:

type ID

equals

public boolean equals(Object o)

Overrides:

equals in class QueueItem

hashCode

public int hashCode()

Overrides:

hashCode in class QueueItem