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 | Method and Description |
---|---|
UUID |
NodeManager.getUUID() |
Modifier and Type | Method and Description |
---|---|
protected void |
NodeManager.setUUID(UUID generateUUID) |
Modifier and Type | Method and Description |
---|---|
static byte[] |
BridgeImpl.getDuplicateBytes(UUID nodeUUID,
long messageID) |
Constructor and Description |
---|
BridgeImpl(ServerLocatorInternal serverLocator,
int reconnectAttempts,
int initialConnectAttempts,
int reconnectAttemptsSameNode,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
SimpleString name,
Queue queue,
Executor executor,
Filter filter,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
boolean activated,
StorageManager storageManager) |
BridgeImpl(ServerLocatorInternal serverLocator,
int reconnectAttempts,
int reconnectAttemptsSameNode,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
SimpleString name,
Queue queue,
Executor executor,
Filter filter,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
boolean activated,
StorageManager storageManager) |
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManager 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,
Filter 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) |
Modifier and Type | Method and Description |
---|---|
UUID |
UUIDGenerator.generateTimeBasedUUID(byte[] byteAddr) |
UUID |
UUIDGenerator.generateUUID() |
Copyright © 2018 JBoss by Red Hat. All rights reserved.