Uses of Class
org.apache.activemq.artemis.api.core.Pair
-
-
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 Description Pair<TransportConfiguration,TransportConfiguration>TopologyMemberImpl. getConnector()Methods in org.apache.activemq.artemis.core.client.impl with parameters of type Pair Modifier and Type Method Description voidServerLocatorImpl. 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 Pair Modifier and Type Method Description protected Pair<String,AddressSettings>FileConfigurationParser. parseAddressSettings(Node node)protected Pair<String,Set<Role>>FileConfigurationParser. parseSecurityRoles(Node node, Map<String,Set<String>> roleMappings) -
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 Description protected 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 Pair Modifier and Type Method Description 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) -
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 Description JournalLoadInformationAbstractJournalStorageManager. 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 Description JournalLoadInformationNullStorageManager. 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 Description Pair<RoutingContext,Message>PostOffice. redistribute(Message 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 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 Description voidDuplicateIDCache. load(List<Pair<byte[],Long>> ids) -
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 Description Pair<RoutingContext,Message>PostOfficeImpl. redistribute(Message 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 threadMethods in org.apache.activemq.artemis.core.postoffice.impl that return types with arguments of type Pair Modifier and Type Method Description List<Pair<byte[],Long>>NoOpDuplicateIDCache. getMap()Method parameters in org.apache.activemq.artemis.core.postoffice.impl with type arguments of type Pair Modifier and Type Method Description voidNoOpDuplicateIDCache. load(List<Pair<byte[],Long>> ids) -
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 Description static Pair<TransportConfiguration,TransportConfiguration>BackwardsCompatibilityUtils. 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 Pair Modifier and Type Field Description protected Pair<TransportConfiguration,TransportConfiguration>ClusterTopologyChangeMessage. pairMethods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return Pair Modifier and Type Method Description Pair<TransportConfiguration,TransportConfiguration>ClusterTopologyChangeMessage. getPair() -
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 Modifier and Type Method Description static Pair<String,String>SSLSupport. getValidProviderAndType(String storeProvider, String storeType)The changes ARTEMIS-3155 introduced an incompatibility with old clients using the keyStoreProvider and trustStoreProvider URL properties. -
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 Description voidReplicationManager. 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 Description Pair<Boolean,Boolean>Queue. checkRedelivery(MessageReference ref, long timeBase, boolean ignoreRedeliveryDelay)Pair<SimpleString,EnumSet<RoutingType>>ServerSession. getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes)Get the canonical (i.e.abstract Pair<TransportConfiguration,TransportConfiguration>LiveNodeLocator. getLiveConfiguration()Returns the current connectorMethods in org.apache.activemq.artemis.core.server that return types with arguments of type Pair Modifier and Type Method 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 Description voidActiveMQServerLogger_$logger. 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 Pair Modifier and Type Method Description voidClusterConnection. 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 Description booleanColocatedHAManager. 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 Description voidClusterConnectionImpl. 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 Description protected Map<SimpleString,Pair<Object,AtomicLong>>ServerSessionImpl. targetAddressInfosMethods in org.apache.activemq.artemis.core.server.impl that return types with arguments of type Pair Modifier and Type Method Description Map<SimpleString,Pair<Object,AtomicLong>>ServerSessionImpl. cloneTargetAddresses()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 Description voidSharedNothingLiveActivation. 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 Description voidBackupRecoveryJournalLoader. 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 Pair Constructor 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 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 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 Description static 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 Pair Modifier and Type Method 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 Description voidTopologyResponseHandler. 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 Pair Modifier and Type Method Description static Pair<SimpleString,EnumSet<RoutingType>>PrefixUtil. getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes, Map<SimpleString,RoutingType> prefixes)
-