Uses of Class
org.apache.activemq.artemis.core.server.NodeManager
Packages that use NodeManager
Package
Description
-
Uses of NodeManager in org.apache.activemq.artemis.core.server
Methods in org.apache.activemq.artemis.core.server that return NodeManager -
Uses of NodeManager in org.apache.activemq.artemis.core.server.cluster
Constructors in org.apache.activemq.artemis.core.server.cluster with parameters of type NodeManagerModifierConstructorDescriptionBackupManager(ActiveMQServer server, ExecutorFactory executorFactory, ScheduledExecutorService scheduledExecutor, NodeManager nodeManager, Configuration configuration, ClusterManager clusterManager) ClusterManager(ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ScheduledExecutorService scheduledExecutor, ManagementService managementService, Configuration configuration, NodeManager nodeManager, boolean useQuorumManager) -
Uses of NodeManager in org.apache.activemq.artemis.core.server.cluster.impl
Constructors in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type NodeManagerModifierConstructorDescriptionBroadcastGroupImpl(NodeManager nodeManager, String name, long broadCastPeriod, ScheduledExecutorService scheduledExecutor, BroadcastEndpointFactory endpointFactory) ClusterConnectionImpl(ClusterManager manager, DiscoveryGroupConfiguration dg, TransportConfiguration connector, SimpleString name, SimpleString address, int minLargeMessageSize, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int initialConnectAttempts, int reconnectAttempts, long callTimeout, long callFailoverTimeout, boolean useDuplicateDetection, MessageLoadBalancingType messageLoadBalancingType, int confirmationWindowSize, int producerWindowSize, ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ManagementService managementService, ScheduledExecutorService scheduledExecutor, int maxHops, NodeManager nodeManager, String clusterUser, String clusterPassword, boolean allowDirectConnectionsOnly, long clusterNotificationInterval, int clusterNotificationAttempts, String clientId, int topologyScannerAttempts) ClusterConnectionImpl(ClusterManager manager, TransportConfiguration[] staticTranspConfigs, TransportConfiguration connector, SimpleString name, SimpleString address, int minLargeMessageSize, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int initialConnectAttempts, int reconnectAttempts, long callTimeout, long callFailoverTimeout, boolean useDuplicateDetection, MessageLoadBalancingType messageLoadBalancingType, int confirmationWindowSize, int producerWindowSize, ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ManagementService managementService, ScheduledExecutorService scheduledExecutor, int maxHops, NodeManager nodeManager, String clusterUser, String clusterPassword, boolean allowDirectConnectionsOnly, long clusterNotificationInterval, int clusterNotificationAttempts, String clientId, int topologyScannerAttempts) -
Uses of NodeManager in org.apache.activemq.artemis.core.server.cluster.quorum
Constructors in org.apache.activemq.artemis.core.server.cluster.quorum with parameters of type NodeManagerModifierConstructorDescriptionSharedNothingBackupQuorum(NodeManager nodeManager, ScheduledExecutorService scheduledPool, NetworkHealthCheck networkHealthCheck, int quorumSize, int voteRetries, long voteRetryWait, int quorumVoteWait, boolean failback) -
Uses of NodeManager in org.apache.activemq.artemis.core.server.impl
Subclasses of NodeManager in org.apache.activemq.artemis.core.server.implModifier and TypeClassDescriptionclassclassfinal classNodeManager used to run multiple servers in the same VM.Fields in org.apache.activemq.artemis.core.server.impl declared as NodeManagerMethods in org.apache.activemq.artemis.core.server.impl that return NodeManagerModifier and TypeMethodDescriptionprotected NodeManagerActiveMQServerImpl.createNodeManager(File directory, boolean replicatingBackup) ActiveMQServerImpl.getNodeManager()Methods in org.apache.activemq.artemis.core.server.impl with parameters of type NodeManagerModifier and TypeMethodDescriptionActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) create the Journal loader needed for this Activation.SharedNothingBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) SharedStoreBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) voidActiveMQServerImpl.interruptActivationThread(NodeManager nodeManagerInUse) Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type NodeManagerModifierConstructorDescriptionBackupRecoveryJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer, ServerLocatorInternal locator, ClusterController clusterController) PostOfficeJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration) PostOfficeJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, Map<Long, Queue> queues) ScaleDownHandler(PagingManager pagingManager, PostOffice postOffice, NodeManager nodeManager, ClusterController clusterController, StorageManager storageManager, int commitInterval) -
Uses of NodeManager in org.apache.activemq.artemis.core.server.impl.jdbc
Subclasses of NodeManager in org.apache.activemq.artemis.core.server.impl.jdbc -
Uses of NodeManager in org.apache.activemq.artemis.core.server.impl.quorum
Methods in org.apache.activemq.artemis.core.server.impl.quorum with parameters of type NodeManagerModifier and TypeMethodDescriptionstatic voidActivationSequenceStateMachine.ensureSequentialAccessToNodeData(String serverDescription, NodeManager nodeManager, org.apache.activemq.artemis.lockmanager.DistributedLockManager distributedManager, Logger logger) This is going to increment the coordinated activation sequence and the local activation sequence (usingwriteNodeActivationSequence(long)) while holding the primary lock, failing with some exception otherwise.static org.apache.activemq.artemis.lockmanager.DistributedLockActivationSequenceStateMachine.tryActivate(NodeManager nodeManager, org.apache.activemq.artemis.lockmanager.DistributedLockManager distributedManager, Logger logger) It loops if the data of the broker is still valuable, but cannot become active.