Modifier and Type | Method and Description |
---|---|
static SimpleString |
HornetQDefaultConfiguration.getDefaultManagementAddress()
the name of the management address to send management messages to.
|
static SimpleString |
HornetQDefaultConfiguration.getDefaultManagementNotificationAddress()
the name of the address that consumers bind to receive management notifications
|
Modifier and Type | Field and Description |
---|---|
static SimpleString |
FilterConstants.DURABLE
Value for the Durable header when the message is durable.
|
static SimpleString |
Message.HDR_ACTUAL_EXPIRY_TIME |
static SimpleString |
Message.HDR_DUPLICATE_DETECTION_ID |
static SimpleString |
Message.HDR_GROUP_ID |
static SimpleString |
Message.HDR_LARGE_BODY_SIZE |
static SimpleString |
Message.HDR_LARGE_COMPRESSED |
static SimpleString |
Message.HDR_LAST_VALUE_NAME |
static SimpleString |
Message.HDR_ORIG_MESSAGE_ID |
static SimpleString |
Message.HDR_ORIGINAL_ADDRESS |
static SimpleString |
Message.HDR_ORIGINAL_QUEUE |
static SimpleString |
Message.HDR_SCHEDULED_DELIVERY_TIME |
static SimpleString |
FilterConstants.HORNETQ_DURABLE
Name of the HornetQ Message durable header.
|
static SimpleString |
FilterConstants.HORNETQ_EXPIRATION
Name of the HornetQ Message expiration header.
|
static SimpleString |
FilterConstants.HORNETQ_PREFIX
All HornetQ headers are prepended by this prefix.
|
static SimpleString |
FilterConstants.HORNETQ_PRIORITY
Name of the HornetQ Message priority header.
|
static SimpleString |
FilterConstants.HORNETQ_SIZE
Name of the HornetQ Message size header.
|
static SimpleString |
FilterConstants.HORNETQ_TIMESTAMP
Name of the HornetQ Message timestamp header.
|
static SimpleString |
FilterConstants.HORNETQ_USERID
Name of the HornetQ UserID header.
|
static SimpleString |
FilterConstants.NON_DURABLE
Value for the Durable header when the message is non-durable.
|
Modifier and Type | Method and Description |
---|---|
SimpleString |
SimpleString.concat(char c)
Concatenates a SimpleString and a char
|
SimpleString |
SimpleString.concat(SimpleString toAdd)
Concatenates 2 SimpleString's
|
SimpleString |
SimpleString.concat(String toAdd)
Concatenates a SimpleString and a String
|
SimpleString |
Message.getAddress()
Returns the address this message is sent to.
|
SimpleString |
Message.getSimpleStringProperty(SimpleString key)
Returns the property corresponding to the specified key as a SimpleString.
|
SimpleString |
Message.getSimpleStringProperty(String key) |
SimpleString |
HornetQBuffer.readNullableSimpleString()
Gets a SimpleString (potentially
null ) at the current readerIndex |
SimpleString |
HornetQBuffer.readSimpleString()
Gets a non-null SimpleString at the current
readerIndex |
SimpleString[] |
SimpleString.split(char delim)
Splits this SimpleString into an array of SimpleString using the char param as the delimiter.
|
static SimpleString |
SimpleString.toSimpleString(String string)
Returns a SimpleString constructed from the
string parameter. |
Modifier and Type | Method and Description |
---|---|
Set<SimpleString> |
Message.getPropertyNames()
Returns all the names of the properties for this message.
|
Modifier and Type | Method and Description |
---|---|
int |
SimpleString.compareTo(SimpleString o) |
SimpleString |
SimpleString.concat(SimpleString toAdd)
Concatenates 2 SimpleString's
|
boolean |
Message.containsProperty(SimpleString key)
Returns
true if this message contains a property with the given key, false else. |
Boolean |
Message.getBooleanProperty(SimpleString key)
Returns the property corresponding to the specified key as a Boolean.
|
Byte |
Message.getByteProperty(SimpleString key)
Returns the property corresponding to the specified key as a Byte.
|
byte[] |
Message.getBytesProperty(SimpleString key)
Returns the property corresponding to the specified key as a byte[].
|
Double |
Message.getDoubleProperty(SimpleString key)
Returns the property corresponding to the specified key as a Double.
|
Float |
Message.getFloatProperty(SimpleString key)
Returns the property corresponding to the specified key as a Float.
|
Integer |
Message.getIntProperty(SimpleString key)
Returns the property corresponding to the specified key as an Integer.
|
Long |
Message.getLongProperty(SimpleString key)
Returns the property corresponding to the specified key as a Long.
|
Object |
Message.getObjectProperty(SimpleString key)
Returns the property corresponding to the specified key
|
Short |
Message.getShortProperty(SimpleString key)
Returns the property corresponding to the specified key as a Short.
|
SimpleString |
Message.getSimpleStringProperty(SimpleString key)
Returns the property corresponding to the specified key as a SimpleString.
|
String |
Message.getStringProperty(SimpleString key)
Returns the property corresponding to the specified key as a String.
|
Message |
Message.putBooleanProperty(SimpleString key,
boolean value)
Puts a boolean property in this message.
|
Message |
Message.putByteProperty(SimpleString key,
byte value)
Puts a byte property in this message.
|
Message |
Message.putBytesProperty(SimpleString key,
byte[] value)
Puts a byte[] property in this message.
|
Message |
Message.putCharProperty(SimpleString key,
char value)
Puts a char property in this message.
|
Message |
Message.putDoubleProperty(SimpleString key,
double value)
Puts a double property in this message.
|
Message |
Message.putFloatProperty(SimpleString key,
float value)
Puts a float property in this message.
|
Message |
Message.putIntProperty(SimpleString key,
int value)
Puts a int property in this message.
|
Message |
Message.putLongProperty(SimpleString key,
long value)
Puts a long property in this message.
|
Message |
Message.putObjectProperty(SimpleString key,
Object value)
Puts an Object property in this message.
|
Message |
Message.putShortProperty(SimpleString key,
short value)
Puts a short property in this message.
|
Message |
Message.putStringProperty(SimpleString key,
SimpleString value)
Puts a SimpleString property in this message.
|
Object |
Message.removeProperty(SimpleString key)
Removes the property corresponding to the specified key.
|
Message |
Message.setAddress(SimpleString address)
Sets the address to send this message to.
|
static int |
SimpleString.sizeofNullableString(SimpleString str)
returns the size of a SimpleString which could be null
|
static int |
SimpleString.sizeofString(SimpleString str)
returns the size of a SimpleString
|
boolean |
SimpleString.startsWith(SimpleString other)
returns true if the SimpleString parameter starts with the same data as this one.
|
void |
HornetQBuffer.writeNullableSimpleString(SimpleString val)
Sets the specified SimpleString (potentially
null ) at the current writerIndex |
void |
HornetQBuffer.writeSimpleString(SimpleString val)
Sets the specified non-null SimpleString at the current
writerIndex |
Modifier and Type | Method and Description |
---|---|
SimpleString |
ClientSession.QueueQuery.getAddress()
Returns the address that the queue is bound to.
|
SimpleString |
ClientProducer.getAddress()
Returns the address where messages will be sent.
|
SimpleString |
ClientSession.QueueQuery.getFilterString()
Returns the queue's filter string (or
null if the queue has no filter). |
Modifier and Type | Method and Description |
---|---|
List<SimpleString> |
ClientSession.BindingQuery.getQueueNames()
Returns the names of the queues bound to the binding.
|
Modifier and Type | Method and Description |
---|---|
ClientSession.BindingQuery |
ClientSession.bindingQuery(SimpleString address)
Queries information on a binding.
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName)
Creates a ClientConsumer to consume message from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName,
SimpleString filter)
Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName,
SimpleString filter,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with
the given name.
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName,
SimpleString filter,
int windowSize,
int maxRate,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with
the given name.
|
ClientProducer |
ClientSession.createProducer(SimpleString address)
Creates a producer which sends messages to the given address
|
ClientProducer |
ClientSession.createProducer(SimpleString address,
int rate)
Creates a producer which sends messages to the given address
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName)
Creates a non-temporary queue non-durable queue.
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSession.createSharedQueue(SimpleString address,
SimpleString queueName,
boolean durable)
Creates a transient queue.
|
void |
ClientSession.createSharedQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a transient queue.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
SimpleString queueName)
Creates a temporary queue.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
SimpleString queueName,
SimpleString filter)
Creates a temporary queue with a filter.
|
void |
ClientSession.deleteQueue(SimpleString queueName)
Deletes the queue.
|
ClientSession.QueueQuery |
ClientSession.queueQuery(SimpleString queueName)
Queries information on a queue.
|
void |
ClientProducer.send(SimpleString address,
Message message)
Sends a message to the specified address instead of the ClientProducer's address.
|
void |
ClientProducer.send(SimpleString address,
Message message,
SendAcknowledgementHandler handler)
Sends a message to the specified address instead of the ClientProducer's address.
|
Constructor and Description |
---|
ClientRequestor(ClientSession session,
SimpleString requestAddress)
Constructor for the ClientRequestor.
|
Modifier and Type | Method and Description |
---|---|
ObjectName |
ObjectNameBuilder.getAddressObjectName(SimpleString address)
Returns the ObjectName used by AddressControl.
|
ObjectName |
ObjectNameBuilder.getQueueObjectName(SimpleString address,
SimpleString name)
Returns the ObjectName used by QueueControl.
|
Modifier and Type | Method and Description |
---|---|
SimpleString |
ChannelBufferWrapper.readNullableSimpleString() |
SimpleString |
ChannelBufferWrapper.readSimpleString() |
Modifier and Type | Method and Description |
---|---|
void |
ResetLimitWrappedHornetQBuffer.writeNullableSimpleString(SimpleString val) |
void |
ChannelBufferWrapper.writeNullableSimpleString(SimpleString val) |
void |
ResetLimitWrappedHornetQBuffer.writeSimpleString(SimpleString val) |
void |
ChannelBufferWrapper.writeSimpleString(SimpleString val) |
Modifier and Type | Field and Description |
---|---|
static SimpleString |
ClientConsumerImpl.FORCED_DELIVERY_MESSAGE |
static SimpleString |
ClientMessageImpl.REPLYTO_HEADER_NAME |
Modifier and Type | Method and Description |
---|---|
SimpleString |
ClientProducerImpl.getAddress() |
SimpleString |
ClientConsumerImpl.getFilterString() |
SimpleString |
ClientConsumerInternal.getFilterString() |
SimpleString |
ClientConsumerImpl.getQueueName() |
SimpleString |
ClientConsumerInternal.getQueueName() |
SimpleString |
LargeMessageControllerImpl.readNullableSimpleString() |
SimpleString |
LargeMessageControllerImpl.readSimpleString() |
Modifier and Type | Method and Description |
---|---|
ClientSession.BindingQuery |
ClientSessionImpl.bindingQuery(SimpleString address) |
ClientSession.BindingQuery |
DelegatingSession.bindingQuery(SimpleString address) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName) |
ClientConsumer |
DelegatingSession.createConsumer(SimpleString queueName) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
boolean browseOnly) |
ClientConsumer |
DelegatingSession.createConsumer(SimpleString queueName,
boolean browseOnly) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
SimpleString filterString) |
ClientConsumer |
DelegatingSession.createConsumer(SimpleString queueName,
SimpleString filterString) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
ClientConsumer |
DelegatingSession.createConsumer(SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
boolean browseOnly)
Note, we DO NOT currently support direct consumers (i.e.
|
ClientConsumer |
DelegatingSession.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
boolean browseOnly) |
ClientProducer |
ClientSessionImpl.createProducer(SimpleString address) |
ClientProducer |
DelegatingSession.createProducer(SimpleString address) |
ClientProducer |
ClientSessionImpl.createProducer(SimpleString address,
int maxRate) |
ClientProducer |
DelegatingSession.createProducer(SimpleString address,
int rate) |
void |
ClientSessionImpl.createQueue(SimpleString address,
SimpleString queueName) |
void |
DelegatingSession.createQueue(SimpleString address,
SimpleString queueName) |
void |
ClientSessionImpl.createQueue(SimpleString address,
SimpleString queueName,
boolean durable) |
void |
DelegatingSession.createQueue(SimpleString address,
SimpleString queueName,
boolean durable) |
void |
ClientSessionImpl.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable) |
void |
DelegatingSession.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable) |
void |
ClientSessionImpl.createSharedQueue(SimpleString address,
SimpleString queueName,
boolean durable) |
void |
DelegatingSession.createSharedQueue(SimpleString address,
SimpleString queueName,
boolean durable) |
void |
ClientSessionImpl.createSharedQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable) |
void |
DelegatingSession.createSharedQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
SimpleString queueName) |
void |
DelegatingSession.createTemporaryQueue(SimpleString address,
SimpleString queueName) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
SimpleString queueName,
SimpleString filter) |
void |
DelegatingSession.createTemporaryQueue(SimpleString address,
SimpleString queueName,
SimpleString filter) |
void |
ClientSessionImpl.deleteQueue(SimpleString queueName) |
void |
DelegatingSession.deleteQueue(SimpleString queueName) |
ClientProducerCredits |
ClientProducerCreditManagerImpl.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientSessionImpl.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientProducerCreditManager.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
DelegatingSession.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientSessionInternal.getCredits(SimpleString address,
boolean anon) |
void |
ClientSessionImpl.handleReceiveProducerCredits(SimpleString address,
int credits) |
void |
DelegatingSession.handleReceiveProducerCredits(SimpleString address,
int credits) |
void |
ClientSessionInternal.handleReceiveProducerCredits(SimpleString address,
int credits) |
void |
ClientSessionImpl.handleReceiveProducerFailCredits(SimpleString address,
int credits) |
void |
DelegatingSession.handleReceiveProducerFailCredits(SimpleString address,
int credits) |
void |
ClientSessionInternal.handleReceiveProducerFailCredits(SimpleString address,
int credits) |
ClientSession.QueueQuery |
ClientSessionImpl.queueQuery(SimpleString queueName) |
ClientSession.QueueQuery |
DelegatingSession.queueQuery(SimpleString queueName) |
void |
ClientProducerCreditManagerImpl.receiveCredits(SimpleString address,
int credits) |
void |
ClientProducerCreditManager.receiveCredits(SimpleString address,
int credits) |
void |
ClientProducerCreditManagerImpl.receiveFailCredits(SimpleString address,
int credits) |
void |
ClientProducerCreditManager.receiveFailCredits(SimpleString address,
int credits) |
void |
ClientProducerCreditManagerImpl.returnCredits(SimpleString address) |
void |
ClientSessionImpl.returnCredits(SimpleString address) |
void |
ClientProducerCreditManager.returnCredits(SimpleString address) |
void |
DelegatingSession.returnCredits(SimpleString address) |
void |
ClientSessionInternal.returnCredits(SimpleString address) |
void |
ClientProducerImpl.send(SimpleString address1,
Message msg) |
void |
ClientProducerImpl.send(SimpleString address1,
Message message,
SendAcknowledgementHandler handler) |
void |
ClientSessionImpl.sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
DelegatingSession.sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
ClientSessionInternal.sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
ClientSessionImpl.setAddress(Message message,
SimpleString address) |
void |
DelegatingSession.setAddress(Message message,
SimpleString address) |
void |
ClientSessionInternal.setAddress(Message message,
SimpleString address) |
void |
LargeMessageControllerImpl.writeNullableSimpleString(SimpleString val) |
void |
LargeMessageControllerImpl.writeSimpleString(SimpleString val) |
Constructor and Description |
---|
ClientConsumerImpl(ClientSessionInternal session,
long id,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
int clientWindowSize,
int ackBatchSize,
TokenBucketLimiter rateLimiter,
Executor executor,
Executor flowControlExecutor,
Channel channel,
SessionQueueQueryResponseMessage queueInfo,
ClassLoader contextClassLoader) |
ClientProducerCreditsImpl(ClientSessionInternal session,
SimpleString address,
int windowSize) |
ClientProducerImpl(ClientSessionInternal session,
SimpleString address,
TokenBucketLimiter rateLimiter,
boolean blockOnNonDurableSend,
boolean blockOnDurableSend,
boolean autoGroup,
SimpleString groupID,
int minLargeMessageSize,
Channel channel) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
Configuration.getManagementAddress()
Returns the management address of this server.
|
SimpleString |
Configuration.getManagementNotificationAddress()
Returns the management notification address of this server.
|
Modifier and Type | Method and Description |
---|---|
void |
Configuration.setManagementAddress(SimpleString address)
Sets the management address of this server.
|
void |
Configuration.setManagementNotificationAddress(SimpleString address)
Sets the management notification address of this server.
|
Modifier and Type | Method and Description |
---|---|
SimpleString |
ConfigurationImpl.getManagementAddress() |
SimpleString |
ConfigurationImpl.getManagementNotificationAddress() |
Modifier and Type | Method and Description |
---|---|
void |
ConfigurationImpl.setManagementAddress(SimpleString address) |
void |
ConfigurationImpl.setManagementNotificationAddress(SimpleString address) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
Filter.getFilterString() |
Modifier and Type | Method and Description |
---|---|
SimpleString |
FilterImpl.getFilterString() |
SimpleString |
Identifier.getName() |
Modifier and Type | Method and Description |
---|---|
static Filter |
FilterImpl.createFilter(SimpleString filterStr) |
static Object |
FilterParser.doParse(SimpleString selector,
Map<SimpleString,Identifier> identifierMap) |
static Object |
FilterParser.doParse(SimpleString selector,
Map<SimpleString,Identifier> identifierMap,
boolean trace) |
Object |
FilterParser.parse(SimpleString selector,
Map<SimpleString,Identifier> identifierMap) |
Object |
FilterParser.parse(SimpleString selector,
Map<SimpleString,Identifier> identifierMap,
boolean trace) |
Modifier and Type | Method and Description |
---|---|
static Object |
FilterParser.doParse(SimpleString selector,
Map<SimpleString,Identifier> identifierMap) |
static Object |
FilterParser.doParse(SimpleString selector,
Map<SimpleString,Identifier> identifierMap,
boolean trace) |
Object |
FilterParser.parse(SimpleString selector,
Map<SimpleString,Identifier> identifierMap) |
Object |
FilterParser.parse(SimpleString selector,
Map<SimpleString,Identifier> identifierMap,
boolean trace) |
void |
FilterParser.stringList(Set<SimpleString> set) |
void |
FilterParser.stringToken(Set<SimpleString> set) |
Constructor and Description |
---|
Identifier(SimpleString name) |
Constructor and Description |
---|
AddressControlImpl(SimpleString address,
PostOffice postOffice,
PagingManager pagingManager,
StorageManager storageManager,
HierarchicalRepository<Set<Role>> securityRepository) |
Modifier and Type | Field and Description |
---|---|
protected SimpleString |
MessageImpl.address |
static SimpleString |
MessageImpl.HDR_BRIDGE_DUPLICATE_ID |
static SimpleString |
MessageImpl.HDR_ROUTE_TO_IDS |
Modifier and Type | Method and Description |
---|---|
SimpleString |
MessageImpl.getAddress()
this doesn't need to be synchronized as setAddress is protecting the buffer,
not the address
|
SimpleString |
MessageImpl.getSimpleStringProperty(SimpleString key) |
SimpleString |
MessageImpl.getSimpleStringProperty(String key) |
Modifier and Type | Method and Description |
---|---|
Set<SimpleString> |
MessageImpl.getPropertyNames() |
Modifier and Type | Method and Description |
---|---|
SimpleString |
PagingStore.getAddress() |
SimpleString |
PagingStore.getStoreName() |
SimpleString[] |
PagingManager.getStoreNames() |
Modifier and Type | Method and Description |
---|---|
void |
PagingManager.deletePageStore(SimpleString storeName) |
PagingStore |
PagingManager.getPageStore(SimpleString address)
Returns the PageStore associated with the address.
|
SequentialFileFactory |
PagingStoreFactory.newFileFactory(SimpleString address) |
PagingStore |
PagingStoreFactory.newStore(SimpleString address,
AddressSettings addressSettings) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
PagingStoreImpl.getAddress() |
SimpleString |
PagingStoreImpl.getStoreName() |
SimpleString[] |
PagingManagerImpl.getStoreNames() |
Modifier and Type | Method and Description |
---|---|
void |
PagingManagerImpl.deletePageStore(SimpleString storeName) |
PagingStore |
PagingManagerImpl.getPageStore(SimpleString storeName)
stores is a ConcurrentHashMap, so we don't need to synchronize this method
|
SequentialFileFactory |
PagingStoreFactoryNIO.newFileFactory(SimpleString address) |
PagingStore |
PagingStoreFactoryNIO.newStore(SimpleString address,
AddressSettings settings) |
Constructor and Description |
---|
Page(SimpleString storeName,
StorageManager storageManager,
SequentialFileFactory factory,
SequentialFile file,
int pageId) |
PagingStoreImpl(SimpleString address,
ScheduledExecutorService scheduledExecutor,
long syncTimeout,
PagingManager pagingManager,
StorageManager storageManager,
SequentialFileFactory fileFactory,
PagingStoreFactory storeFactory,
SimpleString storeName,
AddressSettings addressSettings,
Executor executor,
boolean syncNonTransactional) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
QueueBindingInfo.getAddress() |
SimpleString |
GroupingInfo.getClusterName() |
SimpleString |
QueueBindingInfo.getFilterString() |
SimpleString |
GroupingInfo.getGroupId() |
SimpleString |
QueueBindingInfo.getQueueName() |
Modifier and Type | Method and Description |
---|---|
void |
StorageManager.deleteAddressSetting(SimpleString addressMatch) |
void |
StorageManager.deleteSecurityRoles(SimpleString addressMatch) |
void |
StorageManager.pageClosed(SimpleString storeName,
int pageNumber) |
void |
StorageManager.pageDeleted(SimpleString storeName,
int pageNumber) |
void |
QueueBindingInfo.replaceQueueName(SimpleString newName)
used to rename the queue in case of a duplication during load time
|
void |
StorageManager.storeDuplicateID(SimpleString address,
byte[] duplID,
long recordID) |
void |
StorageManager.storeDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID) |
void |
StorageManager.updateDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
StorageManager.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) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
PersistedAddressSetting.getAddressMatch() |
SimpleString |
PersistedRoles.getAddressMatch() |
Constructor and Description |
---|
PersistedAddressSetting(SimpleString addressMatch,
AddressSettings setting) |
Modifier and Type | Field and Description |
---|---|
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.address |
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.filterString |
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.name |
Modifier and Type | Method and Description |
---|---|
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.getAddress() |
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.getFilterString() |
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.getQueueName() |
Modifier and Type | Method and Description |
---|---|
void |
JournalStorageManager.deleteAddressSetting(SimpleString addressMatch) |
void |
JournalStorageManager.deleteSecurityRoles(SimpleString addressMatch) |
void |
JournalStorageManager.pageClosed(SimpleString storeName,
int pageNumber) |
void |
JournalStorageManager.pageDeleted(SimpleString storeName,
int pageNumber) |
void |
JournalStorageManager.PersistentQueueBindingEncoding.replaceQueueName(SimpleString newName) |
void |
JournalStorageManager.storeDuplicateID(SimpleString address,
byte[] duplID,
long recordID) |
void |
JournalStorageManager.storeDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID) |
void |
JournalStorageManager.updateDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
JournalStorageManager.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) |
Constructor and Description |
---|
DuplicateIDEncoding(SimpleString address,
byte[] duplID) |
PersistentQueueBindingEncoding(SimpleString name,
SimpleString address,
SimpleString filterString) |
Modifier and Type | Method and Description |
---|---|
void |
NullStorageManager.deleteAddressSetting(SimpleString addressMatch) |
void |
NullStorageManager.deleteSecurityRoles(SimpleString addressMatch) |
void |
NullStorageManager.pageClosed(SimpleString storeName,
int pageNumber) |
void |
NullStorageManager.pageDeleted(SimpleString storeName,
int pageNumber) |
void |
NullStorageManager.storeDuplicateID(SimpleString address,
byte[] duplID,
long recordID) |
void |
NullStorageManager.storeDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID) |
void |
NullStorageManager.updateDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
NullStorageManager.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) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
Address.getAddress() |
SimpleString |
Binding.getAddress() |
SimpleString |
QueueInfo.getAddress() |
SimpleString[] |
Address.getAddressParts() |
SimpleString |
Binding.getClusterName() |
SimpleString |
QueueInfo.getClusterName() |
SimpleString |
QueueInfo.getFilterString() |
SimpleString |
Binding.getRoutingName() |
SimpleString |
QueueInfo.getRoutingName() |
SimpleString |
Binding.getUniqueName() |
Modifier and Type | Method and Description |
---|---|
Map<SimpleString,Binding> |
AddressManager.getBindings() |
List<SimpleString> |
QueueInfo.getFilterStrings() |
Modifier and Type | Method and Description |
---|---|
Bindings |
BindingsFactory.createBindings(SimpleString address) |
Binding |
PostOffice.getBinding(SimpleString uniqueName) |
Binding |
AddressManager.getBinding(SimpleString queueName) |
Bindings |
PostOffice.getBindingsForAddress(SimpleString address)
Differently to lookupBindings, this will always create a new element on the Queue if non-existent
|
Bindings |
AddressManager.getBindingsForRoutingAddress(SimpleString address) |
DuplicateIDCache |
PostOffice.getDuplicateIDCache(SimpleString address) |
Bindings |
PostOffice.getMatchingBindings(SimpleString address) |
Bindings |
AddressManager.getMatchingBindings(SimpleString address) |
Bindings |
PostOffice.lookupBindingsForAddress(SimpleString address)
It will lookup the Binding without creating an item on the Queue if non-existent
|
Binding |
PostOffice.removeBinding(SimpleString uniqueName,
Transaction tx) |
Binding |
AddressManager.removeBinding(SimpleString uniqueName,
Transaction tx)
This will use a Transaction as we need to confirm the queue was removed
|
void |
PostOffice.sendQueueInfoToQueue(SimpleString queueName,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
void |
QueueInfo.setFilterStrings(List<SimpleString> filterStrings) |
Constructor and Description |
---|
QueueInfo(SimpleString routingName,
SimpleString clusterName,
SimpleString address,
SimpleString filterString,
long id,
int distance) |
Modifier and Type | Field and Description |
---|---|
static SimpleString |
PostOfficeImpl.BRIDGE_CACHE_STR |
static SimpleString |
PostOfficeImpl.HDR_RESET_QUEUE_DATA |
Modifier and Type | Method and Description |
---|---|
SimpleString |
LocalQueueBinding.getAddress() |
SimpleString |
AddressImpl.getAddress() |
SimpleString |
DivertBinding.getAddress() |
SimpleString[] |
AddressImpl.getAddressParts() |
SimpleString |
LocalQueueBinding.getClusterName() |
SimpleString |
DivertBinding.getClusterName() |
SimpleString |
LocalQueueBinding.getRoutingName() |
SimpleString |
DivertBinding.getRoutingName() |
SimpleString |
LocalQueueBinding.getUniqueName() |
SimpleString |
DivertBinding.getUniqueName() |
Modifier and Type | Method and Description |
---|---|
Map<SimpleString,Binding> |
SimpleAddressManager.getBindings() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
SimpleAddressManager.addMappingInternal(SimpleString address,
Binding binding) |
Bindings |
PostOfficeImpl.createBindings(SimpleString address) |
Binding |
PostOfficeImpl.getBinding(SimpleString name) |
Binding |
SimpleAddressManager.getBinding(SimpleString bindableName) |
Bindings |
PostOfficeImpl.getBindingsForAddress(SimpleString address) |
Bindings |
WildcardAddressManager.getBindingsForRoutingAddress(SimpleString address) |
Bindings |
SimpleAddressManager.getBindingsForRoutingAddress(SimpleString address) |
DuplicateIDCache |
PostOfficeImpl.getDuplicateIDCache(SimpleString address) |
Bindings |
PostOfficeImpl.getMatchingBindings(SimpleString address) |
Bindings |
SimpleAddressManager.getMatchingBindings(SimpleString address) |
Bindings |
PostOfficeImpl.lookupBindingsForAddress(SimpleString address) |
Binding |
PostOfficeImpl.removeBinding(SimpleString uniqueName,
Transaction tx) |
Binding |
WildcardAddressManager.removeBinding(SimpleString uniqueName,
Transaction tx)
If the address is a wild card then the binding will be removed from the actual mappings for any linked address.
|
Binding |
SimpleAddressManager.removeBinding(SimpleString uniqueName,
Transaction tx) |
protected void |
SimpleAddressManager.removeBindingInternal(SimpleString address,
SimpleString bindableName) |
protected Binding |
SimpleAddressManager.removeMapping(SimpleString bindableName,
Bindings bindings) |
void |
PostOfficeImpl.sendQueueInfoToQueue(SimpleString queueName,
SimpleString address) |
Constructor and Description |
---|
AddressImpl(SimpleString address) |
BindingsImpl(SimpleString name,
GroupingHandler groupingHandler,
PagingStore pageStore) |
DivertBinding(long id,
SimpleString address,
Divert divert) |
DuplicateIDCacheImpl(SimpleString address,
int size,
StorageManager storageManager,
boolean persist) |
LocalQueueBinding(SimpleString address,
Queue queue,
SimpleString nodeID) |
Modifier and Type | Method and Description |
---|---|
void |
CoreSessionCallback.sendProducerCreditsFailMessage(int credits,
SimpleString address) |
void |
CoreSessionCallback.sendProducerCreditsMessage(int credits,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
SessionRequestProducerCreditsMessage.getAddress() |
SimpleString |
SessionQueueQueryResponseMessage.getAddress() |
SimpleString |
SessionBindingQueryMessage.getAddress() |
SimpleString |
CreateSharedQueueMessage.getAddress() |
SimpleString |
CreateQueueMessage.getAddress() |
SimpleString |
SessionProducerCreditsMessage.getAddress() |
SimpleString |
SessionProducerCreditsFailMessage.getAddress() |
SimpleString |
SessionQueueQueryResponseMessage.getFilterString() |
SimpleString |
CreateSharedQueueMessage.getFilterString() |
SimpleString |
CreateQueueMessage.getFilterString() |
SimpleString |
SessionCreateConsumerMessage.getFilterString() |
SimpleString |
SessionQueueQueryResponseMessage.getName() |
SimpleString |
DisconnectMessage.getNodeID() |
SimpleString |
ReplicationSyncFileMessage.getPageStore() |
SimpleString |
CreateSharedQueueMessage.getQueueName() |
SimpleString |
CreateQueueMessage.getQueueName() |
SimpleString |
SessionQueueQueryMessage.getQueueName() |
SimpleString |
SessionDeleteQueueMessage.getQueueName() |
SimpleString |
SessionCreateConsumerMessage.getQueueName() |
SimpleString |
ReplicationPageEventMessage.getStoreName() |
Modifier and Type | Method and Description |
---|---|
List<SimpleString> |
SessionBindingQueryResponseMessage.getQueueNames() |
Modifier and Type | Method and Description |
---|---|
void |
CreateSharedQueueMessage.setAddress(SimpleString address) |
void |
CreateQueueMessage.setAddress(SimpleString address) |
void |
CreateSharedQueueMessage.setFilterString(SimpleString filterString) |
void |
CreateQueueMessage.setFilterString(SimpleString filterString) |
void |
SessionCreateConsumerMessage.setFilterString(SimpleString filterString) |
void |
CreateSharedQueueMessage.setQueueName(SimpleString queueName) |
void |
CreateQueueMessage.setQueueName(SimpleString queueName) |
void |
SessionCreateConsumerMessage.setQueueName(SimpleString queueName) |
Constructor and Description |
---|
SessionBindingQueryResponseMessage(boolean exists,
List<SimpleString> queueNames) |
Modifier and Type | Method and Description |
---|---|
void |
ProtonSession.sendProducerCreditsFailMessage(int credits,
SimpleString address) |
void |
ProtonSession.sendProducerCreditsMessage(int credits,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
void |
StompSession.sendProducerCreditsFailMessage(int credits,
SimpleString address) |
void |
StompSession.sendProducerCreditsMessage(int credits,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationManager.pageClosed(SimpleString storeName,
int pageNumber) |
void |
ReplicationManager.pageDeleted(SimpleString storeName,
int pageNumber) |
void |
ReplicationManager.syncPages(SequentialFile file,
long id,
SimpleString queueName) |
Modifier and Type | Method and Description |
---|---|
void |
SecurityStore.check(SimpleString address,
CheckType checkType,
ServerSession session) |
Modifier and Type | Method and Description |
---|---|
void |
SecurityStoreImpl.check(SimpleString address,
CheckType checkType,
ServerSession session) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
Queue.getAddress() |
SimpleString |
QueueQueryResult.getAddress() |
SimpleString |
QueueQueryResult.getFilterString() |
SimpleString |
Queue.getName() |
SimpleString |
QueueQueryResult.getName() |
SimpleString |
NodeManager.getNodeId() |
SimpleString |
HornetQServer.getNodeID() |
SimpleString |
TransientQueueManager.getQueueName() |
SimpleString |
Divert.getRoutingName() |
SimpleString |
Divert.getUniqueName() |
abstract SimpleString |
NodeManager.readNodeId() |
Modifier and Type | Method and Description |
---|---|
Map<SimpleString,RouteContextList> |
RoutingContext.getContexListing() |
List<SimpleString> |
BindingQueryResult.getQueueNames() |
Modifier and Type | Method and Description |
---|---|
void |
RoutingContext.addQueue(SimpleString address,
Queue queue) |
void |
HornetQServerLogger.backupServerStarted(String version,
SimpleString nodeID) |
HornetQInternalErrorException |
HornetQMessageBundle.bindingNotDivert(SimpleString name) |
void |
HornetQServerLogger.bridgeAbortStart(SimpleString name,
Integer retryCount,
Integer reconnectAttempts) |
void |
HornetQServerLogger.bridgeNoBindings(SimpleString name,
SimpleString forwardingAddress,
SimpleString address) |
void |
HornetQServerLogger.bridgePaused(SimpleString name) |
void |
HornetQServerLogger.bridgeStopped(SimpleString name) |
HornetQIllegalStateException |
HornetQMessageBundle.cannotDeleteQueue(SimpleString name,
SimpleString queueName,
String s) |
HornetQIllegalStateException |
HornetQMessageBundle.consumerNoReference(Long id,
Long messageID,
SimpleString name) |
void |
ServerSession.createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
Queue |
QueueFactory.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary) |
void |
ServerSession.createQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
HornetQServer.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary) |
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
boolean durable,
SimpleString filterString) |
void |
HornetQServer.createSharedQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean durable)
Creates a shared queue.
|
void |
ServerSession.deleteQueue(SimpleString name) |
void |
HornetQServerLogger.deployQueue(SimpleString queueName) |
Queue |
HornetQServer.deployQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary) |
void |
HornetQServer.destroyDivert(SimpleString name) |
void |
HornetQServer.destroyQueue(SimpleString queueName) |
void |
HornetQServer.destroyQueue(SimpleString queueName,
ServerSession session) |
void |
HornetQServer.destroyQueue(SimpleString queueName,
ServerSession session,
boolean checkConsumerCount) |
void |
HornetQServer.destroyQueue(SimpleString queueName,
ServerSession session,
boolean checkConsumerCount,
boolean removeConsumers) |
void |
HornetQServerLogger.divertBindingNotExists(SimpleString bindingName) |
void |
HornetQServerLogger.errorExpiringReferencesNoBindings(SimpleString expiryAddress) |
void |
HornetQServerLogger.errorExpiringReferencesNoQueue(SimpleString name) |
void |
HornetQServerLogger.errorQueryingBridge(SimpleString address,
Integer retryCount) |
void |
HornetQServerLogger.errorQueryingBridge(Throwable t,
SimpleString name) |
void |
HornetQServerLogger.errorRemovingTempQueue(Exception e,
SimpleString bindingName) |
void |
HornetQServerLogger.errorStartingBridge(SimpleString name) |
BindingQueryResult |
ServerSession.executeBindingQuery(SimpleString address) |
QueueQueryResult |
ServerSession.executeQueueQuery(SimpleString name) |
void |
ServerMessage.forceAddress(SimpleString address)
This will force encoding of the address, and will re-check the buffer
This is to avoid setMessageTransient which set the address without changing the buffer
|
RouteContextList |
RoutingContext.getContextListing(SimpleString address) |
List<Queue> |
RoutingContext.getDurableQueues(SimpleString address) |
List<Queue> |
RoutingContext.getNonDurableQueues(SimpleString address) |
void |
HornetQServerLogger.groupingQueueRemoved(int size,
SimpleString clusterName) |
HornetQNonExistentQueueException |
HornetQMessageBundle.groupingQueueRemoved(SimpleString chosenClusterName) |
void |
HornetQServerLogger.groupingQueueRemovedComplete(SimpleString clusterName) |
HornetQInvalidFilterExpressionException |
HornetQMessageBundle.invalidFilter(Throwable e,
SimpleString filter) |
void |
HornetQServerLogger.invalidFilter(Throwable t,
SimpleString filter) |
Queue |
HornetQServer.locateQueue(SimpleString queueName) |
void |
HornetQServerLogger.messageExceededMaxDelivery(MessageReference ref,
SimpleString name) |
void |
HornetQServerLogger.messageExceededMaxDeliveryNoDLA(SimpleString name) |
void |
HornetQServerLogger.messageExceededMaxDeliverySendtoDLA(MessageReference ref,
SimpleString name,
SimpleString simpleString) |
void |
HornetQServerLogger.messageWithDuplicateID(Object duplicateProperty,
SimpleString toAddress,
SimpleString address,
SimpleString simpleString) |
boolean |
Queue.moveReference(long messageID,
SimpleString toAddress) |
boolean |
Queue.moveReference(long messageID,
SimpleString toAddress,
boolean rejectDuplicates) |
int |
Queue.moveReferences(Filter filter,
SimpleString toAddress) |
int |
Queue.moveReferences(int flushLimit,
Filter filter,
SimpleString toAddress,
boolean rejectDuplicates) |
HornetQInternalErrorException |
HornetQMessageBundle.noBindingForDivert(SimpleString name) |
void |
HornetQServerLogger.noDLA(SimpleString address) |
void |
HornetQServerLogger.noQueueIdDefined(ServerMessage message,
ServerMessage messageCopy,
SimpleString idsHeaderName) |
HornetQNonExistentQueueException |
HornetQMessageBundle.noSuchQueue(SimpleString queueName) |
void |
HornetQServerLogger.pageStoreDropMessages(SimpleString storeName) |
void |
HornetQServerLogger.pageStoreStart(SimpleString storeName,
long addressSize,
long maxSize) |
void |
HornetQServerLogger.pageStoreTimeout(SimpleString address) |
void |
HornetQServerLogger.pageSubscriptionCouldntLoad(long transactionID,
PagePosition position,
SimpleString address,
SimpleString name) |
void |
HornetQServerLogger.problemCleaningPageAddress(Exception e,
SimpleString address) |
HornetQQueueExistsException |
HornetQMessageBundle.queueAlreadyExists(SimpleString queueName) |
HornetQInvalidTransientQueueUseException |
HornetQMessageBundle.queueSubscriptionBelongsToDifferentAddress(SimpleString queueName) |
HornetQInvalidTransientQueueUseException |
HornetQMessageBundle.queueSubscriptionBelongsToDifferentFilter(SimpleString queueName) |
void |
HornetQServerLogger.remoteQueueAlreadyBoundOnClusterConnection(Object messageFlowRecord,
SimpleString clusterName) |
void |
ServerSession.requestProducerCredits(SimpleString address,
int credits) |
void |
HornetQServerLogger.serverStarted(String fullVersion,
SimpleString nodeId,
String identity) |
void |
HornetQServerLogger.serverStopped(String version,
SimpleString nodeId) |
void |
Queue.setExpiryAddress(SimpleString expiryAddress) |
void |
HornetQServerLogger.unableToDeleteGroupBindings(Exception e,
SimpleString groupId) |
void |
HornetQServerLogger.unableToStartBridge(Exception e,
SimpleString name) |
void |
HornetQServerLogger.unableToStartClusterConnection(Exception e,
SimpleString name) |
Constructor and Description |
---|
QueueQueryResult(SimpleString name,
SimpleString address,
boolean durable,
boolean temporary,
SimpleString filterString,
int consumerCount,
long messageCount) |
Constructor and Description |
---|
BindingQueryResult(boolean exists,
List<SimpleString> queueNames) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
Bridge.getForwardingAddress() |
SimpleString |
ClusterConnection.getName() |
SimpleString |
Bridge.getName() |
Modifier and Type | Method and Description |
---|---|
void |
RemoteQueueBinding.addConsumer(SimpleString filterString) |
void |
RemoteQueueBinding.removeConsumer(SimpleString filterString) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
RemoteQueueBindingImpl.getAddress() |
SimpleString |
RemoteQueueBindingImpl.getClusterName() |
SimpleString |
BridgeImpl.getForwardingAddress() |
SimpleString |
ClusterConnectionImpl.getName() |
SimpleString |
BridgeImpl.getName() |
SimpleString |
RemoteQueueBindingImpl.getRoutingName() |
SimpleString |
RemoteQueueBindingImpl.getUniqueName() |
Modifier and Type | Method and Description |
---|---|
void |
RemoteQueueBindingImpl.addConsumer(SimpleString filterString) |
void |
RemoteQueueBindingImpl.removeConsumer(SimpleString filterString) |
Constructor and Description |
---|
BridgeImpl(ServerLocatorInternal serverLocator,
int initialConnectAttempts,
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,
StorageManager storageManager) |
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManager clusterManager,
ServerLocatorInternal targetLocator,
ServerLocatorInternal discoveryLocator,
int initialConnectAttempts,
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,
StorageManager storageManager,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector) |
ClusterConnectionImpl(ClusterManager manager,
DiscoveryGroupConfiguration dg,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int initialConnectAttempts,
int reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
ClusterConnectionImpl(ClusterManager manager,
TransportConfiguration[] staticTranspConfigs,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int initialConnectAttempts,
int reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
RemoteQueueBindingImpl(long id,
SimpleString address,
SimpleString uniqueName,
SimpleString routingName,
Long remoteQueueID,
SimpleString filterString,
Queue storeAndForwardQueue,
SimpleString bridgeName,
int distance) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
GroupingHandler.getName() |
Modifier and Type | Method and Description |
---|---|
Response |
GroupingHandler.getProposal(SimpleString fullID) |
void |
GroupingHandler.remove(SimpleString groupid,
SimpleString clusterName,
int distance) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
GroupingHandlerConfiguration.getAddress() |
SimpleString |
Response.getAlternativeClusterName() |
SimpleString |
Response.getChosenClusterName() |
SimpleString |
Proposal.getClusterName() |
SimpleString |
Response.getClusterName() |
SimpleString |
GroupBinding.getClusterName() |
SimpleString |
Proposal.getGroupId() |
SimpleString |
Response.getGroupId() |
SimpleString |
GroupBinding.getGroupId() |
SimpleString |
RemoteGroupingHandler.getName() |
SimpleString |
LocalGroupingHandler.getName() |
SimpleString |
GroupingHandlerConfiguration.getName() |
Modifier and Type | Method and Description |
---|---|
Response |
RemoteGroupingHandler.getProposal(SimpleString fullID) |
Response |
LocalGroupingHandler.getProposal(SimpleString fullID) |
void |
RemoteGroupingHandler.remove(SimpleString groupid,
SimpleString clusterName,
int distance) |
void |
LocalGroupingHandler.remove(SimpleString groupid,
SimpleString clusterName,
int distance) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
QueueImpl.getAddress() |
SimpleString |
QueueImpl.getName() |
SimpleString |
HornetQServerImpl.getNodeID() |
SimpleString |
TransientQueueManagerImpl.getQueueName() |
SimpleString |
QueueImpl.getRoutingName() |
SimpleString |
DivertImpl.getRoutingName() |
SimpleString |
QueueImpl.getUniqueName() |
SimpleString |
DivertImpl.getUniqueName() |
SimpleString |
FileLockNodeManager.readNodeId() |
Modifier and Type | Method and Description |
---|---|
Map<SimpleString,RouteContextList> |
RoutingContextImpl.getContexListing() |
Modifier and Type | Method and Description |
---|---|
void |
RoutingContextImpl.addQueue(SimpleString address,
Queue queue) |
void |
ServerSessionImpl.createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
void |
ServerSessionImpl.createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage,
Integer credits) |
Queue |
QueueFactoryImpl.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary) |
Queue |
HornetQServerImpl.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary) |
void |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable) |
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
boolean durable,
SimpleString filterString) |
void |
HornetQServerImpl.createSharedQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean durable)
Creates a transient queue.
|
void |
ServerSessionImpl.deleteQueue(SimpleString queueToDelete) |
Queue |
HornetQServerImpl.deployQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary) |
void |
HornetQServerImpl.destroyDivert(SimpleString name) |
void |
HornetQServerImpl.destroyQueue(SimpleString queueName) |
void |
HornetQServerImpl.destroyQueue(SimpleString queueName,
ServerSession session) |
void |
HornetQServerImpl.destroyQueue(SimpleString queueName,
ServerSession session,
boolean checkConsumerCount) |
void |
HornetQServerImpl.destroyQueue(SimpleString queueName,
ServerSession session,
boolean checkConsumerCount,
boolean removeConsumers) |
BindingQueryResult |
ServerSessionImpl.executeBindingQuery(SimpleString address) |
QueueQueryResult |
ServerSessionImpl.executeQueueQuery(SimpleString name) |
void |
ServerMessageImpl.forceAddress(SimpleString address) |
RouteContextList |
RoutingContextImpl.getContextListing(SimpleString address) |
List<Queue> |
RoutingContextImpl.getDurableQueues(SimpleString address) |
List<Queue> |
RoutingContextImpl.getNonDurableQueues(SimpleString address) |
Queue |
HornetQServerImpl.locateQueue(SimpleString queueName) |
boolean |
QueueImpl.moveReference(long messageID,
SimpleString toAddress) |
boolean |
QueueImpl.moveReference(long messageID,
SimpleString toAddress,
boolean rejectDuplicate) |
int |
QueueImpl.moveReferences(Filter filter,
SimpleString toAddress) |
int |
QueueImpl.moveReferences(int flushLimit,
Filter filter,
SimpleString toAddress,
boolean rejectDuplicates) |
void |
ServerSessionImpl.requestProducerCredits(SimpleString address,
int credits) |
void |
QueueImpl.setExpiryAddress(SimpleString expiryAddress) |
Modifier and Type | Method and Description |
---|---|
void |
JournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
void |
PostOfficeJournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
Constructor and Description |
---|
DivertImpl(SimpleString forwardAddress,
SimpleString uniqueName,
SimpleString routingName,
boolean exclusive,
Filter filter,
Transformer transformer,
PostOffice postOffice,
StorageManager storageManager) |
LastValueQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
ServerSessionImpl(String name,
String username,
String password,
int minLargeMessageSize,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
boolean xa,
RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
HornetQServer server,
SimpleString managementAddress,
SimpleString defaultAddress,
SessionCallback callback,
OperationContext context) |
TransientQueueManagerImpl(HornetQServer server,
SimpleString queueName) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
ManagementService.getManagementAddress() |
SimpleString |
ManagementService.getManagementNotificationAddress() |
Modifier and Type | Method and Description |
---|---|
void |
ManagementService.registerAddress(SimpleString address) |
void |
ManagementService.registerQueue(Queue queue,
SimpleString address,
StorageManager storageManager) |
void |
ManagementService.unregisterAddress(SimpleString address) |
void |
ManagementService.unregisterDivert(SimpleString name) |
void |
ManagementService.unregisterQueue(SimpleString name,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
ManagementServiceImpl.getManagementAddress() |
SimpleString |
ManagementServiceImpl.getManagementNotificationAddress() |
Modifier and Type | Method and Description |
---|---|
void |
ManagementServiceImpl.registerAddress(SimpleString address) |
void |
ManagementServiceImpl.registerQueue(Queue queue,
SimpleString address,
StorageManager storageManager) |
void |
ManagementServiceImpl.unregisterAddress(SimpleString address) |
void |
ManagementServiceImpl.unregisterDivert(SimpleString name) |
void |
ManagementServiceImpl.unregisterQueue(SimpleString name,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
AddressSettings.getDeadLetterAddress() |
SimpleString |
AddressSettings.getExpiryAddress() |
Modifier and Type | Method and Description |
---|---|
void |
AddressSettings.setDeadLetterAddress(SimpleString deadLetterAddress) |
void |
AddressSettings.setExpiryAddress(SimpleString expiryAddress) |
Modifier and Type | Field and Description |
---|---|
static SimpleString |
HornetQConnection.CONNECTION_ID_PROPERTY_NAME |
Modifier and Type | Method and Description |
---|---|
static SimpleString |
HornetQTopic.createAddressFromName(String name) |
static SimpleString |
HornetQQueue.createAddressFromName(String name) |
static SimpleString |
HornetQDestination.createQueueAddressFromName(String name) |
static SimpleString |
HornetQDestination.createTopicAddressFromName(String name) |
SimpleString |
HornetQDestination.getSimpleAddress() |
SimpleString |
HornetQConnection.getUID() |
Modifier and Type | Method and Description |
---|---|
void |
HornetQConnection.addTemporaryQueue(SimpleString queueAddress) |
boolean |
HornetQConnection.containsTemporaryQueue(SimpleString queueAddress) |
HornetQNonExistentQueueException |
HornetQJMSClientBundle.destinationDoesNotExist(SimpleString destination) |
HornetQInvalidFilterExpressionException |
HornetQJMSClientBundle.invalidFilter(Throwable e,
SimpleString filter) |
void |
HornetQConnection.removeTemporaryQueue(SimpleString queueAddress) |
Constructor and Description |
---|
HornetQMessageConsumer(HornetQConnection connection,
HornetQSession session,
ClientConsumer consumer,
boolean noLocal,
HornetQDestination destination,
String selector,
SimpleString autoDeleteQueueName) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
HornetQActivation.getAddress() |
SimpleString |
HornetQActivation.getTopicTemporaryQueue() |
Modifier and Type | Method and Description |
---|---|
void |
HornetQActivation.setTopicTemporaryQueue(SimpleString topicTemporaryQueue) |
Modifier and Type | Method and Description |
---|---|
void |
SessionCallback.sendProducerCreditsFailMessage(int credits,
SimpleString address) |
void |
SessionCallback.sendProducerCreditsMessage(int credits,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
UUIDGenerator.generateSimpleStringUUID() |
SimpleString |
TypedProperties.getSimpleStringProperty(SimpleString key) |
Modifier and Type | Method and Description |
---|---|
Set<SimpleString> |
TypedProperties.getPropertyNames() |
Modifier and Type | Method and Description |
---|---|
boolean |
TypedProperties.containsProperty(SimpleString key) |
Boolean |
TypedProperties.getBooleanProperty(SimpleString key) |
Byte |
TypedProperties.getByteProperty(SimpleString key) |
byte[] |
TypedProperties.getBytesProperty(SimpleString key) |
Character |
TypedProperties.getCharProperty(SimpleString key) |
Double |
TypedProperties.getDoubleProperty(SimpleString key) |
Float |
TypedProperties.getFloatProperty(SimpleString key) |
Integer |
TypedProperties.getIntProperty(SimpleString key) |
Long |
TypedProperties.getLongProperty(SimpleString key) |
Object |
TypedProperties.getProperty(SimpleString key) |
Short |
TypedProperties.getShortProperty(SimpleString key) |
SimpleString |
TypedProperties.getSimpleStringProperty(SimpleString key) |
void |
TypedProperties.putBooleanProperty(SimpleString key,
boolean value) |
void |
TypedProperties.putByteProperty(SimpleString key,
byte value) |
void |
TypedProperties.putBytesProperty(SimpleString key,
byte[] value) |
void |
TypedProperties.putCharProperty(SimpleString key,
char value) |
void |
TypedProperties.putDoubleProperty(SimpleString key,
double value) |
void |
TypedProperties.putFloatProperty(SimpleString key,
float value) |
void |
TypedProperties.putIntProperty(SimpleString key,
int value) |
void |
TypedProperties.putLongProperty(SimpleString key,
long value) |
void |
TypedProperties.putNullValue(SimpleString key) |
void |
TypedProperties.putShortProperty(SimpleString key,
short value) |
void |
TypedProperties.putSimpleStringProperty(SimpleString key,
SimpleString value) |
Object |
TypedProperties.removeProperty(SimpleString key) |
static void |
TypedProperties.setObjectProperty(SimpleString key,
Object value,
TypedProperties properties)
Helper for
MapMessage#setObjectProperty(String, Object) |
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.