Uses of Class
org.apache.activemq.artemis.api.core.Pair

Packages that use Pair

Package	Description
org.apache.activemq.artemis.core.client.impl
org.apache.activemq.artemis.core.deployers.impl
org.apache.activemq.artemis.core.journal.impl
org.apache.activemq.artemis.core.persistence
org.apache.activemq.artemis.core.persistence.impl.journal
org.apache.activemq.artemis.core.persistence.impl.nullpm
org.apache.activemq.artemis.core.postoffice
org.apache.activemq.artemis.core.postoffice.impl
org.apache.activemq.artemis.core.protocol.core.impl
org.apache.activemq.artemis.core.protocol.core.impl.wireformat
org.apache.activemq.artemis.core.replication
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.cluster
org.apache.activemq.artemis.core.server.cluster.ha
org.apache.activemq.artemis.core.server.cluster.impl
org.apache.activemq.artemis.core.server.impl
org.apache.activemq.artemis.jms.client
org.apache.activemq.artemis.jms.server.config.impl
org.apache.activemq.artemis.reader
org.apache.activemq.artemis.spi.core.remoting

Uses of Pair in org.apache.activemq.artemis.core.client.impl

Methods in org.apache.activemq.artemis.core.client.impl that return Pair

Modifier and Type	Method and Description
Pair<TransportConfiguration,TransportConfiguration>	TopologyMemberImpl.getConnector()

Methods in org.apache.activemq.artemis.core.client.impl with parameters of type Pair

Modifier and Type	Method and Description
void	ServerLocatorInternal.notifyNodeUp(long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)
void	ServerLocatorImpl.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 Pair

Modifier and Type	Method and Description
protected Pair<String,AddressSettings>	FileConfigurationParser.parseAddressSettings(Node node)
protected Pair<String,Set<Role>>	FileConfigurationParser.parseSecurityRoles(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 Pair

Modifier and Type	Method and Description
protected SequentialFile	JournalImpl.createControlFile(List<JournalFile> files, List<JournalFile> newFiles, Pair<String,String> cleanupRename)

Method parameters in org.apache.activemq.artemis.core.journal.impl with type arguments of type Pair

Modifier and Type	Method and Description
static SequentialFile	AbstractJournalUpdateTask.readControlFile(SequentialFileFactory fileFactory, List<String> dataFiles, List<String> newFiles, List<Pair<String,String>> renameFile)
protected SequentialFile	JournalImpl.writeControlFile(SequentialFileFactory fileFactory, List<JournalFile> files, List<JournalFile> newFiles, List<Pair<String,String>> renames)
static SequentialFile	AbstractJournalUpdateTask.writeControlFile(SequentialFileFactory fileFactory, List<JournalFile> files, List<JournalFile> newFiles, List<Pair<String,String>> renames)

Uses of Pair in org.apache.activemq.artemis.core.persistence

Method parameters in org.apache.activemq.artemis.core.persistence with type arguments of type Pair

Modifier and Type	Method and Description
JournalLoadInformation	StorageManager.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)
JournalLoadInformation	StorageManager.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)

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 Pair

Modifier and Type	Method and Description
JournalLoadInformation	AbstractJournalStorageManager.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)
JournalLoadInformation	AbstractJournalStorageManager.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)

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 Pair

Modifier and Type	Method and Description
JournalLoadInformation	NullStorageManager.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)
JournalLoadInformation	NullStorageManager.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)

Uses of Pair in org.apache.activemq.artemis.core.postoffice

Methods in org.apache.activemq.artemis.core.postoffice that return Pair

Modifier and Type	Method and Description
Pair<RoutingContext,ServerMessage>	PostOffice.redistribute(ServerMessage message, Queue originatingQueue, Transaction tx)

Methods in org.apache.activemq.artemis.core.postoffice that return types with arguments of type Pair

Modifier and Type	Method and Description
List<Pair<byte[],Long>>	DuplicateIDCache.getMap()

Method parameters in org.apache.activemq.artemis.core.postoffice with type arguments of type Pair

Modifier and Type	Method and Description
void	DuplicateIDCache.load(List<Pair<byte[],Long>> theIds)

Uses of Pair in org.apache.activemq.artemis.core.postoffice.impl

Methods in org.apache.activemq.artemis.core.postoffice.impl that return Pair

Modifier and Type	Method and Description
Pair<RoutingContext,ServerMessage>	PostOfficeImpl.redistribute(ServerMessage message, Queue originatingQueue, Transaction tx) 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 thread

Methods in org.apache.activemq.artemis.core.postoffice.impl that return types with arguments of type Pair

Modifier and Type	Method and Description
List<Pair<byte[],Long>>	DuplicateIDCacheImpl.getMap()

Method parameters in org.apache.activemq.artemis.core.postoffice.impl with type arguments of type Pair

Modifier and Type	Method and Description
void	DuplicateIDCacheImpl.load(List<Pair<byte[],Long>> theIds)

Uses of Pair in org.apache.activemq.artemis.core.protocol.core.impl

Methods in org.apache.activemq.artemis.core.protocol.core.impl that return Pair

Modifier and Type	Method and Description
static Pair<TransportConfiguration,TransportConfiguration>	BackwardsCompatibilityUtils.getTCPair(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 Pair

Modifier and Type	Field and Description
protected Pair<TransportConfiguration,TransportConfiguration>	ClusterTopologyChangeMessage.pair

Methods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return Pair

Modifier and Type	Method and Description
Pair<TransportConfiguration,TransportConfiguration>	ClusterTopologyChangeMessage.getPair()

Constructors in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type Pair

Constructor and Description
ClusterTopologyChangeMessage_V2(long uniqueEventID, String nodeID, String backupGroupName, Pair<TransportConfiguration,TransportConfiguration> pair, boolean last)
ClusterTopologyChangeMessage_V3(long uniqueEventID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration,TransportConfiguration> pair, boolean last)
ClusterTopologyChangeMessage(String nodeID, Pair<TransportConfiguration,TransportConfiguration> pair, boolean last)

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

Modifier and Type	Method and Description
void	ReplicationManager.sendLargeMessageIdListMessage(Map<Long,Pair<String,Long>> largeMessages) Reserves several LargeMessage IDs in the backup.

Uses of Pair in org.apache.activemq.artemis.core.server

Methods in org.apache.activemq.artemis.core.server that return Pair

Modifier and Type	Method and Description
abstract Pair<TransportConfiguration,TransportConfiguration>	LiveNodeLocator.getLiveConfiguration() Returns the current connector

Methods in org.apache.activemq.artemis.core.server that return types with arguments of type Pair

Modifier and Type	Method and Description
Collection<Pair<ConnectorServiceFactory,ConnectorServiceConfiguration>>	ServiceRegistry.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 Pair

Modifier and Type	Method and Description
void	ActiveMQServerLogger.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 Pair

Modifier and Type	Method and Description
void	ClusterConnection.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 Pair

Modifier and Type	Method and Description
boolean	ColocatedHAManager.requestBackup(Pair<TransportConfiguration,TransportConfiguration> connectorPair, int backupSize, boolean replicated) send a request to a live 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 Pair

Modifier and Type	Method and Description
void	ClusterConnectionImpl.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

Fields in org.apache.activemq.artemis.core.server.impl with type parameters of type Pair

Modifier and Type	Field and Description
protected Map<SimpleString,Pair<UUID,AtomicLong>>	ServerSessionImpl.targetAddressInfos

Methods in org.apache.activemq.artemis.core.server.impl that return Pair

Modifier and Type	Method and Description
Pair<TransportConfiguration,TransportConfiguration>	NamedNodeIdNodeLocator.getLiveConfiguration()
Pair<TransportConfiguration,TransportConfiguration>	NamedLiveNodeLocatorForScaleDown.getLiveConfiguration()
Pair<TransportConfiguration,TransportConfiguration>	NamedLiveNodeLocatorForReplication.getLiveConfiguration()
Pair<TransportConfiguration,TransportConfiguration>	AnyLiveNodeLocatorForScaleDown.getLiveConfiguration()
Pair<TransportConfiguration,TransportConfiguration>	AnyLiveNodeLocatorForReplication.getLiveConfiguration()

Methods in org.apache.activemq.artemis.core.server.impl that return types with arguments of type Pair

Modifier and Type	Method and Description
Collection<Pair<ConnectorServiceFactory,ConnectorServiceConfiguration>>	ServiceRegistryImpl.getConnectorServices(List<ConnectorServiceConfiguration> configs)

Methods in org.apache.activemq.artemis.core.server.impl with parameters of type Pair

Modifier and Type	Method and Description
void	SharedNothingLiveActivation.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 Pair

Modifier and Type	Method and Description
void	PostOfficeJournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
void	JournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
void	BackupRecoveryJournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
void	PostOfficeJournalLoader.postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
void	JournalLoader.postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
void	BackupRecoveryJournalLoader.postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
long	ScaleDownHandler.scaleDown(ClientSessionFactory sessionFactory, ResourceManager resourceManager, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, SimpleString managementAddress, SimpleString targetNodeId)
void	ScaleDownHandler.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 Pair

Constructor and Description
NamedNodeIdNodeLocator(String nodeID, Pair<TransportConfiguration,TransportConfiguration> liveConfiguration)

Uses of Pair in org.apache.activemq.artemis.jms.client

Methods in org.apache.activemq.artemis.jms.client that return Pair

Modifier and Type	Method and Description
static Pair<String,String>	ActiveMQDestination.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 Pair

Modifier and Type	Method and Description
static List<Pair<TransportConfiguration,TransportConfiguration>>	TransportConfigurationEncodingSupport.decodeConfigs(ActiveMQBuffer buffer)

Method parameters in org.apache.activemq.artemis.jms.server.config.impl with type arguments of type Pair

Modifier and Type	Method and Description
static void	TransportConfigurationEncodingSupport.encodeConfigs(ActiveMQBuffer buffer, List<Pair<TransportConfiguration,TransportConfiguration>> configs)
static int	TransportConfigurationEncodingSupport.getEncodeSize(List<Pair<TransportConfiguration,TransportConfiguration>> configs)

Uses of Pair in org.apache.activemq.artemis.reader

Methods in org.apache.activemq.artemis.reader that return Pair

Modifier and Type	Method and Description
static Pair<Integer,Integer>	StreamMessageUtil.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 Pair

Modifier and Type	Method and Description
void	TopologyResponseHandler.notifyNodeUp(long uniqueEventID, String backupGroupName, String scaleDownGroupName, String nodeName, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean isLast)