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_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.
|
void |
Message.putBooleanProperty(SimpleString key,
boolean value)
Puts a boolean property in this message.
|
void |
Message.putByteProperty(SimpleString key,
byte value)
Puts a byte property in this message.
|
void |
Message.putBytesProperty(SimpleString key,
byte[] value)
Puts a byte[] property in this message.
|
void |
Message.putDoubleProperty(SimpleString key,
double value)
Puts a double property in this message.
|
void |
Message.putFloatProperty(SimpleString key,
float value)
Puts a float property in this message.
|
void |
Message.putIntProperty(SimpleString key,
int value)
Puts a int property in this message.
|
void |
Message.putLongProperty(SimpleString key,
long value)
Puts a long property in this message.
|
void |
Message.putObjectProperty(SimpleString key,
Object value)
Puts an Object property in this message.
|
void |
Message.putShortProperty(SimpleString key,
short value)
Puts a short property in this message.
|
void |
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.
|
void |
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.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.
|
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 |
ClientConsumerInternal.getFilterString() |
SimpleString |
ClientConsumerImpl.getFilterString() |
SimpleString |
ClientConsumerInternal.getQueueName() |
SimpleString |
ClientConsumerImpl.getQueueName() |
SimpleString |
LargeMessageControllerImpl.readNullableSimpleString() |
SimpleString |
CompressedLargeMessageControllerImpl.readNullableSimpleString() |
SimpleString |
LargeMessageControllerImpl.readSimpleString() |
SimpleString |
CompressedLargeMessageControllerImpl.readSimpleString() |
Modifier and Type | Method and Description |
---|---|
ClientSession.BindingQuery |
DelegatingSession.bindingQuery(SimpleString address) |
ClientSession.BindingQuery |
ClientSessionImpl.bindingQuery(SimpleString address) |
ClientConsumer |
DelegatingSession.createConsumer(SimpleString queueName) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName) |
ClientConsumer |
DelegatingSession.createConsumer(SimpleString queueName,
boolean browseOnly) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
boolean browseOnly) |
ClientConsumer |
DelegatingSession.createConsumer(SimpleString queueName,
SimpleString filterString) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
SimpleString filterString) |
ClientConsumer |
DelegatingSession.createConsumer(SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
ClientConsumer |
DelegatingSession.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
boolean browseOnly) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
boolean browseOnly) |
ClientProducer |
DelegatingSession.createProducer(SimpleString address) |
ClientProducer |
ClientSessionImpl.createProducer(SimpleString address) |
ClientProducer |
DelegatingSession.createProducer(SimpleString address,
int rate) |
ClientProducer |
ClientSessionImpl.createProducer(SimpleString address,
int maxRate) |
void |
DelegatingSession.createQueue(SimpleString address,
SimpleString queueName) |
void |
ClientSessionImpl.createQueue(SimpleString address,
SimpleString queueName) |
void |
DelegatingSession.createQueue(SimpleString address,
SimpleString queueName,
boolean durable) |
void |
ClientSessionImpl.createQueue(SimpleString address,
SimpleString queueName,
boolean durable) |
void |
DelegatingSession.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable) |
void |
ClientSessionImpl.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable) |
void |
DelegatingSession.createTemporaryQueue(SimpleString address,
SimpleString queueName) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
SimpleString queueName) |
void |
DelegatingSession.createTemporaryQueue(SimpleString address,
SimpleString queueName,
SimpleString filter) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
SimpleString queueName,
SimpleString filter) |
void |
DelegatingSession.deleteQueue(SimpleString queueName) |
void |
ClientSessionImpl.deleteQueue(SimpleString queueName) |
ClientProducerCredits |
DelegatingSession.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientSessionInternal.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientSessionImpl.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientProducerCreditManagerImpl.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientProducerCreditManager.getCredits(SimpleString address,
boolean anon) |
void |
DelegatingSession.handleReceiveProducerCredits(SimpleString address,
int credits) |
void |
ClientSessionInternal.handleReceiveProducerCredits(SimpleString address,
int credits) |
void |
ClientSessionImpl.handleReceiveProducerCredits(SimpleString address,
int credits) |
ClientSession.QueueQuery |
DelegatingSession.queueQuery(SimpleString queueName) |
ClientSession.QueueQuery |
ClientSessionImpl.queueQuery(SimpleString queueName) |
void |
ClientProducerCreditManagerImpl.receiveCredits(SimpleString address,
int credits) |
void |
ClientProducerCreditManager.receiveCredits(SimpleString address,
int credits) |
void |
DelegatingSession.returnCredits(SimpleString address) |
void |
ClientSessionInternal.returnCredits(SimpleString address) |
void |
ClientSessionImpl.returnCredits(SimpleString address) |
void |
ClientProducerCreditManagerImpl.returnCredits(SimpleString address) |
void |
ClientProducerCreditManager.returnCredits(SimpleString address) |
void |
ClientProducerImpl.send(SimpleString address,
Message msg) |
void |
DelegatingSession.sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
ClientSessionInternal.sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
ClientSessionImpl.sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
DelegatingSession.setAddress(Message message,
SimpleString address) |
void |
ClientSessionInternal.setAddress(Message message,
SimpleString address) |
void |
ClientSessionImpl.setAddress(Message message,
SimpleString address) |
void |
LargeMessageControllerImpl.writeNullableSimpleString(SimpleString val) |
void |
CompressedLargeMessageControllerImpl.writeNullableSimpleString(SimpleString val) |
void |
LargeMessageControllerImpl.writeSimpleString(SimpleString val) |
void |
CompressedLargeMessageControllerImpl.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 | Field and Description |
---|---|
static SimpleString |
ConfigurationImpl.DEFAULT_MANAGEMENT_ADDRESS |
static SimpleString |
ConfigurationImpl.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS |
protected SimpleString |
ConfigurationImpl.managementAddress |
protected SimpleString |
ConfigurationImpl.managementNotificationAddress |
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) |
Constructor and Description |
---|
Identifier(SimpleString name) |
SimpleStringReader(SimpleString simpleString) |
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() |
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)
To return 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) |
protected PagingStore |
PagingManagerImpl.newStore(SimpleString address) |
PagingStore |
PagingStoreFactoryNIO.newStore(SimpleString address,
AddressSettings settings) |
Constructor and Description |
---|
PageImpl(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 |
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,Queue> queues,
Map<Long,QueueBindingInfo> queueInfos,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
Set<Pair<Long,Long>> pendingLargeMessages) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
PersistedRoles.getAddressMatch() |
SimpleString |
PersistedAddressSetting.getAddressMatch() |
Constructor and Description |
---|
PersistedAddressSetting(SimpleString addressMatch,
AddressSettings setting) |
Modifier and Type | Field and Description |
---|---|
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.address |
SimpleString |
JournalStorageManager.GroupingEncoding.clusterName |
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.filterString |
SimpleString |
JournalStorageManager.GroupingEncoding.groupId |
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.name |
Modifier and Type | Method and Description |
---|---|
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.getAddress() |
SimpleString |
JournalStorageManager.GroupingEncoding.getClusterName() |
SimpleString |
JournalStorageManager.PersistentQueueBindingEncoding.getFilterString() |
SimpleString |
JournalStorageManager.GroupingEncoding.getGroupId() |
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.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,Queue> queues,
Map<Long,QueueBindingInfo> queueInfos,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
Set<Pair<Long,Long>> pendingLargeMessages) |
Constructor and Description |
---|
JournalStorageManager.DuplicateIDEncoding(SimpleString address,
byte[] duplID) |
JournalStorageManager.GroupingEncoding(long id,
SimpleString groupId,
SimpleString clusterName) |
JournalStorageManager.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.updateDuplicateID(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,Queue> queues,
Map<Long,QueueBindingInfo> queueInfos,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
Set<Pair<Long,Long>> pendingLM) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
QueueInfo.getAddress() |
SimpleString |
Binding.getAddress() |
SimpleString |
Address.getAddress() |
SimpleString[] |
Address.getAddressParts() |
SimpleString |
QueueInfo.getClusterName() |
SimpleString |
Binding.getClusterName() |
SimpleString |
QueueInfo.getFilterString() |
SimpleString |
QueueInfo.getRoutingName() |
SimpleString |
Binding.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) |
Binding |
AddressManager.removeBinding(SimpleString uniqueName) |
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 |
DivertBinding.getAddress() |
SimpleString |
AddressImpl.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 |
SimpleAddressManager.getBinding(SimpleString bindableName) |
Binding |
PostOfficeImpl.getBinding(SimpleString name) |
Bindings |
PostOfficeImpl.getBindingsForAddress(SimpleString address) |
Bindings |
WildcardAddressManager.getBindingsForRoutingAddress(SimpleString address) |
Bindings |
SimpleAddressManager.getBindingsForRoutingAddress(SimpleString address) |
DuplicateIDCache |
PostOfficeImpl.getDuplicateIDCache(SimpleString address) |
Bindings |
SimpleAddressManager.getMatchingBindings(SimpleString address) |
Bindings |
PostOfficeImpl.getMatchingBindings(SimpleString address) |
Bindings |
PostOfficeImpl.lookupBindingsForAddress(SimpleString address) |
Binding |
WildcardAddressManager.removeBinding(SimpleString uniqueName)
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) |
Binding |
PostOfficeImpl.removeBinding(SimpleString uniqueName) |
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.sendProducerCreditsMessage(int credits,
SimpleString address) |
Constructor and Description |
---|
RemotingConnectionImpl(Connection transportConnection,
List<Interceptor> interceptors,
Executor executor,
SimpleString nodeID) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
SessionRequestProducerCreditsMessage.getAddress() |
SimpleString |
SessionQueueQueryResponseMessage.getAddress() |
SimpleString |
SessionProducerCreditsMessage.getAddress() |
SimpleString |
SessionBindingQueryMessage.getAddress() |
SimpleString |
CreateQueueMessage.getAddress() |
SimpleString |
SessionQueueQueryResponseMessage.getFilterString() |
SimpleString |
SessionCreateConsumerMessage.getFilterString() |
SimpleString |
CreateQueueMessage.getFilterString() |
SimpleString |
SessionQueueQueryResponseMessage.getName() |
SimpleString |
DisconnectMessage.getNodeID() |
SimpleString |
SessionQueueQueryMessage.getQueueName() |
SimpleString |
SessionDeleteQueueMessage.getQueueName() |
SimpleString |
SessionCreateConsumerMessage.getQueueName() |
SimpleString |
CreateQueueMessage.getQueueName() |
SimpleString |
ReplicationPageEventMessage.getStoreName() |
Modifier and Type | Method and Description |
---|---|
List<SimpleString> |
SessionBindingQueryResponseMessage.getQueueNames() |
Constructor and Description |
---|
CreateQueueMessage(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary,
boolean requiresResponse) |
DisconnectMessage(SimpleString nodeID) |
ReplicationPageEventMessage(SimpleString storeName,
int pageNumber,
boolean isDelete) |
SessionBindingQueryMessage(SimpleString address) |
SessionCreateConsumerMessage(long id,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
boolean requiresResponse) |
SessionDeleteQueueMessage(SimpleString queueName) |
SessionProducerCreditsMessage(int credits,
SimpleString address) |
SessionQueueQueryMessage(SimpleString queueName) |
SessionRequestProducerCreditsMessage(int credits,
SimpleString address) |
Constructor and Description |
---|
SessionBindingQueryResponseMessage(boolean exists,
List<SimpleString> queueNames) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationManager.pageClosed(SimpleString storeName,
int pageNumber) |
void |
ReplicationManager.pageDeleted(SimpleString storeName,
int pageNumber) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationManagerImpl.pageClosed(SimpleString storeName,
int pageNumber) |
void |
ReplicationManagerImpl.pageDeleted(SimpleString storeName,
int pageNumber) |
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 | Field and Description |
---|---|
protected SimpleString |
NodeManager.nodeID |
Modifier and Type | Method and Description |
---|---|
SimpleString |
QueueQueryResult.getAddress() |
SimpleString |
Queue.getAddress() |
SimpleString |
QueueQueryResult.getFilterString() |
SimpleString |
QueueQueryResult.getName() |
SimpleString |
Queue.getName() |
SimpleString |
NodeManager.getNodeId() |
SimpleString |
HornetQServer.getNodeID() |
SimpleString |
Divert.getRoutingName() |
SimpleString |
Divert.getUniqueName() |
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 |
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.deleteQueue(SimpleString name) |
Queue |
HornetQServer.deployQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary) |
void |
HornetQServer.destroyDivert(SimpleString name) |
void |
HornetQServer.destroyQueue(SimpleString queueName,
ServerSession session) |
BindingQueryResult |
ServerSession.executeBindingQuery(SimpleString address) |
QueueQueryResult |
ServerSession.executeQueueQuery(SimpleString name) |
RouteContextList |
RoutingContext.getContextListing(SimpleString address) |
List<Queue> |
RoutingContext.getDurableQueues(SimpleString address) |
List<Queue> |
RoutingContext.getNonDurableQueues(SimpleString address) |
Queue |
HornetQServer.locateQueue(SimpleString queueName) |
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(Filter filter,
SimpleString toAddress,
boolean rejectDuplicates) |
void |
ServerSession.requestProducerCredits(SimpleString address,
int credits) |
void |
Queue.setExpiryAddress(SimpleString expiryAddress) |
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 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) |
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) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
GroupingHandlerConfiguration.getAddress() |
SimpleString |
Response.getAlternativeClusterName() |
SimpleString |
Response.getChosenClusterName() |
SimpleString |
Response.getClusterName() |
SimpleString |
Proposal.getClusterName() |
SimpleString |
GroupBinding.getClusterName() |
SimpleString |
Response.getGroupId() |
SimpleString |
Proposal.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) |
Constructor and Description |
---|
GroupBinding(long id,
SimpleString groupId,
SimpleString clusterName) |
GroupBinding(SimpleString groupId,
SimpleString clusterName) |
GroupingHandlerConfiguration(SimpleString name,
GroupingHandlerConfiguration.TYPE type,
SimpleString address) |
GroupingHandlerConfiguration(SimpleString name,
GroupingHandlerConfiguration.TYPE type,
SimpleString address,
int timeout) |
LocalGroupingHandler(ManagementService managementService,
SimpleString name,
SimpleString address,
StorageManager storageManager,
int timeout) |
Proposal(SimpleString groupId,
SimpleString clusterName) |
RemoteGroupingHandler(ManagementService managementService,
SimpleString name,
SimpleString address,
int timeout) |
Response(SimpleString groupId,
SimpleString clusterName) |
Response(SimpleString groupId,
SimpleString clusterName,
SimpleString alternativeClusterName) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
QueueImpl.getAddress() |
SimpleString |
QueueImpl.getName() |
SimpleString |
HornetQServerImpl.getNodeID() |
SimpleString |
QueueImpl.getRoutingName() |
SimpleString |
DivertImpl.getRoutingName() |
SimpleString |
QueueImpl.getUniqueName() |
SimpleString |
DivertImpl.getUniqueName() |
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) |
Queue |
QueueFactoryImpl.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary) |
void |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
HornetQServerImpl.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary) |
void |
ServerSessionImpl.deleteQueue(SimpleString name) |
Queue |
HornetQServerImpl.deployQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary) |
void |
HornetQServerImpl.destroyDivert(SimpleString name) |
void |
HornetQServerImpl.destroyQueue(SimpleString queueName,
ServerSession session) |
BindingQueryResult |
ServerSessionImpl.executeBindingQuery(SimpleString address) |
QueueQueryResult |
ServerSessionImpl.executeQueueQuery(SimpleString name) |
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(Filter filter,
SimpleString toAddress,
boolean rejectDuplicates) |
void |
ServerSessionImpl.requestProducerCredits(SimpleString address,
int credits) |
void |
QueueImpl.setExpiryAddress(SimpleString expiryAddress) |
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) |
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) |
void |
HornetQConnection.removeTemporaryQueue(SimpleString queueAddress) |
Constructor and Description |
---|
HornetQMessageConsumer(HornetQSession session,
ClientConsumer consumer,
boolean noLocal,
HornetQDestination destination,
String selector,
SimpleString autoDeleteQueueName) |
Modifier and Type | Method and Description |
---|---|
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) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.