public interface HazelcastInstance
| Modifier and Type | Method and Description |
|---|---|
String |
addDistributedObjectListener(DistributedObjectListener distributedObjectListener)
Adds a Distributed Object listener which will be notified when a
new
DistributedObject will be created or destroyed. |
<T> T |
executeTransaction(TransactionalTask<T> task)
Executes the given transactional task in current thread using default options
and returns the result of the task.
|
<T> T |
executeTransaction(TransactionOptions options,
TransactionalTask<T> task)
Executes the given transactional task in current thread using given options
and returns the result of the task.
|
IAtomicLong |
getAtomicLong(String name)
Creates cluster-wide atomic long.
|
<E> IAtomicReference<E> |
getAtomicReference(String name)
Creates cluster-wide atomic reference.
|
ClientService |
getClientService()
Returns the client service of this Hazelcast instance.
|
Cluster |
getCluster()
Returns the Cluster that this Hazelcast instance is part of.
|
Config |
getConfig()
Returns the configuration of this Hazelcast instance.
|
ICountDownLatch |
getCountDownLatch(String name)
Creates cluster-wide CountDownLatch.
|
<T extends DistributedObject> |
getDistributedObject(String serviceName,
String name) |
Collection<DistributedObject> |
getDistributedObjects()
Returns all
DistributedObject's such as; queue, map, set, list, topic, lock, multimap. |
IExecutorService |
getExecutorService(String name)
Returns the distributed executor service for the given
name.
|
IdGenerator |
getIdGenerator(String name)
Creates cluster-wide unique IDs.
|
JobTracker |
getJobTracker(String name)
Returns the job tracker instance with the specified name.
|
LifecycleService |
getLifecycleService()
Returns the lifecycle service for this instance.
|
<E> IList<E> |
getList(String name)
Returns the distributed list instance with the specified name.
|
Endpoint |
getLocalEndpoint()
Returns the local Endpoint which this HazelcastInstance belongs to.
|
ILock |
getLock(String key)
Returns the distributed lock instance for the specified key object.
|
LoggingService |
getLoggingService()
Returns the logging service of this Hazelcast instance.
|
<K,V> IMap<K,V> |
getMap(String name)
Returns the distributed map instance with the specified name.
|
<K,V> MultiMap<K,V> |
getMultiMap(String name)
Returns the distributed multimap instance with the specified name.
|
String |
getName()
Returns the name of this Hazelcast instance
|
PartitionService |
getPartitionService()
Returns the partition service of this Hazelcast instance.
|
<E> IQueue<E> |
getQueue(String name)
Returns the distributed queue instance with the specified name.
|
QuorumService |
getQuorumService()
Returns the quorum service of this Hazelcast instance.
|
<E> ITopic<E> |
getReliableTopic(String name)
Returns the reliable ReliableTopic instance with the specified name.
|
<K,V> ReplicatedMap<K,V> |
getReplicatedMap(String name)
Returns the replicated map instance with the specified name.
|
<E> Ringbuffer<E> |
getRingbuffer(String name)
Returns the distributed Ringbuffer instance with the specified name.
|
ISemaphore |
getSemaphore(String name)
Creates cluster-wide semaphore.
|
<E> ISet<E> |
getSet(String name)
Returns the distributed set instance with the specified name.
|
<E> ITopic<E> |
getTopic(String name)
Returns the distributed topic instance with the specified name.
|
ConcurrentMap<String,Object> |
getUserContext()
Returns a ConcurrentMap that can be used to add user-context to the HazelcastInstance.
|
HazelcastXAResource |
getXAResource()
Gets xaResource which will participate in XATransaction.
|
TransactionContext |
newTransactionContext()
Creates a new TransactionContext associated with the current thread using default options.
|
TransactionContext |
newTransactionContext(TransactionOptions options)
Creates a new TransactionContext associated with the current thread with given options.
|
boolean |
removeDistributedObjectListener(String registrationId)
Removes the specified Distributed Object listener.
|
void |
shutdown()
Shuts down this HazelcastInstance.
|
String getName()
<E> IQueue<E> getQueue(String name)
name - name of the distributed queue<E> ITopic<E> getTopic(String name)
name - name of the distributed topic<E> ISet<E> getSet(String name)
name - name of the distributed set<E> IList<E> getList(String name)
name - name of the distributed list<K,V> IMap<K,V> getMap(String name)
name - name of the distributed map<K,V> ReplicatedMap<K,V> getReplicatedMap(String name)
name - name of the distributed mapReplicatedMapCantBeCreatedOnLiteMemberException - if it is called on a lite memberJobTracker getJobTracker(String name)
name - name of the job tracker<K,V> MultiMap<K,V> getMultiMap(String name)
name - name of the distributed multimapILock getLock(String key)
Lock lock = hazelcastInstance.getLock("PROCESS_LOCK");
lock.lock();
try {
// process
} finally {
lock.unlock();
}
key - key of the lock instance<E> Ringbuffer<E> getRingbuffer(String name)
name - name of the distributed Ringbuffer<E> ITopic<E> getReliableTopic(String name)
name - name of the reliable ITopicCluster getCluster()
Endpoint getLocalEndpoint()
IExecutorService getExecutorService(String name)
Note: Note that it don't support invokeAll/Any and don't have standard shutdown behavior
name - name of the executor service<T> T executeTransaction(TransactionalTask<T> task) throws TransactionException
T - return type of tasktask - the transactional task to be executedTransactionException - if an error occurs during transaction.<T> T executeTransaction(TransactionOptions options, TransactionalTask<T> task) throws TransactionException
T - return type of taskoptions - options for this transactional tasktask - task to be executedTransactionException - if an error occurs during transaction.TransactionContext newTransactionContext()
TransactionContext newTransactionContext(TransactionOptions options)
options - options for this transactionIdGenerator getIdGenerator(String name)
name - name of the IdGeneratorIAtomicLong getAtomicLong(String name)
IAtomicLong is distributed
implementation of java.util.concurrent.atomic.AtomicLong.name - name of the IAtomicLong proxy<E> IAtomicReference<E> getAtomicReference(String name)
IAtomicReference is distributed
implementation of java.util.concurrent.atomic.AtomicReference.name - name of the IAtomicReference proxyIAtomicReference proxy for the given nameICountDownLatch getCountDownLatch(String name)
ICountDownLatch is distributed
implementation of java.util.concurrent.CountDownLatch.name - name of the ICountDownLatch proxyICountDownLatch proxy for the given nameISemaphore getSemaphore(String name)
ISemaphore is distributed
implementation of java.util.concurrent.Semaphore.name - name of the ISemaphore proxyISemaphore proxy for the given nameCollection<DistributedObject> getDistributedObjects()
DistributedObject's such as; queue, map, set, list, topic, lock, multimap.String addDistributedObjectListener(DistributedObjectListener distributedObjectListener)
DistributedObject will be created or destroyed.distributedObjectListener - instance listenerboolean removeDistributedObjectListener(String registrationId)
registrationId - Id of listener registration.Config getConfig()
PartitionService getPartitionService()
QuorumService getQuorumService()
ClientService getClientService()
ClientService of this Hazelcast instance.LoggingService getLoggingService()
LifecycleService getLifecycleService()
<T extends DistributedObject> T getDistributedObject(String serviceName, String name)
T - type of the DistributedObjectserviceName - name of the servicename - name of the objectConcurrentMap<String,Object> getUserContext()
HazelcastInstanceAware interface when submitting a Runnable/Callable to
Hazelcast ExecutorService. By storing the dependencies in the user-context, they can be retrieved as soon
as you have a reference to the HazelcastInstance.
This structure is purely local and Hazelcast remains agnostic abouts its content.HazelcastXAResource getXAResource()
void shutdown()
LifecycleService.shutdown().Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.