com.hazelcast.impl

Class TransactionImpl

java.lang.Object

com.hazelcast.impl.TransactionImpl

All Implemented Interfaces:

Transaction

public class TransactionImpl
extends Object
implements Transaction

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_TXN_TIMEOUT

Fields inherited from interface com.hazelcast.core.Transaction

TXN_STATUS_ACTIVE, TXN_STATUS_COMMITTED, TXN_STATUS_COMMITTING, TXN_STATUS_NO_TXN, TXN_STATUS_PREPARED, TXN_STATUS_PREPARING, TXN_STATUS_ROLLED_BACK, TXN_STATUS_ROLLING_BACK, TXN_STATUS_UNKNOWN

Constructor Summary

Constructors

Constructor and Description
TransactionImpl(FactoryImpl factory, long txnId)

Method Summary

Methods

Modifier and Type	Method and Description
void	attachGetOp(String name, Object key, Data value)
void	attachPutMultiOp(String name, Object key, Data value)
Data	attachPutOp(String name, Object key, Data value, boolean newRecord)
Data	attachPutOp(String name, Object key, Data value, int timeout, long ttl, boolean newRecord)
Data	attachPutOp(String name, Object key, Data value, long timeout, boolean newRecord, int index)
Data	attachPutOp(String name, Object key, Data value, long timeout, long ttl, boolean newRecord, int index)
Data	attachRemoveOp(String name, Object key, Data value, boolean newRecord)
Data	attachRemoveOp(String name, Object key, Data value, boolean newRecord, int valueCount)
void	begin() Creates a new transaction and associate it with the current thread.
void	commit() Commits the transaction associated with the current thread.
boolean	containsEntry(String name, Object key, Object value)
boolean	containsValue(String name, Object value)
Data	get(String name, Object key)
long	getId()
void	getMulti(String name, Object key, Collection col)
int	getStatus() Returns the status of the transaction associated with the current thread.
boolean	has(String name, Object key)
boolean	has(String name, Object key, Object value)
boolean	isNew(String name, Object key)
boolean	isRemoved(String name, Object key)
List<Map.Entry>	newEntries(String name)
Map	newKeys(String name)
void	rollback() Rolls back the transaction associated with the current thread.
int	size(String name)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_TXN_TIMEOUT

public static final long DEFAULT_TXN_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

TransactionImpl

public TransactionImpl(FactoryImpl factory,
               long txnId)

Method Detail

attachPutOp

public Data attachPutOp(String name,
               Object key,
               Data value,
               boolean newRecord)

attachPutMultiOp

public void attachPutMultiOp(String name,
                    Object key,
                    Data value)

attachPutOp

public Data attachPutOp(String name,
               Object key,
               Data value,
               int timeout,
               long ttl,
               boolean newRecord)

attachPutOp

public Data attachPutOp(String name,
               Object key,
               Data value,
               long timeout,
               boolean newRecord,
               int index)

attachPutOp

public Data attachPutOp(String name,
               Object key,
               Data value,
               long timeout,
               long ttl,
               boolean newRecord,
               int index)

attachGetOp

public void attachGetOp(String name,
               Object key,
               Data value)

attachRemoveOp

public Data attachRemoveOp(String name,
                  Object key,
                  Data value,
                  boolean newRecord)

attachRemoveOp

public Data attachRemoveOp(String name,
                  Object key,
                  Data value,
                  boolean newRecord,
                  int valueCount)

begin

public void begin()
           throws IllegalStateException

Description copied from interface: Transaction

Creates a new transaction and associate it with the current thread.

Specified by:

begin in interface Transaction

Throws:

IllegalStateException - if transaction is already began

commit

public void commit()
            throws IllegalStateException

Description copied from interface: Transaction

Commits the transaction associated with the current thread.

Specified by:

commit in interface Transaction

Throws:

IllegalStateException - if transaction didn't begin.

rollback

public void rollback()
              throws IllegalStateException

Description copied from interface: Transaction

Rolls back the transaction associated with the current thread.

Specified by:

rollback in interface Transaction

Throws:

IllegalStateException - if transaction didn't begin.

containsValue

public boolean containsValue(String name,
                    Object value)

containsEntry

public boolean containsEntry(String name,
                    Object key,
                    Object value)

get

public Data get(String name,
       Object key)

getId

public long getId()

getStatus

public int getStatus()

Description copied from interface: Transaction

Returns the status of the transaction associated with the current thread.

Specified by:

getStatus in interface Transaction

Returns:

the status

has

public boolean has(String name,
          Object key)

has

public boolean has(String name,
          Object key,
          Object value)

isNew

public boolean isNew(String name,
            Object key)

isRemoved

public boolean isRemoved(String name,
                Object key)

size

public int size(String name)

newEntries

public List<Map.Entry> newEntries(String name)

getMulti

public void getMulti(String name,
            Object key,
            Collection col)

newKeys

public Map newKeys(String name)

toString

public String toString()

Overrides:

toString in class Object