Modifier and Type | Method and Description |
---|---|
Pair<TransportConfiguration,TransportConfiguration> |
TopologyMemberImpl.getConnector() |
Modifier and Type | Method and Description |
---|---|
void |
ServerLocatorImpl.notifyNodeUp(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ServerLocatorInternal.notifyNodeUp(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
Modifier and Type | Method and Description |
---|---|
protected Pair<String,AddressSettings> |
FileConfigurationParser.parseAddressSettings(Node node) |
protected Pair<String,Set<Role>> |
FileConfigurationParser.parseSecurityRoles(Node node) |
Modifier and Type | Method and Description |
---|---|
Map<Pair<URI,Deployer>,FileDeploymentManager.DeployInfo> |
FileDeploymentManager.getDeployed() |
Modifier and Type | Method and Description |
---|---|
protected SequentialFile |
JournalImpl.createControlFile(List<JournalFile> files,
List<JournalFile> newFiles,
Pair<String,String> cleanupRename) |
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) |
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) |
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) |
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>> pendingLargeMessages) |
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>> pendingLargeMessages) |
Modifier and Type | Method and Description |
---|---|
Pair<RoutingContext,ServerMessage> |
PostOffice.redistribute(ServerMessage message,
Queue originatingQueue,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
void |
DuplicateIDCache.load(List<Pair<byte[],Long>> theIds) |
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
|
Modifier and Type | Method and Description |
---|---|
void |
DuplicateIDCacheImpl.load(List<Pair<byte[],Long>> theIds) |
Modifier and Type | Field and Description |
---|---|
protected Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.pair |
Modifier and Type | Method and Description |
---|---|
Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.getPair() |
Constructor and Description |
---|
ClusterTopologyChangeMessage_V2(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean last) |
ClusterTopologyChangeMessage(String nodeID,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean last) |
Modifier and Type | Method and Description |
---|---|
Map.Entry<Long,Pair<String,Long>> |
ReplicationManager.getNextLargeMessageToSync() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationManager.sendLargeMessageIdListMessage(Map<Long,Pair<String,Long>> largeMessages)
Reserves several LargeMessage IDs in the backup.
|
Modifier and Type | Method and Description |
---|---|
abstract Pair<TransportConfiguration,TransportConfiguration> |
LiveNodeLocator.getLiveConfiguration()
Returns the current connector
|
Modifier and Type | Method and Description |
---|---|
void |
HornetQServerLogger.deletingPendingMessage(Pair<Long,Long> msgToDelete) |
void |
HornetQServer.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean failBackRequest)
Starts replication.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterConnection.nodeAnnounced(long eventUID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterConnectionImpl.nodeAnnounced(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
Pair<TransportConfiguration,TransportConfiguration> |
AnyLiveNodeLocator.getLiveConfiguration() |
Pair<TransportConfiguration,TransportConfiguration> |
NamedLiveNodeLocator.getLiveConfiguration() |
Modifier and Type | Method and Description |
---|---|
void |
HornetQServerImpl.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean isFailBackRequest) |
Modifier and Type | Method and Description |
---|---|
static Pair<String,String> |
HornetQDestination.decomposeQueueNameForDurableSubscription(String queueName) |
Copyright © 2014 JBoss, a division of Red Hat. All rights reserved.