public final class HazelcastClientProxy extends Object implements HazelcastInstance
HazelcastInstance
instance.Modifier and Type | Field and Description |
---|---|
HazelcastClientInstanceImpl |
client |
Constructor and Description |
---|
HazelcastClientProxy(HazelcastClientInstanceImpl client) |
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 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 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.
|
ClientConfig |
getClientConfig() |
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,
Object id)
Deprecated.
|
<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.
|
Client |
getLocalEndpoint()
Returns the local Endpoint which this HazelcastInstance is belongs to.
|
ILock |
getLock(Object key) |
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.
|
<K,V> ReplicatedMap<K,V> |
getReplicatedMap(String name)
Returns the replicated map instance with the specified name.
|
ISemaphore |
getSemaphore(String name)
Creates cluster-wide semaphore.
|
SerializationService |
getSerializationService() |
<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.
|
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 |
toString() |
public volatile HazelcastClientInstanceImpl client
public HazelcastClientProxy(HazelcastClientInstanceImpl client)
public Config getConfig()
HazelcastInstance
getConfig
in interface HazelcastInstance
public String getName()
HazelcastInstance
getName
in interface HazelcastInstance
public <E> IQueue<E> getQueue(String name)
HazelcastInstance
getQueue
in interface HazelcastInstance
name
- name of the distributed queuepublic <E> ITopic<E> getTopic(String name)
HazelcastInstance
getTopic
in interface HazelcastInstance
name
- name of the distributed topicpublic <E> ISet<E> getSet(String name)
HazelcastInstance
getSet
in interface HazelcastInstance
name
- name of the distributed setpublic <E> IList<E> getList(String name)
HazelcastInstance
getList
in interface HazelcastInstance
name
- name of the distributed listpublic <K,V> IMap<K,V> getMap(String name)
HazelcastInstance
getMap
in interface HazelcastInstance
name
- name of the distributed mappublic <K,V> MultiMap<K,V> getMultiMap(String name)
HazelcastInstance
getMultiMap
in interface HazelcastInstance
name
- name of the distributed multimappublic <K,V> ReplicatedMap<K,V> getReplicatedMap(String name)
HazelcastInstance
getReplicatedMap
in interface HazelcastInstance
name
- name of the distributed mappublic JobTracker getJobTracker(String name)
HazelcastInstance
getJobTracker
in interface HazelcastInstance
name
- name of the job trackerpublic ILock getLock(Object key)
getLock
in interface HazelcastInstance
public ILock getLock(String key)
HazelcastInstance
Lock lock = hazelcastInstance.getLock("PROCESS_LOCK"); lock.lock(); try { // process } finally { lock.unlock(); }
getLock
in interface HazelcastInstance
key
- key of the lock instancepublic Cluster getCluster()
HazelcastInstance
getCluster
in interface HazelcastInstance
public Client getLocalEndpoint()
HazelcastInstance
Member
instance for cluster nodes
and a Client
instance for clients.getLocalEndpoint
in interface HazelcastInstance
Member
,
Client
public IExecutorService getExecutorService(String name)
HazelcastInstance
Note: Note that it don't support invokeAll/Any and don't have standard shutdown behavior
getExecutorService
in interface HazelcastInstance
name
- name of the executor servicepublic <T> T executeTransaction(TransactionalTask<T> task) throws TransactionException
HazelcastInstance
executeTransaction
in interface HazelcastInstance
T
- return type of tasktask
- task to be executedTransactionException
- if an error occurs during transaction.public <T> T executeTransaction(TransactionOptions options, TransactionalTask<T> task) throws TransactionException
HazelcastInstance
executeTransaction
in interface HazelcastInstance
T
- return type of taskoptions
- options for this transactional tasktask
- task to be executedTransactionException
- if an error occurs during transaction.public TransactionContext newTransactionContext()
HazelcastInstance
newTransactionContext
in interface HazelcastInstance
public TransactionContext newTransactionContext(TransactionOptions options)
HazelcastInstance
newTransactionContext
in interface HazelcastInstance
options
- options for this transactionpublic IdGenerator getIdGenerator(String name)
HazelcastInstance
getIdGenerator
in interface HazelcastInstance
name
- name of the IdGeneratorpublic IAtomicLong getAtomicLong(String name)
HazelcastInstance
getAtomicLong
in interface HazelcastInstance
name
- name of the IAtomicLong proxypublic <E> IAtomicReference<E> getAtomicReference(String name)
HazelcastInstance
getAtomicReference
in interface HazelcastInstance
name
- name of the IAtomicReference proxypublic ICountDownLatch getCountDownLatch(String name)
HazelcastInstance
getCountDownLatch
in interface HazelcastInstance
name
- name of the ICountDownLatch proxypublic ISemaphore getSemaphore(String name)
HazelcastInstance
getSemaphore
in interface HazelcastInstance
name
- name of the ISemaphore proxypublic Collection<DistributedObject> getDistributedObjects()
HazelcastInstance
DistributedObject
's such as; queue, map, set, list, topic, lock, multimap.getDistributedObjects
in interface HazelcastInstance
public String addDistributedObjectListener(DistributedObjectListener distributedObjectListener)
HazelcastInstance
DistributedObject
will be created or destroyed.addDistributedObjectListener
in interface HazelcastInstance
distributedObjectListener
- instance listenerpublic boolean removeDistributedObjectListener(String registrationId)
HazelcastInstance
removeDistributedObjectListener
in interface HazelcastInstance
registrationId
- Id of listener registration.public PartitionService getPartitionService()
HazelcastInstance
getPartitionService
in interface HazelcastInstance
public ClientService getClientService()
HazelcastInstance
getClientService
in interface HazelcastInstance
public LoggingService getLoggingService()
HazelcastInstance
getLoggingService
in interface HazelcastInstance
public LifecycleService getLifecycleService()
HazelcastInstance
getLifecycleService
in interface HazelcastInstance
@Deprecated public <T extends DistributedObject> T getDistributedObject(String serviceName, Object id)
getDistributedObject
in interface HazelcastInstance
T
- type of the DistributedObjectserviceName
- name of the serviceid
- identifier of the objectpublic <T extends DistributedObject> T getDistributedObject(String serviceName, String name)
getDistributedObject
in interface HazelcastInstance
T
- type of the DistributedObjectserviceName
- name of the servicename
- name of the objectpublic ConcurrentMap<String,Object> getUserContext()
HazelcastInstance
getUserContext
in interface HazelcastInstance
public ClientConfig getClientConfig()
public void shutdown()
HazelcastInstance
LifecycleService.shutdown()
.shutdown
in interface HazelcastInstance
public SerializationService getSerializationService()
Copyright © 2014 Hazelcast, Inc.. All Rights Reserved.