HazelcastConnectionImpl (Hazelcast Root 3.6.5 API)

java.lang.Object
- com.hazelcast.jca.HazelcastConnectionImpl

All Implemented Interfaces:

HazelcastInstance, HazelcastConnection, javax.resource.cci.Connection
```
public class HazelcastConnectionImpl
extends Object
implements HazelcastConnection
```
Implementation class of HazelcastConnectionImpl

Constructor Summary

Constructors
Constructor and Description

HazelcastConnectionImpl(ManagedConnectionImpl managedConnectionImpl, Subject subject)

Constructors
Constructor and Description
`HazelcastConnectionImpl(ManagedConnectionImpl managedConnectionImpl, Subject subject)`

Method Summary

Methods
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.
`void`	`close()`
`javax.resource.cci.Interaction`	`createInteraction()`
`<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> T`	`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.
`HazelcastTransaction`	`getLocalTransaction()`
`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.
`javax.resource.cci.ConnectionMetaData`	`getMetaData()`
`<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.
`javax.resource.cci.ResultSetInfo`	`getResultSetInfo()`
`<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.
`<E> TransactionalList<E>`	`getTransactionalList(String name)`
`<K,V> TransactionalMap<K,V>`	`getTransactionalMap(String name)`
`<K,V> TransactionalMultiMap<K,V>`	`getTransactionalMultiMap(String name)`
`<E> TransactionalQueue<E>`	`getTransactionalQueue(String name)`
`<E> TransactionalSet<E>`	`getTransactionalSet(String 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`	`toString()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - HazelcastConnectionImpl
```
public HazelcastConnectionImpl(ManagedConnectionImpl managedConnectionImpl,
                       Subject subject)
```
- Method Detail
  - close
```
public void close()
           throws javax.resource.ResourceException
```
    Specified by:
    
    close in interface javax.resource.cci.Connection
    
    Throws:
    
    javax.resource.ResourceException
  - createInteraction
```
public javax.resource.cci.Interaction createInteraction()
                                                 throws javax.resource.ResourceException
```
    Specified by:
    
    createInteraction in interface javax.resource.cci.Connection
    
    Throws:
    
    javax.resource.ResourceException
  - getResultSetInfo
```
public javax.resource.cci.ResultSetInfo getResultSetInfo()
                                                  throws javax.resource.NotSupportedException
```
    Specified by:
    
    getResultSetInfo in interface javax.resource.cci.Connection
    
    Throws:
    
    javax.resource.NotSupportedException - as this is not supported by this resource adapter
  - getLocalTransaction
```
public HazelcastTransaction getLocalTransaction()
                                         throws javax.resource.ResourceException
```
    Specified by:
    
    getLocalTransaction in interface javax.resource.cci.Connection
    
    Throws:
    
    javax.resource.ResourceException
  - getMetaData
```
public javax.resource.cci.ConnectionMetaData getMetaData()
                                                  throws javax.resource.ResourceException
```
    Specified by:
    
    getMetaData in interface javax.resource.cci.Connection
    
    Throws:
    
    javax.resource.ResourceException
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - getMap
```
public <K,V> IMap<K,V> getMap(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the distributed map instance with the specified name.
    
    Specified by:
    
    getMap in interface HazelcastInstance
    
    Parameters:
    name - name of the distributed map
    
    Returns:
    distributed map instance with the specified name
  - getQueue
```
public <E> IQueue<E> getQueue(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the distributed queue instance with the specified name.
    
    Specified by:
    
    getQueue in interface HazelcastInstance
    
    Parameters:
    name - name of the distributed queue
    
    Returns:
    distributed queue instance with the specified name
  - getTopic
```
public <E> ITopic<E> getTopic(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the distributed topic instance with the specified name.
    
    Specified by:
    
    getTopic in interface HazelcastInstance
    
    Parameters:
    name - name of the distributed topic
    
    Returns:
    distributed topic instance with the specified name
  - getReliableTopic
```
public <E> ITopic<E> getReliableTopic(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the reliable ReliableTopic instance with the specified name.
    
    Specified by:
    
    getReliableTopic in interface HazelcastInstance
    
    Parameters:
    name - name of the reliable ITopic
    
    Returns:
    the reliable ITopic
  - getSet
```
public <E> ISet<E> getSet(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the distributed set instance with the specified name.
    
    Specified by:
    
    getSet in interface HazelcastInstance
    
    Parameters:
    name - name of the distributed set
    
    Returns:
    distributed set instance with the specified name
  - getList
```
public <E> IList<E> getList(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the distributed list instance with the specified name. Index based operations on the list are not supported.
    
    Specified by:
    
    getList in interface HazelcastInstance
    
    Parameters:
    name - name of the distributed list
    
    Returns:
    distributed list instance with the specified name
  - getMultiMap
```
public <K,V> MultiMap<K,V> getMultiMap(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the distributed multimap instance with the specified name.
    
    Specified by:
    
    getMultiMap in interface HazelcastInstance
    
    Parameters:
    name - name of the distributed multimap
    
    Returns:
    distributed multimap instance with the specified name
  - getExecutorService
```
public IExecutorService getExecutorService(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the distributed executor service for the given name. Executor service enables you to run your Runnables and Callables on the Hazelcast cluster.
    
    Note: Note that it don't support invokeAll/Any and don't have standard shutdown behavior
    
    Specified by:
    
    getExecutorService in interface HazelcastInstance
    
    Parameters:
    name - name of the executor service
    
    Returns:
    the distributed executor service for the given name
  - getAtomicLong
```
public IAtomicLong getAtomicLong(String name)
```
    Description copied from interface: HazelcastInstance
    
    Creates cluster-wide atomic long. Hazelcast IAtomicLong is distributed implementation of java.util.concurrent.atomic.AtomicLong.
    
    Specified by:
    
    getAtomicLong in interface HazelcastInstance
    
    Parameters:
    name - name of the IAtomicLong proxy
    
    Returns:
    IAtomicLong proxy for the given name
  - getCountDownLatch
```
public ICountDownLatch getCountDownLatch(String name)
```
    Description copied from interface: HazelcastInstance
    
    Creates cluster-wide CountDownLatch. Hazelcast ICountDownLatch is distributed implementation of java.util.concurrent.CountDownLatch.
    
    Specified by:
    
    getCountDownLatch in interface HazelcastInstance
    
    Parameters:
    name - name of the ICountDownLatch proxy
    
    Returns:
    ICountDownLatch proxy for the given name
  - getSemaphore
```
public ISemaphore getSemaphore(String name)
```
    Description copied from interface: HazelcastInstance
    
    Creates cluster-wide semaphore. Hazelcast ISemaphore is distributed implementation of java.util.concurrent.Semaphore.
    
    Specified by:
    
    getSemaphore in interface HazelcastInstance
    
    Parameters:
    name - name of the ISemaphore proxy
    
    Returns:
    ISemaphore proxy for the given name
  - getDistributedObjects
```
public Collection<DistributedObject> getDistributedObjects()
```
    Description copied from interface: HazelcastInstance
    
    Returns all DistributedObject's such as; queue, map, set, list, topic, lock, multimap.
    
    Specified by:
    
    getDistributedObjects in interface HazelcastInstance
    
    Returns:
    the collection of instances created by Hazelcast.
  - addDistributedObjectListener
```
public String addDistributedObjectListener(DistributedObjectListener distributedObjectListener)
```
    Description copied from interface: HazelcastInstance
    
    Adds a Distributed Object listener which will be notified when a new DistributedObject will be created or destroyed.
    
    Specified by:
    
    addDistributedObjectListener in interface HazelcastInstance
    
    Parameters:
    distributedObjectListener - instance listener
    
    Returns:
    returns registration id.
  - removeDistributedObjectListener
```
public boolean removeDistributedObjectListener(String registrationId)
```
    Description copied from interface: HazelcastInstance
    
    Removes the specified Distributed Object listener. Returns silently if the specified instance listener does not exist.
    
    Specified by:
    
    removeDistributedObjectListener in interface HazelcastInstance
    
    Parameters:
    registrationId - Id of listener registration.
    
    Returns:
    true if registration is removed, false otherwise
  - getConfig
```
public Config getConfig()
```
    Description copied from interface: HazelcastInstance
    
    Returns the configuration of this Hazelcast instance.
    
    Specified by:
    
    getConfig in interface HazelcastInstance
    
    Returns:
    configuration of this Hazelcast instance
  - getPartitionService
```
public PartitionService getPartitionService()
```
    Description copied from interface: HazelcastInstance
    
    Returns the partition service of this Hazelcast instance. InternalPartitionService allows you to introspect current partitions in the cluster, partition the owner members, and listen for partition migration events.
    
    Specified by:
    
    getPartitionService in interface HazelcastInstance
    
    Returns:
    the partition service of this Hazelcast instance
  - getQuorumService
```
public QuorumService getQuorumService()
```
    Description copied from interface: HazelcastInstance
    
    Returns the quorum service of this Hazelcast instance.
    Quorum service can be used to retrieve quorum callbacks which let you to notify quorum results of your own to the cluster quorum service.
    
    Specified by:
    
    getQuorumService in interface HazelcastInstance
    
    Returns:
    the quorum service of this Hazelcast instance
  - getClientService
```
public ClientService getClientService()
```
    Description copied from interface: HazelcastInstance
    
    Returns the client service of this Hazelcast instance. Client service allows you to get information about connected clients.
    
    Specified by:
    
    getClientService in interface HazelcastInstance
    
    Returns:
    the ClientService of this Hazelcast instance.
  - getLoggingService
```
public LoggingService getLoggingService()
```
    Description copied from interface: HazelcastInstance
    
    Returns the logging service of this Hazelcast instance. LoggingService allows you to listen for LogEvents generated by Hazelcast runtime. You can log the events somewhere or take action based on the message.
    
    Specified by:
    
    getLoggingService in interface HazelcastInstance
    
    Returns:
    the logging service of this Hazelcast instance
  - getDistributedObject
```
public <T extends DistributedObject> T getDistributedObject(String serviceName,
                                                   String name)
```
    Specified by:
    
    getDistributedObject in interface HazelcastInstance
    
    Type Parameters:
    T - type of the DistributedObject
    Parameters:
    serviceName - name of the service
    name - name of the object
    
    Returns:
    DistributedObject created by the service
  - getUserContext
```
public ConcurrentMap<String,Object> getUserContext()
```
    Description copied from interface: HazelcastInstance
    
    Returns a ConcurrentMap that can be used to add user-context to the HazelcastInstance. This can be used to store dependencies that otherwise are hard to obtain. HazelcastInstance can be obtained by implementing a 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.
    
    Specified by:
    
    getUserContext in interface HazelcastInstance
    
    Returns:
    a ConcurrentMap that can be used to add user-context to the HazelcastInstance.
  - getTransactionalMap
```
public <K,V> TransactionalMap<K,V> getTransactionalMap(String name)
```
    Specified by:
    
    getTransactionalMap in interface HazelcastConnection
    
    See Also:
    TransactionalTaskContext.getMap(String)
  - getTransactionalQueue
```
public <E> TransactionalQueue<E> getTransactionalQueue(String name)
```
    Specified by:
    
    getTransactionalQueue in interface HazelcastConnection
    
    See Also:
    TransactionalTaskContext.getQueue(String)
  - getTransactionalMultiMap
```
public <K,V> TransactionalMultiMap<K,V> getTransactionalMultiMap(String name)
```
    Specified by:
    
    getTransactionalMultiMap in interface HazelcastConnection
    
    See Also:
    TransactionalTaskContext.getMultiMap(String)
  - getTransactionalList
```
public <E> TransactionalList<E> getTransactionalList(String name)
```
    Specified by:
    
    getTransactionalList in interface HazelcastConnection
    
    See Also:
    TransactionalTaskContext.getList(String)
  - getTransactionalSet
```
public <E> TransactionalSet<E> getTransactionalSet(String name)
```
    Specified by:
    
    getTransactionalSet in interface HazelcastConnection
    
    See Also:
    TransactionalTaskContext.getSet(String)
  - getIdGenerator
```
public IdGenerator getIdGenerator(String name)
```
    Description copied from interface: HazelcastInstance
    
    Creates cluster-wide unique IDs. Generated IDs are long type primitive values between 0 and Long.MAX_VALUE . Id generation occurs almost at the speed of AtomicLong.incrementAndGet() . Generated IDs are unique during the life cycle of the cluster. If the entire cluster is restarted, IDs start from 0 again.
    
    Specified by:
    
    getIdGenerator in interface HazelcastInstance
    
    Parameters:
    name - name of the IdGenerator
    
    Returns:
    IdGenerator for the given name
  - getAtomicReference
```
public <E> IAtomicReference<E> getAtomicReference(String name)
```
    Description copied from interface: HazelcastInstance
    
    Creates cluster-wide atomic reference. Hazelcast IAtomicReference is distributed implementation of java.util.concurrent.atomic.AtomicReference.
    
    Specified by:
    
    getAtomicReference in interface HazelcastInstance
    
    Parameters:
    name - name of the IAtomicReference proxy
    
    Returns:
    IAtomicReference proxy for the given name
  - getReplicatedMap
```
public <K,V> ReplicatedMap<K,V> getReplicatedMap(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the replicated map instance with the specified name.
    
    Specified by:
    
    getReplicatedMap in interface HazelcastInstance
    
    Parameters:
    name - name of the distributed map
    
    Returns:
    replicated map instance with specified name
  - getRingbuffer
```
public <E> Ringbuffer<E> getRingbuffer(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the distributed Ringbuffer instance with the specified name.
    
    Specified by:
    
    getRingbuffer in interface HazelcastInstance
    
    Parameters:
    name - name of the distributed Ringbuffer
    
    Returns:
    distributed RingBuffer instance with the specified name
  - getJobTracker
```
public JobTracker getJobTracker(String name)
```
    Description copied from interface: HazelcastInstance
    
    Returns the job tracker instance with the specified name.
    
    Specified by:
    
    getJobTracker in interface HazelcastInstance
    
    Parameters:
    name - name of the job tracker
    
    Returns:
    job tracker instance with the specified name
  - getName
```
public String getName()
```
    Description copied from interface: HazelcastInstance
    
    Returns the name of this Hazelcast instance
    
    Specified by:
    
    getName in interface HazelcastInstance
    
    Returns:
    name of this Hazelcast instance
  - getLock
```
public ILock getLock(String key)
```
    Description copied from interface: HazelcastInstance
    Returns the distributed lock instance for the specified key object. The specified object is considered to be the key for this lock. So keys are considered equals cluster-wide as long as they are serialized to the same byte array such as String, long, Integer.
    Locks are fail-safe. If a member holds a lock and some of the members go down, the cluster will keep your locks safe and available. Moreover, when a member leaves the cluster, all the locks acquired by this dead member will be removed so that these locks can be available for live members immediately.
```
 Lock lock = hazelcastInstance.getLock("PROCESS_LOCK");
 lock.lock();
 try {
   // process
 } finally {
   lock.unlock();
 }
 
```
    Specified by:
    
    getLock in interface HazelcastInstance
    
    Parameters:
    key - key of the lock instance
    
    Returns:
    distributed lock instance for the specified key.
  - getCluster
```
public Cluster getCluster()
```
    Description copied from interface: HazelcastInstance
    
    Returns the Cluster that this Hazelcast instance is part of. Cluster interface allows you to add a listener for membership events and to learn more about the cluster that this Hazelcast instance is part of.
    
    Specified by:
    
    getCluster in interface HazelcastInstance
    
    Returns:
    the cluster that this Hazelcast instance is part of
  - getLocalEndpoint
```
public Endpoint getLocalEndpoint()
```
    Description copied from interface: HazelcastInstance
    
    Returns the local Endpoint which this HazelcastInstance belongs to.
    Returned endpoint will be a Member instance for cluster nodes and a Client instance for clients.
    
    Specified by:
    
    getLocalEndpoint in interface HazelcastInstance
    
    Returns:
    the local Endpoint which this HazelcastInstance belongs to
    See Also:
    Member, Client
  - getXAResource
```
public HazelcastXAResource getXAResource()
```
    Description copied from interface: HazelcastInstance
    
    Gets xaResource which will participate in XATransaction.
    
    Specified by:
    
    getXAResource in interface HazelcastInstance
    
    Returns:
    the xaResource.
  - getLifecycleService
```
public LifecycleService getLifecycleService()
```
    Description copied from interface: HazelcastInstance
    
    Returns the lifecycle service for this instance. LifecycleService allows you to shutdown this HazelcastInstance and listen for the lifecycle events.
    
    Specified by:
    
    getLifecycleService in interface HazelcastInstance
    
    Returns:
    the lifecycle service for this instance
  - shutdown
```
public void shutdown()
```
    Description copied from interface: HazelcastInstance
    
    Shuts down this HazelcastInstance. For more information see LifecycleService.shutdown().
    
    Specified by:
    
    shutdown in interface HazelcastInstance
  - executeTransaction
```
public <T> T executeTransaction(TransactionalTask<T> task)
                     throws TransactionException
```
    Description copied from interface: HazelcastInstance
    
    Executes the given transactional task in current thread using default options and returns the result of the task.
    
    Specified by:
    
    executeTransaction in interface HazelcastInstance
    
    Type Parameters:
    T - return type of task
    Parameters:
    task - the transactional task to be executed
    
    Returns:
    result of the transactional task
    
    Throws:
    
    TransactionException - if an error occurs during transaction.
  - executeTransaction
```
public <T> T executeTransaction(TransactionOptions options,
                       TransactionalTask<T> task)
                     throws TransactionException
```
    Description copied from interface: HazelcastInstance
    
    Executes the given transactional task in current thread using given options and returns the result of the task.
    
    Specified by:
    
    executeTransaction in interface HazelcastInstance
    
    Type Parameters:
    T - return type of task
    Parameters:
    options - options for this transactional task
    task - task to be executed
    
    Returns:
    result of the transactional task
    
    Throws:
    
    TransactionException - if an error occurs during transaction.
  - newTransactionContext
```
public TransactionContext newTransactionContext()
```
    Description copied from interface: HazelcastInstance
    
    Creates a new TransactionContext associated with the current thread using default options.
    
    Specified by:
    
    newTransactionContext in interface HazelcastInstance
    
    Returns:
    new TransactionContext associated with the current thread
  - newTransactionContext
```
public TransactionContext newTransactionContext(TransactionOptions options)
```
    Description copied from interface: HazelcastInstance
    
    Creates a new TransactionContext associated with the current thread with given options.
    
    Specified by:
    
    newTransactionContext in interface HazelcastInstance
    
    Parameters:
    options - options for this transaction
    
    Returns:
    new TransactionContext associated with the current thread

Class HazelcastConnectionImpl

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

HazelcastConnectionImpl

Method Detail

close

createInteraction

getResultSetInfo

getLocalTransaction

getMetaData

toString

getMap

getQueue

getTopic

getReliableTopic

getSet

getList

getMultiMap

getExecutorService

getAtomicLong

getCountDownLatch

getSemaphore

getDistributedObjects

addDistributedObjectListener

removeDistributedObjectListener

getConfig

getPartitionService

getQuorumService

getClientService

getLoggingService

getDistributedObject

getUserContext

getTransactionalMap

getTransactionalQueue

getTransactionalMultiMap

getTransactionalList

getTransactionalSet

getIdGenerator

getAtomicReference

getReplicatedMap

getRingbuffer

getJobTracker

getName

getLock

getCluster

getLocalEndpoint

getXAResource

getLifecycleService

shutdown

executeTransaction

executeTransaction

newTransactionContext

newTransactionContext