Uses of Class
org.apache.activemq.artemis.api.core.Pair
Packages that use Pair
Package
Description
-
Uses of Pair in org.apache.activemq.artemis.core.client.impl
Methods in org.apache.activemq.artemis.core.client.impl that return PairModifier and TypeMethodDescriptionTopologyMemberImpl.getConnector()ServerLocatorImpl.selectNextConnectorPair()ServerLocatorInternal.selectNextConnectorPair()Methods in org.apache.activemq.artemis.core.client.impl with parameters of type PairModifier and TypeMethodDescriptionvoidServerLocatorImpl.notifyNodeUp(long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration, TransportConfiguration> connectorPair, boolean last) voidServerLocatorInternal.notifyNodeUp(long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration, TransportConfiguration> connectorPair, boolean last) -
Uses of Pair in org.apache.activemq.artemis.core.deployers.impl
Methods in org.apache.activemq.artemis.core.deployers.impl that return PairModifier and TypeMethodDescriptionprotected Pair<String,AddressSettings> FileConfigurationParser.parseAddressSettings(Node node) -
Uses of Pair in org.apache.activemq.artemis.core.journal.impl
Methods in org.apache.activemq.artemis.core.journal.impl with parameters of type PairModifier and TypeMethodDescriptionprotected SequentialFileJournalImpl.createControlFile(List<JournalFile> files, List<JournalFile> newFiles, Pair<String, String> cleanupRename) -
Uses of Pair in org.apache.activemq.artemis.core.persistence
Method parameters in org.apache.activemq.artemis.core.persistence with type arguments of type PairModifier and TypeMethodDescriptiondefault JournalLoadInformationStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader) default JournalLoadInformationStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, Set<Long> largeMessagesInFolder, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader) StorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, Set<Long> largeMessagesInFolder, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader, List<Consumer<RecordInfo>> extraRecordsLoader) -
Uses of Pair in org.apache.activemq.artemis.core.persistence.impl.journal
Method parameters in org.apache.activemq.artemis.core.persistence.impl.journal with type arguments of type PairModifier and TypeMethodDescriptionAbstractJournalStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, Set<Long> storedLargeMessages, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader, List<Consumer<RecordInfo>> journalRecordsListener) -
Uses of Pair in org.apache.activemq.artemis.core.persistence.impl.nullpm
Method parameters in org.apache.activemq.artemis.core.persistence.impl.nullpm with type arguments of type PairModifier and TypeMethodDescriptionNullStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, Set<Long> storedLargeMessages, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader, List<Consumer<RecordInfo>> extraLoaders) -
Uses of Pair in org.apache.activemq.artemis.core.postoffice
Methods in org.apache.activemq.artemis.core.postoffice that return PairModifier and TypeMethodDescriptionPostOffice.redistribute(Message message, Queue originatingQueue) Methods in org.apache.activemq.artemis.core.postoffice that return types with arguments of type PairMethod parameters in org.apache.activemq.artemis.core.postoffice with type arguments of type Pair -
Uses of Pair in org.apache.activemq.artemis.core.postoffice.impl
Methods in org.apache.activemq.artemis.core.postoffice.impl that return PairModifier and TypeMethodDescriptionPostOfficeImpl.redistribute(Message message, Queue originatingQueue) The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different threadMethods in org.apache.activemq.artemis.core.postoffice.impl that return types with arguments of type PairMethod parameters in org.apache.activemq.artemis.core.postoffice.impl with type arguments of type Pair -
Uses of Pair in org.apache.activemq.artemis.core.protocol.core.impl
Methods in org.apache.activemq.artemis.core.protocol.core.impl that return PairModifier and TypeMethodDescriptionBackwardsCompatibilityUtils.checkTCPPairConversion(int clientIncrementingVersion, TopologyMember member) -
Uses of Pair in org.apache.activemq.artemis.core.protocol.core.impl.wireformat
Fields in org.apache.activemq.artemis.core.protocol.core.impl.wireformat declared as PairModifier and TypeFieldDescriptionprotected Pair<TransportConfiguration,TransportConfiguration> ClusterTopologyChangeMessage.pairMethods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return PairConstructors in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type PairModifierConstructorDescriptionClusterTopologyChangeMessage(String nodeID, Pair<TransportConfiguration, TransportConfiguration> pair, boolean last) ClusterTopologyChangeMessage_V2(long uniqueEventID, String nodeID, String backupGroupName, Pair<TransportConfiguration, TransportConfiguration> pair, boolean last) protectedClusterTopologyChangeMessage_V3(byte type, long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration, TransportConfiguration> pair, boolean last) ClusterTopologyChangeMessage_V3(long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration, TransportConfiguration> pair, boolean last) ClusterTopologyChangeMessage_V4(long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration, TransportConfiguration> pair, boolean last, int serverVersion) -
Uses of Pair in org.apache.activemq.artemis.core.remoting.impl.ssl
Methods in org.apache.activemq.artemis.core.remoting.impl.ssl that return Pair -
Uses of Pair in org.apache.activemq.artemis.core.replication
Method parameters in org.apache.activemq.artemis.core.replication with type arguments of type Pair -
Uses of Pair in org.apache.activemq.artemis.core.security.impl
Methods in org.apache.activemq.artemis.core.security.impl that return types with arguments of type Pair -
Uses of Pair in org.apache.activemq.artemis.core.server
Methods in org.apache.activemq.artemis.core.server that return PairModifier and TypeMethodDescriptionQueue.checkRedelivery(MessageReference ref, long timeBase, boolean ignoreRedeliveryDelay) Returns a Pair of Booleans: the first indicates whether redelivery happened; the second indicates whether or not the message was actually sent to a DLA with bindings.ServerSession.getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes) Get the canonical (i.e. non-prefixed) address and the corresponding routing-type.abstract Pair<TransportConfiguration,TransportConfiguration> NodeLocator.getPrimaryConfiguration()Returns the current connector.Methods in org.apache.activemq.artemis.core.server that return types with arguments of type PairModifier and TypeMethodDescriptionServiceRegistry.getConnectorServices(List<ConnectorServiceConfiguration> configs) Get a collection of paired org.apache.activemq.artemis.core.server.ConnectorServiceFactory and org.apache.activemq.artemis.core.config.ConnectorServiceConfiguration instances.Methods in org.apache.activemq.artemis.core.server with parameters of type PairModifier and TypeMethodDescriptionvoidActiveMQServerLogger_impl.deletingPendingMessage(Pair<Long, Long> msgToDelete) voidActiveMQServerLogger.deletingPendingMessage(Pair<Long, Long> msgToDelete) -
Uses of Pair in org.apache.activemq.artemis.core.server.cluster
Methods in org.apache.activemq.artemis.core.server.cluster with parameters of type PairModifier and TypeMethodDescriptionvoidClusterConnection.nodeAnnounced(long eventUID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration, TransportConfiguration> connectorPair, boolean backup) -
Uses of Pair in org.apache.activemq.artemis.core.server.cluster.ha
Methods in org.apache.activemq.artemis.core.server.cluster.ha with parameters of type PairModifier and TypeMethodDescriptionbooleanColocatedHAManager.requestBackup(Pair<TransportConfiguration, TransportConfiguration> connectorPair, int backupSize, boolean replicated) send a request to a primary server to start a backup for us -
Uses of Pair in org.apache.activemq.artemis.core.server.cluster.impl
Methods in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type PairModifier and TypeMethodDescriptionvoidClusterConnectionImpl.nodeAnnounced(long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration, TransportConfiguration> connectorPair, boolean backup) -
Uses of Pair in org.apache.activemq.artemis.core.server.impl
Methods in org.apache.activemq.artemis.core.server.impl that return PairModifier and TypeMethodDescriptionQueueImpl.checkRedelivery(MessageReference reference, long timeBase, boolean ignoreRedeliveryDelay) ServerSessionImpl.getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes) AnyNodeLocatorForReplication.getPrimaryConfiguration()AnyNodeLocatorForScaleDown.getPrimaryConfiguration()NamedNodeIdLocatorForReplication.getPrimaryConfiguration()NamedNodeIdNodeLocator.getPrimaryConfiguration()NamedNodeLocatorForReplication.getPrimaryConfiguration()NamedNodeLocatorForScaleDown.getPrimaryConfiguration()Methods in org.apache.activemq.artemis.core.server.impl that return types with arguments of type PairModifier and TypeMethodDescriptionServiceRegistryImpl.getConnectorServices(List<ConnectorServiceConfiguration> configs) Methods in org.apache.activemq.artemis.core.server.impl with parameters of type PairModifier and TypeMethodDescriptionvoidSharedNothingPrimaryActivation.startReplication(CoreRemotingConnection rc, ClusterConnection clusterConnection, Pair<TransportConfiguration, TransportConfiguration> pair, boolean isFailBackRequest) Method parameters in org.apache.activemq.artemis.core.server.impl with type arguments of type PairModifier and TypeMethodDescriptionvoidBackupRecoveryJournalLoader.handleDuplicateIds(Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) voidJournalLoader.handleDuplicateIds(Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) voidPostOfficeJournalLoader.handleDuplicateIds(Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) voidBackupRecoveryJournalLoader.postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) voidJournalLoader.postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) voidPostOfficeJournalLoader.postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) longScaleDownHandler.scaleDown(ClientSessionFactory sessionFactory, ResourceManager resourceManager, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, SimpleString managementAddress, SimpleString targetNodeId) voidScaleDownHandler.scaleDownDuplicateIDs(Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, ClientSessionFactory sessionFactory, SimpleString managementAddress, String user, String password) Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type PairModifierConstructorDescriptionNamedNodeIdNodeLocator(String nodeID, Pair<TransportConfiguration, TransportConfiguration> configuration) -
Uses of Pair in org.apache.activemq.artemis.jms.client
Methods in org.apache.activemq.artemis.jms.client that return PairModifier and TypeMethodDescriptionActiveMQDestination.decomposeQueueNameForDurableSubscription(String queueName) -
Uses of Pair in org.apache.activemq.artemis.jms.server.config.impl
Methods in org.apache.activemq.artemis.jms.server.config.impl that return types with arguments of type PairModifier and TypeMethodDescriptionTransportConfigurationEncodingSupport.decodeConfigs(ActiveMQBuffer buffer) Method parameters in org.apache.activemq.artemis.jms.server.config.impl with type arguments of type PairModifier and TypeMethodDescriptionstatic voidTransportConfigurationEncodingSupport.encodeConfigs(ActiveMQBuffer buffer, List<Pair<TransportConfiguration, TransportConfiguration>> configs) static intTransportConfigurationEncodingSupport.getEncodeSize(List<Pair<TransportConfiguration, TransportConfiguration>> configs) -
Uses of Pair in org.apache.activemq.artemis.reader
Methods in org.apache.activemq.artemis.reader that return PairModifier and TypeMethodDescriptionStreamMessageUtil.streamReadBytes(ActiveMQBuffer buff, int remainingBytes, byte[] value) Utility for reading bytes out of streaming. -
Uses of Pair in org.apache.activemq.artemis.spi.core.remoting
Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type PairModifier and TypeMethodDescriptionvoidTopologyResponseHandler.notifyNodeUp(long uniqueEventID, String backupGroupName, String scaleDownGroupName, String nodeName, Pair<TransportConfiguration, TransportConfiguration> connectorPair, boolean isLast) -
Uses of Pair in org.apache.activemq.artemis.utils
Methods in org.apache.activemq.artemis.utils that return PairModifier and TypeMethodDescriptionstatic Pair<SimpleString,EnumSet<RoutingType>> PrefixUtil.getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes, Map<SimpleString, RoutingType> prefixes)