Package | Description |
---|---|
org.hornetq.api.core |
Core Messaging API.
|
org.hornetq.core.message.impl | |
org.hornetq.core.server | |
org.hornetq.core.server.cluster.impl | |
org.hornetq.utils |
Utilities and helper classes.
|
Modifier and Type | Method and Description |
---|---|
UUID |
Message.getUserID()
Returns the userID - this is an optional user specified UUID that can be set to identify the message
and will be passed around with the message
|
Modifier and Type | Method and Description |
---|---|
void |
Message.setUserID(UUID userID)
Sets the user ID
|
Modifier and Type | Method and Description |
---|---|
UUID |
MessageImpl.getUserID() |
Modifier and Type | Method and Description |
---|---|
void |
MessageImpl.setUserID(UUID userID) |
Modifier and Type | Field and Description |
---|---|
protected UUID |
NodeManager.uuid |
Modifier and Type | Method and Description |
---|---|
UUID |
NodeManager.getUUID() |
Modifier and Type | Method and Description |
---|---|
static byte[] |
BridgeImpl.getDuplicateBytes(UUID nodeUUID,
long messageID) |
Constructor and Description |
---|
BridgeImpl(ServerLocatorInternal serverLocator,
int reconnectAttempts,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
SimpleString name,
Queue queue,
Executor executor,
SimpleString filterString,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
boolean activated,
StorageManager storageManager) |
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManagerInternal clusterManager,
ServerLocatorInternal targetLocator,
ServerLocatorInternal discoveryLocator,
int reconnectAttempts,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
long targetNodeEventUID,
String targetNodeID,
SimpleString name,
Queue queue,
Executor executor,
SimpleString filterString,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
boolean activated,
StorageManager storageManager,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector) |
ClusterConnectionImpl(ClusterManagerImpl manager,
DiscoveryGroupConfiguration dg,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
long callTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
UUID nodeUUID,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly) |
ClusterConnectionImpl(ClusterManagerInternal manager,
TransportConfiguration[] tcConfigs,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
long callTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
UUID nodeUUID,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly) |
ClusterManagerImpl(ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
Configuration configuration,
UUID nodeUUID,
boolean backup,
boolean clustered) |
Modifier and Type | Method and Description |
---|---|
UUID |
UUIDGenerator.generateTimeBasedUUID(byte[] byteAddr) |
UUID |
UUIDGenerator.generateUUID() |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.