Uses of Class
org.hornetq.api.core.Pair

Packages that use Pair

Package	Description
org.hornetq.api.core.client	Core Client Messaging API.
org.hornetq.core.client.impl
org.hornetq.core.deployers.impl
org.hornetq.core.journal.impl
org.hornetq.core.paging
org.hornetq.core.persistence
org.hornetq.core.persistence.impl.journal
org.hornetq.core.persistence.impl.nullpm
org.hornetq.core.postoffice
org.hornetq.core.postoffice.impl
org.hornetq.core.protocol.core.impl.wireformat
org.hornetq.core.server.cluster
org.hornetq.core.server.cluster.impl
org.hornetq.jms.client	Implementation of the JMS API.
org.hornetq.jms.server.config.impl
org.hornetq.jms.server.recovery	This package is used to locate resources and connectors along the cluster set I - JCA Connection Factories or InBound MDBs will call HornetQRegistryBase::register(XARecoveryConfig) II - For each XARecoveryConfig the RegistryBase will instantiate a ResourceDiscoveryUnit which will connect using that configuration and inform the Registry of any topology members III - For each topology member found on the DiscoveryUnits, the RegistryBase will registry a HornetQResourceRecovery that will exist per server

Uses of Pair in org.hornetq.api.core.client

Methods in org.hornetq.api.core.client with parameters of type Pair

Modifier and Type	Method and Description
void	ClusterTopologyListener.nodeUP(long eventUID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)

Uses of Pair in org.hornetq.core.client.impl

Methods in org.hornetq.core.client.impl that return Pair

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

Methods in org.hornetq.core.client.impl with parameters of type Pair

Modifier and Type	Method and Description
void	ServerLocatorInternal.notifyNodeUp(long uniqueEventID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)
void	ServerLocatorImpl.notifyNodeUp(long uniqueEventID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)

Constructors in org.hornetq.core.client.impl with parameters of type Pair

Constructor and Description
TopologyMember(Pair<TransportConfiguration,TransportConfiguration> connector)

Uses of Pair in org.hornetq.core.deployers.impl

Methods in org.hornetq.core.deployers.impl that return Pair

Modifier and Type	Method and Description
Pair<String,AddressSettings>	FileConfigurationParser.parseAddressSettings(Node node)
Pair<String,Set<Role>>	FileConfigurationParser.parseSecurityRoles(Node node)

Methods in org.hornetq.core.deployers.impl that return types with arguments of type Pair

Modifier and Type	Method and Description
Map<Pair<URL,Deployer>,FileDeploymentManager.DeployInfo>	FileDeploymentManager.getDeployed()

Uses of Pair in org.hornetq.core.journal.impl

Methods in org.hornetq.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.hornetq.core.journal.impl with type arguments of type Pair

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

Uses of Pair in org.hornetq.core.paging

Methods in org.hornetq.core.paging that return Pair

Modifier and Type	Method and Description
protected static Pair<Map<Long,Set<PagePosition>>,Set<Long>>	PrintPages.loadCursorACKs(String journalLocation)

Uses of Pair in org.hornetq.core.persistence

Method parameters in org.hornetq.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,Queue> queues, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLargeMessages)
JournalLoadInformation	StorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,Queue> queues, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLargeMessages)

Uses of Pair in org.hornetq.core.persistence.impl.journal

Method parameters in org.hornetq.core.persistence.impl.journal with type arguments of type Pair

Modifier and Type	Method and Description
JournalLoadInformation	JournalStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,Queue> queues, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLargeMessages)
JournalLoadInformation	JournalStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,Queue> queues, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLargeMessages)

Uses of Pair in org.hornetq.core.persistence.impl.nullpm

Method parameters in org.hornetq.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,Queue> queues, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLM)
JournalLoadInformation	NullStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,Queue> queues, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLM)

Uses of Pair in org.hornetq.core.postoffice

Methods in org.hornetq.core.postoffice that return Pair

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

Method parameters in org.hornetq.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.hornetq.core.postoffice.impl

Methods in org.hornetq.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

Method parameters in org.hornetq.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.hornetq.core.protocol.core.impl.wireformat

Fields in org.hornetq.core.protocol.core.impl.wireformat declared as Pair

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

Methods in org.hornetq.core.protocol.core.impl.wireformat that return Pair

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

Constructors in org.hornetq.core.protocol.core.impl.wireformat with parameters of type Pair

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

Uses of Pair in org.hornetq.core.server.cluster

Methods in org.hornetq.core.server.cluster with parameters of type Pair

Modifier and Type	Method and Description
void	ClusterConnection.nodeAnnounced(long eventUID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean backup)

Uses of Pair in org.hornetq.core.server.cluster.impl

Methods in org.hornetq.core.server.cluster.impl with parameters of type Pair

Modifier and Type	Method and Description
void	ClusterConnectionImpl.nodeAnnounced(long uniqueEventID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean backup)
void	ClusterConnectionImpl.nodeUP(long eventUID, String nodeID, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean last)

Uses of Pair in org.hornetq.jms.client

Methods in org.hornetq.jms.client that return Pair

Modifier and Type	Method and Description
static Pair<String,String>	HornetQDestination.decomposeQueueNameForDurableSubscription(String queueName)

Uses of Pair in org.hornetq.jms.server.config.impl

Methods in org.hornetq.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(HornetQBuffer buffer)

Method parameters in org.hornetq.jms.server.config.impl with type arguments of type Pair

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

Uses of Pair in org.hornetq.jms.server.recovery

Methods in org.hornetq.jms.server.recovery with parameters of type Pair

Modifier and Type	Method and Description
void	HornetQRecoveryRegistry.nodeUp(String nodeID, Pair<TransportConfiguration,TransportConfiguration> networkConfiguration, String username, String password)