K - type of the map keyV - type of the map valuepublic interface TransactionalMap<K,V> extends TransactionalObject, BaseMap<K,V>
BaseMap.
HazelcastInstance client = HazelcastClient.newHazelcastClient();
UserTransactionManager tm = new UserTransactionManager();
tm.setTransactionTimeout(60);
tm.begin();
HazelcastXAResource xaResource = client.getXAResource();
Transaction transaction = tm.getTransaction();
transaction.enlistResource(xaResource);
// you can enlist more resources here like a database XAResource
try {
TransactionContext context = xaResource.getTransactionContext()
TransactionalMap map = context.getMap("map");
map.put("key", "value");
final TransactionalQueue queue = context.getQueue("queue");
queue.offer("item");
// you can do other resource operations like store/delete to a database
transaction.delistResource(xaResource, XAResource.TMSUCCESS);
tm.commit();
} catch (TransactionException t) {
t.printStackTrace();
transaction.delistResource(xaResource, XAResource.TMFAIL);
tm.rollback();
}
| Modifier and Type | Method and Description |
|---|---|
boolean |
containsKey(Object key)
Transactional implementation of
IMap.containsKey(Object). |
void |
delete(Object key)
Transactional implementation of
IMap.delete(Object). |
V |
get(Object key)
Transactional implementation of
IMap.get(Object). |
V |
getForUpdate(Object key)
Locks the key and then gets and returns the value to which the specified
key is mapped.
|
boolean |
isEmpty()
Transactional implementation of
Map.isEmpty(). |
Set<K> |
keySet()
Transactional implementation of
IMap.keySet(). |
Set<K> |
keySet(Predicate predicate)
Transactional implementation of
IMap.keySet(com.hazelcast.query.Predicate). |
V |
put(K key,
V value)
Transactional implementation of
IMap.put(Object, Object). |
V |
put(K key,
V value,
long ttl,
TimeUnit timeunit)
Transactional implementation of
IMap.put(Object, Object, long, TimeUnit). |
V |
putIfAbsent(K key,
V value)
Transactional implementation of
IMap.putIfAbsent(Object, Object). |
V |
remove(Object key)
Transactional implementation of
IMap.remove(Object). |
boolean |
remove(Object key,
Object value)
Transactional implementation of
IMap.remove(Object, Object). |
V |
replace(K key,
V value)
Transactional implementation of
IMap.replace(Object, Object). |
boolean |
replace(K key,
V oldValue,
V newValue)
Transactional implementation of
IMap.replace(Object, Object, Object). |
void |
set(K key,
V value)
Transactional implementation of
IMap.set(Object, Object). |
int |
size()
Transactional implementation of
Map.size(). |
Collection<V> |
values()
Transactional implementation of
IMap.values(). |
Collection<V> |
values(Predicate predicate)
Transactional implementation of
IMap.values(com.hazelcast.query.Predicate). |
destroy, getName, getPartitionKey, getServiceNameboolean containsKey(Object key)
IMap.containsKey(Object).containsKey in interface BaseMap<K,V>key - The specified key.true if this map contains an entry for the specified key.NullPointerException - if the specified key is nullIMap.containsKey(Object)V get(Object key)
IMap.get(Object).get in interface BaseMap<K,V>key - The specified key.NullPointerException - if the specified key is nullIMap.get(Object)V getForUpdate(Object key)
NullPointerException - if the specified key is nullTransactionTimedOutException - if the key could not be locked for update in the transaction timeoutIMap.get(Object)int size()
Map.size().size in interface BaseMap<K,V>Map.size()boolean isEmpty()
Map.isEmpty().isEmpty in interface BaseMap<K,V>Map.isEmpty()V put(K key, V value)
IMap.put(Object, Object).
The object to be put will be accessible only in the current transaction context till transaction is committed.
put in interface BaseMap<K,V>key - The specified key.value - The value to associate with the key.key or null
if there was no mapping for key.NullPointerException - if the specified key or value is nullTransactionTimedOutException - if the key could not be locked for update in the transaction timeoutIMap.put(Object, Object)V put(K key, V value, long ttl, TimeUnit timeunit)
IMap.put(Object, Object, long, TimeUnit).
The object to be put will be accessible only in the current transaction context till transaction is committed.
put in interface BaseMap<K,V>key - The specified key.value - The value to associate with the key.ttl - maximum time for this entry to stay in the map
0 means infinite.timeunit - time unit for the ttlkey or null
if there was no mapping for key.NullPointerException - if the specified key, value or timeunit is nullTransactionTimedOutException - if the key could not be locked for update in the transaction timeoutIMap.put(Object, Object, long, TimeUnit)void set(K key, V value)
IMap.set(Object, Object).
The object to be set will be accessible only in the current transaction context till transaction is committed.
set in interface BaseMap<K,V>key - The specified key.value - The value to associate with the key.NullPointerException - if the specified key or value is nullTransactionTimedOutException - if the key could not be locked for update in the transaction timeoutIMap.set(Object, Object)V putIfAbsent(K key, V value)
IMap.putIfAbsent(Object, Object).
The object to be put will be accessible only in the current transaction context until the transaction is committed.
putIfAbsent in interface BaseMap<K,V>key - The specified key.value - The value to associate with the key when there is no previous value.key, or null
if there was no mapping for key.NullPointerException - if the specified key or value is nullTransactionTimedOutException - if the key could not be locked for update in the transaction timeoutIMap.putIfAbsent(Object, Object)V replace(K key, V value)
IMap.replace(Object, Object).
The object to be replaced will be accessible only in the current transaction context until the transaction is committed.
replace in interface BaseMap<K,V>key - The specified key.value - The value to replace the previous value.key, or null
if there was no mapping for key.NullPointerException - if the specified key or nullTransactionTimedOutException - if the key could not be locked for update in the transaction timeoutIMap.replace(Object, Object)boolean replace(K key, V oldValue, V newValue)
IMap.replace(Object, Object, Object).
The object to be replaced will be accessible only in the current transaction context until the transaction is committed.
replace in interface BaseMap<K,V>key - The specified key.oldValue - Replace the key value if it is the old value.newValue - The new value to replace the old value.true if the value was replaced.NullPointerException - if the specified key, oldValue or newValue is nullTransactionTimedOutException - if the key could not be locked for update in the transaction timeoutIMap.replace(Object, Object, Object)V remove(Object key)
IMap.remove(Object).
The object to be removed will be removed from only the current transaction context until the transaction is committed.
remove in interface BaseMap<K,V>key - Remove the mapping for this key.key, or null
if there was no mapping for key.NullPointerException - if the specified key is nullTransactionTimedOutException - if the key could not be locked for update in the transaction timeoutIMap.remove(Object)void delete(Object key)
IMap.delete(Object).
The object to be deleted will be removed from only the current transaction context until the transaction is committed.
delete in interface BaseMap<K,V>key - Remove the mapping for this key.NullPointerException - if the specified key is nullTransactionTimedOutException - if the key could not be locked for update in the transaction timeoutIMap.delete(Object)boolean remove(Object key, Object value)
IMap.remove(Object, Object).
The object to be removed will be removed from only the current transaction context until the transaction is committed.
remove in interface BaseMap<K,V>key - The specified key.value - Remove the key if it has this value.true if the value was removed.NullPointerException - if the specified key or value nullTransactionTimedOutException - if the key could not be locked for update in the transaction timeoutIMap.remove(Object, Object)Set<K> keySet()
IMap.keySet().keySet in interface BaseMap<K,V>IMap.keySet()Set<K> keySet(Predicate predicate)
IMap.keySet(com.hazelcast.query.Predicate).keySet in interface BaseMap<K,V>predicate - specified query criteria.NullPointerException - if the specified predicate is nullIMap.keySet(com.hazelcast.query.Predicate)Collection<V> values()
IMap.values().values in interface BaseMap<K,V>IMap.values()Collection<V> values(Predicate predicate)
IMap.values(com.hazelcast.query.Predicate).values in interface BaseMap<K,V>predicate - specified query criteria.NullPointerException - if the specified predicate is nullIMap.values(com.hazelcast.query.Predicate)Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.