A C F G H I O R S T
All Classes All Packages

A

addUnavailableManagerListener(DistributedPrimitiveManager.UnavailableManagerListener) - Method in class org.apache.activemq.artemis.quorum.file.FileBasedPrimitiveManager

addUnavailableManagerListener(DistributedPrimitiveManager.UnavailableManagerListener) - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

C

call() - Method in interface org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive.InterruptablePrimitiveAction

call() - Method in interface org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive.PrimitiveAction

checkHandlingEvents() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

checkUnavailable() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

close() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

completeHandlingEvents() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

CuratorDistributedPrimitive - Class in org.apache.activemq.artemis.quorum.zookeeper

CuratorDistributedPrimitive(CuratorDistributedPrimitiveManager.PrimitiveId, CuratorDistributedPrimitiveManager) - Constructor for class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

CuratorDistributedPrimitive.InterruptablePrimitiveAction<R,T extends java.lang.Throwable> - Interface in org.apache.activemq.artemis.quorum.zookeeper

CuratorDistributedPrimitive.PrimitiveAction<R,T extends java.lang.Throwable> - Interface in org.apache.activemq.artemis.quorum.zookeeper

CuratorDistributedPrimitiveManager - Class in org.apache.activemq.artemis.quorum.zookeeper

CuratorDistributedPrimitiveManager(Map<String, String>) - Constructor for class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

F

FileBasedPrimitiveManager - Class in org.apache.activemq.artemis.quorum.file

This is an implementation suitable to be used just on unit tests and it won't attempt to manage nor purge existing stale locks files.

FileBasedPrimitiveManager(File) - Constructor for class org.apache.activemq.artemis.quorum.file.FileBasedPrimitiveManager

FileBasedPrimitiveManager(Map<String, String>) - Constructor for class org.apache.activemq.artemis.quorum.file.FileBasedPrimitiveManager

fireUnavailableListener(Runnable) - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

G

getCurator() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

Used for testing purposes

getDistributedLock(String) - Method in class org.apache.activemq.artemis.quorum.file.FileBasedPrimitiveManager

getDistributedLock(String) - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

getMutableLong(String) - Method in class org.apache.activemq.artemis.quorum.file.FileBasedPrimitiveManager

getMutableLong(String) - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

H

handleClosed() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

handleLost() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

handleReconnected() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

handleSuspended() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

I

isStarted() - Method in class org.apache.activemq.artemis.quorum.file.FileBasedPrimitiveManager

isStarted() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

isUnavailable() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

O

org.apache.activemq.artemis.quorum.file - package org.apache.activemq.artemis.quorum.file

org.apache.activemq.artemis.quorum.zookeeper - package org.apache.activemq.artemis.quorum.zookeeper

R

remove(CuratorDistributedPrimitive) - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

removeUnavailableManagerListener(DistributedPrimitiveManager.UnavailableManagerListener) - Method in class org.apache.activemq.artemis.quorum.file.FileBasedPrimitiveManager

removeUnavailableManagerListener(DistributedPrimitiveManager.UnavailableManagerListener) - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

run(CuratorDistributedPrimitive.PrimitiveAction<R, T>) - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

S

start() - Method in class org.apache.activemq.artemis.quorum.file.FileBasedPrimitiveManager

start() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

start(long, TimeUnit) - Method in class org.apache.activemq.artemis.quorum.file.FileBasedPrimitiveManager

start(long, TimeUnit) - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

startHandlingEvents() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

stateChanged(CuratorFramework, ConnectionState) - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

stop() - Method in class org.apache.activemq.artemis.quorum.file.FileBasedPrimitiveManager

stop() - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager

T

tryRun(CuratorDistributedPrimitive.InterruptablePrimitiveAction<R, T>) - Method in class org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

A C F G H I O R S T
All Classes All Packages