Modifier and Type | Method and Description |
---|---|
static SimpleString |
ActiveMQDefaultConfiguration.getDefaultManagementAddress()
the name of the management address to send management messages to.
|
static SimpleString |
ActiveMQDefaultConfiguration.getDefaultManagementNotificationAddress()
the name of the address that consumers bind to receive management notifications
|
Modifier and Type | Field and Description |
---|---|
static SimpleString |
FilterConstants.ACTIVEMQ_ADDRESS
Name of the ActiveMQ Artemis Address header
|
static SimpleString |
FilterConstants.ACTIVEMQ_DURABLE
Name of the ActiveMQ Artemis Message durable header.
|
static SimpleString |
FilterConstants.ACTIVEMQ_EXPIRATION
Name of the ActiveMQ Artemis Message expiration header.
|
static SimpleString |
FilterConstants.ACTIVEMQ_PREFIX
All ActiveMQ Artemis headers are prepended by this prefix.
|
static SimpleString |
FilterConstants.ACTIVEMQ_PRIORITY
Name of the ActiveMQ Artemis Message priority header.
|
static SimpleString |
FilterConstants.ACTIVEMQ_SIZE
Name of the ActiveMQ Artemis Message size header.
|
static SimpleString |
FilterConstants.ACTIVEMQ_TIMESTAMP
Name of the ActiveMQ Artemis Message timestamp header.
|
static SimpleString |
FilterConstants.ACTIVEMQ_USERID
Name of the ActiveMQ Artemis UserID header.
|
static SimpleString |
FilterConstants.DURABLE
Value for the Durable header when the message is durable.
|
static SimpleString |
Message.HDR_ACTUAL_EXPIRY_TIME
the actual time the message was expired.
|
static SimpleString |
Message.HDR_CONTENT_TYPE
To define the mime-type of body messages.
|
static SimpleString |
Message.HDR_DUPLICATE_DETECTION_ID
To be used with duplicate detection.
|
static SimpleString |
Message.HDR_GROUP_ID
For the Message Grouping feature.
|
static SimpleString |
Message.HDR_LARGE_BODY_SIZE
The body size of a large message before it was compressed.
|
static SimpleString |
Message.HDR_LARGE_COMPRESSED
to determine if the Large Message was compressed.
|
static SimpleString |
Message.HDR_LAST_VALUE_NAME
To be used with Last value queues.
|
static SimpleString |
Message.HDR_ORIG_MESSAGE_ID
The original message ID before th emessage was transferred.
|
static SimpleString |
Message.HDR_ORIGINAL_ADDRESS
The original address of a message when a message is transferred through DLQ or expiry
|
static SimpleString |
Message.HDR_ORIGINAL_QUEUE
The original address of a message when a message is transferred through DLQ or expiry
|
static SimpleString |
Message.HDR_SCHEDULED_DELIVERY_TIME
To be used with Scheduled Delivery.
|
static SimpleString |
Message.HDR_VALIDATED_USER
The name of the validated user who sent the message.
|
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 |
ActiveMQBuffer.readNullableSimpleString()
Gets a SimpleString (potentially
null ) at the current readerIndex |
SimpleString |
ActiveMQBuffer.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 an 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 |
ActiveMQBuffer.writeNullableSimpleString(SimpleString val)
Sets the specified SimpleString (potentially
null ) at the current writerIndex |
void |
ActiveMQBuffer.writeSimpleString(SimpleString val)
Sets the specified non-null SimpleString at the current
writerIndex |
Modifier and Type | Method and Description |
---|---|
SimpleString |
ClientProducer.getAddress()
Returns the address where messages will be sent.
|
SimpleString |
ClientSession.QueueQuery.getAddress()
Returns the address that the queue is bound to.
|
SimpleString |
ClientSession.QueueQuery.getFilterString()
Returns the queue's filter string (or
null if the queue has no filter). |
SimpleString |
ClientSession.QueueQuery.getName()
Return the name of the queue
|
Modifier and Type | Method and Description |
---|---|
List<SimpleString> |
ClientSession.AddressQuery.getQueueNames()
Returns the names of the queues bound to the binding.
|
Modifier and Type | Method and Description |
---|---|
ClientSession.AddressQuery |
ClientSession.addressQuery(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.
|
ClientMessage |
ClientMessage.putBooleanProperty(SimpleString key,
boolean value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putByteProperty(SimpleString key,
byte value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putBytesProperty(SimpleString key,
byte[] value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putCharProperty(SimpleString key,
char value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putDoubleProperty(SimpleString key,
double value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putFloatProperty(SimpleString key,
float value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putIntProperty(SimpleString key,
int value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putLongProperty(SimpleString key,
long value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putShortProperty(SimpleString key,
short value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putStringProperty(SimpleString key,
SimpleString value)
Overridden from
Message to enable fluent API |
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 |
ResetLimitWrappedActiveMQBuffer.writeNullableSimpleString(SimpleString val) |
void |
ChannelBufferWrapper.writeNullableSimpleString(SimpleString val) |
void |
ResetLimitWrappedActiveMQBuffer.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 |
QueueQueryImpl.getAddress() |
SimpleString |
ClientConsumerImpl.getFilterString() |
SimpleString |
QueueQueryImpl.getFilterString() |
SimpleString |
ClientConsumerInternal.getFilterString() |
SimpleString |
QueueQueryImpl.getName() |
SimpleString |
ClientConsumerImpl.getQueueName() |
SimpleString |
ClientConsumerInternal.getQueueName() |
SimpleString |
LargeMessageControllerImpl.readNullableSimpleString() |
SimpleString |
LargeMessageControllerImpl.readSimpleString() |
Modifier and Type | Method and Description |
---|---|
List<SimpleString> |
AddressQueryImpl.getQueueNames() |
Modifier and Type | Method and Description |
---|---|
ClientSession.AddressQuery |
ClientSessionImpl.addressQuery(SimpleString address) |
void |
ClientSessionImpl.checkDefaultAddress(SimpleString address) |
void |
ClientSessionInternal.checkDefaultAddress(SimpleString address) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
boolean browseOnly) |
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
SimpleString filterString) |
ClientConsumer |
ClientSessionImpl.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.
|
ClientProducer |
ClientSessionImpl.createProducer(SimpleString address) |
ClientProducer |
ClientSessionImpl.createProducer(SimpleString address,
int maxRate) |
void |
ClientSessionImpl.createQueue(SimpleString address,
SimpleString queueName) |
void |
ClientSessionImpl.createQueue(SimpleString address,
SimpleString queueName,
boolean durable) |
void |
ClientSessionImpl.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable) |
void |
ClientSessionImpl.createSharedQueue(SimpleString address,
SimpleString queueName,
boolean durable) |
void |
ClientSessionImpl.createSharedQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
SimpleString queueName) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
SimpleString queueName,
SimpleString filter) |
void |
ClientSessionImpl.deleteQueue(SimpleString queueName) |
ClientProducerCredits |
ClientSessionImpl.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientSessionInternal.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientProducerCreditManagerImpl.getCredits(SimpleString address,
boolean anon,
SessionContext context) |
ClientProducerCredits |
ClientProducerCreditManager.getCredits(SimpleString address,
boolean anon,
SessionContext context) |
void |
ClientSessionImpl.handleReceiveProducerCredits(SimpleString address,
int credits) |
void |
ClientSessionInternal.handleReceiveProducerCredits(SimpleString address,
int credits) |
void |
ClientSessionImpl.handleReceiveProducerFailCredits(SimpleString address,
int credits) |
void |
ClientSessionInternal.handleReceiveProducerFailCredits(SimpleString address,
int credits) |
ClientMessageImpl |
ClientMessageImpl.putBooleanProperty(SimpleString key,
boolean value) |
ClientMessageImpl |
ClientMessageImpl.putByteProperty(SimpleString key,
byte value) |
ClientMessageImpl |
ClientMessageImpl.putBytesProperty(SimpleString key,
byte[] value) |
ClientMessageImpl |
ClientMessageImpl.putCharProperty(SimpleString key,
char value) |
ClientMessageImpl |
ClientMessageImpl.putDoubleProperty(SimpleString key,
double value) |
ClientMessageImpl |
ClientMessageImpl.putFloatProperty(SimpleString key,
float value) |
ClientMessageImpl |
ClientMessageImpl.putIntProperty(SimpleString key,
int value) |
ClientMessageImpl |
ClientMessageImpl.putLongProperty(SimpleString key,
long value) |
ClientMessageImpl |
ClientMessageImpl.putObjectProperty(SimpleString key,
Object value) |
ClientMessageImpl |
ClientMessageImpl.putShortProperty(SimpleString key,
short value) |
ClientMessageImpl |
ClientMessageImpl.putStringProperty(SimpleString key,
SimpleString value) |
ClientSession.QueueQuery |
ClientSessionImpl.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 |
ClientSessionImpl.returnCredits(SimpleString address) |
void |
ClientProducerCreditManagerImpl.returnCredits(SimpleString address) |
void |
ClientProducerCreditManager.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 |
ClientSessionInternal.sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
ClientSessionImpl.setAddress(Message message,
SimpleString address) |
void |
ClientSessionInternal.setAddress(Message message,
SimpleString address)
This will set the address at the message
|
void |
ClientMessageInternal.setAddressTransient(SimpleString address) |
void |
LargeMessageControllerImpl.writeNullableSimpleString(SimpleString val) |
void |
LargeMessageControllerImpl.writeSimpleString(SimpleString val) |
Constructor and Description |
---|
ClientConsumerImpl(ClientSessionInternal session,
ConsumerContext consumerContext,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
int clientWindowSize,
int ackBatchSize,
TokenBucketLimiter rateLimiter,
Executor executor,
Executor flowControlExecutor,
SessionContext sessionContext,
ClientSession.QueueQuery 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,
SessionContext sessionContext) |
QueueQueryImpl(boolean durable,
boolean temporary,
int consumerCount,
long messageCount,
SimpleString filterString,
SimpleString address,
SimpleString name,
boolean exists) |
QueueQueryImpl(boolean durable,
boolean temporary,
int consumerCount,
long messageCount,
SimpleString filterString,
SimpleString address,
SimpleString name,
boolean exists,
boolean autoCreateJmsQueues) |
Constructor and Description |
---|
AddressQueryImpl(boolean exists,
List<SimpleString> queueNames,
boolean autoCreateJmsQueues,
boolean autoCreateJmsTopics) |
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 |
---|---|
Configuration |
Configuration.setManagementAddress(SimpleString address)
Sets the management address of this server.
|
Configuration |
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 |
---|---|
ConfigurationImpl |
ConfigurationImpl.setManagementAddress(SimpleString address) |
ConfigurationImpl |
ConfigurationImpl.setManagementNotificationAddress(SimpleString address) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
Filter.getFilterString() |
Modifier and Type | Method and Description |
---|---|
SimpleString |
FilterImpl.getFilterString() |
Modifier and Type | Method and Description |
---|---|
static Filter |
FilterImpl.createFilter(SimpleString filterStr) |
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_ACK_IDS |
static SimpleString |
MessageImpl.HDR_ROUTE_TO_IDS |
static SimpleString |
MessageImpl.HDR_SCALEDOWN_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() |
SimpleString |
QueueBindingInfo.getUser() |
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 |
PersistedRoles.getAddressMatch() |
SimpleString |
PersistedAddressSetting.getAddressMatch() |
Constructor and Description |
---|
PersistedAddressSetting(SimpleString addressMatch,
AddressSettings setting) |
Modifier and Type | Field and Description |
---|---|
protected Map<SimpleString,PersistedAddressSetting> |
AbstractJournalStorageManager.mapPersistedAddressSettings |
protected Map<SimpleString,PersistedRoles> |
AbstractJournalStorageManager.mapPersistedRoles |
Modifier and Type | Method and Description |
---|---|
void |
AbstractJournalStorageManager.deleteAddressSetting(SimpleString addressMatch) |
void |
AbstractJournalStorageManager.deleteSecurityRoles(SimpleString addressMatch) |
void |
JournalStorageManager.pageClosed(SimpleString storeName,
int pageNumber) |
void |
JournalStorageManager.pageDeleted(SimpleString storeName,
int pageNumber) |
void |
AbstractJournalStorageManager.storeDuplicateID(SimpleString address,
byte[] duplID,
long recordID) |
void |
AbstractJournalStorageManager.storeDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID) |
void |
AbstractJournalStorageManager.updateDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
AbstractJournalStorageManager.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 | Field and Description |
---|---|
SimpleString |
DuplicateIDEncoding.address |
SimpleString |
PersistentQueueBindingEncoding.address |
SimpleString |
GroupingEncoding.clusterName |
SimpleString |
PersistentQueueBindingEncoding.filterString |
SimpleString |
GroupingEncoding.groupId |
SimpleString |
PersistentQueueBindingEncoding.name |
SimpleString |
PersistentQueueBindingEncoding.user |
Modifier and Type | Method and Description |
---|---|
SimpleString |
PersistentQueueBindingEncoding.getAddress() |
SimpleString |
GroupingEncoding.getClusterName() |
SimpleString |
PersistentQueueBindingEncoding.getFilterString() |
SimpleString |
GroupingEncoding.getGroupId() |
SimpleString |
PersistentQueueBindingEncoding.getQueueName() |
SimpleString |
PersistentQueueBindingEncoding.getUser() |
Modifier and Type | Method and Description |
---|---|
void |
PersistentQueueBindingEncoding.replaceQueueName(SimpleString newName) |
Constructor and Description |
---|
DuplicateIDEncoding(SimpleString address,
byte[] duplID) |
GroupingEncoding(long id,
SimpleString groupId,
SimpleString clusterName) |
PersistentQueueBindingEncoding(SimpleString name,
SimpleString address,
SimpleString filterString,
SimpleString user,
boolean autoCreated) |
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 |
QueueInfo.getAddress() |
SimpleString |
Address.getAddress() |
SimpleString |
Binding.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 |
---|---|
Set<SimpleString> |
AddressManager.getAddresses() |
Set<SimpleString> |
PostOffice.getAddresses() |
Map<SimpleString,Binding> |
PostOffice.getAllBindings() |
Map<SimpleString,Binding> |
AddressManager.getBindings() |
List<SimpleString> |
QueueInfo.getFilterStrings() |
Modifier and Type | Method and Description |
---|---|
Bindings |
BindingsFactory.createBindings(SimpleString address) |
Binding |
AddressManager.getBinding(SimpleString queueName) |
Binding |
PostOffice.getBinding(SimpleString uniqueName) |
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 |
AddressManager.getMatchingBindings(SimpleString address) |
Bindings |
PostOffice.getMatchingBindings(SimpleString address) |
boolean |
PostOffice.isAddressBound(SimpleString address) |
Bindings |
PostOffice.lookupBindingsForAddress(SimpleString address)
It will lookup the Binding without creating an item on the Queue if non-existent
|
boolean |
QueueInfo.matchesAddress(SimpleString address) |
Binding |
AddressManager.removeBinding(SimpleString uniqueName,
Transaction tx)
This will use a Transaction as we need to confirm the queue was removed
|
Binding |
PostOffice.removeBinding(SimpleString uniqueName,
Transaction tx,
boolean deleteData) |
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 |
static SimpleString |
PostOfficeImpl.HDR_RESET_QUEUE_DATA_COMPLETE |
Modifier and Type | Method and Description |
---|---|
SimpleString |
AddressImpl.getAddress() |
SimpleString |
LocalQueueBinding.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 |
---|---|
Set<SimpleString> |
PostOfficeImpl.getAddresses() |
Set<SimpleString> |
SimpleAddressManager.getAddresses() |
Map<SimpleString,Binding> |
PostOfficeImpl.getAllBindings() |
Map<SimpleString,Binding> |
SimpleAddressManager.getBindings() |
ConcurrentMap<SimpleString,DuplicateIDCache> |
PostOfficeImpl.getDuplicateIDCaches() |
Map<SimpleString,List<Binding>> |
BindingsImpl.getRoutingNameBindingMap() |
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) |
boolean |
PostOfficeImpl.isAddressBound(SimpleString address) |
Bindings |
PostOfficeImpl.lookupBindingsForAddress(SimpleString address) |
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) |
Binding |
PostOfficeImpl.removeBinding(SimpleString uniqueName,
Transaction tx,
boolean deleteData) |
protected void |
SimpleAddressManager.removeBindingInternal(SimpleString address,
SimpleString bindableName) |
protected Binding |
SimpleAddressManager.removeMapping(SimpleString bindableName,
Bindings bindings) |
void |
PostOfficeImpl.sendQueueInfoToQueue(SimpleString queueName,
SimpleString address) |
void |
LocalQueueBinding.unproposed(SimpleString groupID) |
void |
DivertBinding.unproposed(SimpleString groupID) |
void |
BindingsImpl.unproposed(SimpleString groupID) |
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 |
---|---|
ClientSession.AddressQuery |
ActiveMQSessionContext.addressQuery(SimpleString address) |
ClientConsumerInternal |
ActiveMQSessionContext.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
int ackBatchSize,
boolean browseOnly,
Executor executor,
Executor flowControlExecutor) |
void |
ActiveMQSessionContext.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temp) |
void |
ActiveMQSessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable) |
void |
ActiveMQSessionContext.deleteQueue(SimpleString queueName) |
void |
RemotingConnectionImpl.killMessage(SimpleString nodeID) |
void |
ActiveMQSessionContext.linkFlowControl(SimpleString address,
ClientProducerCreditsImpl clientProducerCredits) |
protected CreateSessionMessage |
ActiveMQSessionContext.newCreateSession(String username,
String password,
int minLargeMessageSize,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
SimpleString defaultAddress) |
ClientSession.QueueQuery |
ActiveMQSessionContext.queueQuery(SimpleString queueName) |
void |
ActiveMQSessionContext.recreateSession(String username,
String password,
int minLargeMessageSize,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
SimpleString defaultAddress) |
void |
ActiveMQSessionContext.sendFullMessage(MessageInternal msgI,
boolean sendBlocking,
SendAcknowledgementHandler handler,
SimpleString defaultAddress) |
void |
CoreSessionCallback.sendProducerCreditsFailMessage(int credits,
SimpleString address) |
void |
CoreSessionCallback.sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
ActiveMQSessionContext.sendProducerCreditsMessage(int credits,
SimpleString address) |
Modifier and Type | Field and Description |
---|---|
protected SimpleString |
SessionQueueQueryResponseMessage.address |
protected SimpleString |
SessionQueueQueryResponseMessage.filterString |
protected SimpleString |
SessionQueueQueryResponseMessage.name |
protected SimpleString |
DisconnectMessage.nodeID |
Modifier and Type | Field and Description |
---|---|
protected List<SimpleString> |
SessionBindingQueryResponseMessage.queueNames |
Modifier and Type | Method and Description |
---|---|
SimpleString |
CreateSharedQueueMessage.getAddress() |
SimpleString |
SessionRequestProducerCreditsMessage.getAddress() |
SimpleString |
SessionBindingQueryMessage.getAddress() |
SimpleString |
CreateQueueMessage.getAddress() |
SimpleString |
SessionProducerCreditsFailMessage.getAddress() |
SimpleString |
SessionProducerCreditsMessage.getAddress() |
SimpleString |
SessionQueueQueryResponseMessage.getAddress() |
SimpleString |
CreateSharedQueueMessage.getFilterString() |
SimpleString |
CreateQueueMessage.getFilterString() |
SimpleString |
SessionQueueQueryResponseMessage.getFilterString() |
SimpleString |
SessionCreateConsumerMessage.getFilterString() |
SimpleString |
QuorumVoteReplyMessage.getHandler() |
SimpleString |
QuorumVoteMessage.getHandler() |
SimpleString |
SessionQueueQueryResponseMessage.getName() |
SimpleString |
BackupRequestMessage.getNodeID() |
SimpleString |
DisconnectConsumerWithKillMessage.getNodeID() |
SimpleString |
DisconnectMessage.getNodeID() |
SimpleString |
ReplicationSyncFileMessage.getPageStore() |
SimpleString |
CreateSharedQueueMessage.getQueueName() |
SimpleString |
CreateQueueMessage.getQueueName() |
SimpleString |
SessionDeleteQueueMessage.getQueueName() |
SimpleString |
SessionQueueQueryMessage.getQueueName() |
SimpleString |
SessionCreateConsumerMessage.getQueueName() |
SimpleString |
ScaleDownAnnounceMessage.getScaledDownNodeId() |
SimpleString |
DisconnectMessage_V2.getScaleDownNodeID() |
SimpleString |
ReplicationPageEventMessage.getStoreName() |
SimpleString |
ScaleDownAnnounceMessage.getTargetNodeId() |
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_V2(boolean exists,
List<SimpleString> queueNames,
boolean autoCreateJmsQueues) |
SessionBindingQueryResponseMessage_V3(boolean exists,
List<SimpleString> queueNames,
boolean autoCreateJmsQueues,
boolean autoCreateJmsTopics) |
SessionBindingQueryResponseMessage(boolean exists,
List<SimpleString> queueNames) |
Modifier and Type | Method and Description |
---|---|
ClientSession.AddressQuery |
HornetQClientSessionContext.addressQuery(SimpleString address) |
ClientConsumerInternal |
HornetQClientSessionContext.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
int ackBatchSize,
boolean browseOnly,
Executor executor,
Executor flowControlExecutor) |
protected CreateSessionMessage |
HornetQClientSessionContext.newCreateSession(String username,
String password,
int minLargeMessageSize,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
SimpleString defaultAddress) |
ClientSession.QueueQuery |
HornetQClientSessionContext.queueQuery(SimpleString queueName) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQProtonRemotingConnection.killMessage(SimpleString nodeID) |
Modifier and Type | Method and Description |
---|---|
void |
ProtonSessionIntegrationCallback.sendProducerCreditsFailMessage(int credits,
SimpleString address) |
void |
ProtonSessionIntegrationCallback.sendProducerCreditsMessage(int credits,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
void |
StompConnection.killMessage(SimpleString nodeID) |
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,
SecurityAuth session) |
Modifier and Type | Method and Description |
---|---|
void |
SecurityStoreImpl.check(SimpleString address,
CheckType checkType,
SecurityAuth session) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
Queue.getAddress() |
SimpleString |
QueueQueryResult.getAddress() |
SimpleString |
Queue.getExpiryAddress() |
SimpleString |
QueueQueryResult.getFilterString() |
SimpleString |
Queue.getName() |
SimpleString |
QueueQueryResult.getName() |
SimpleString |
NodeManager.getNodeId() |
SimpleString |
ActiveMQServer.getNodeID() |
SimpleString |
TransientQueueManager.getQueueName() |
SimpleString |
AutoCreatedQueueManager.getQueueName() |
SimpleString |
Divert.getRoutingName() |
SimpleString |
Divert.getUniqueName() |
SimpleString |
Queue.getUser() |
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 |
ActiveMQServerLogger_$logger.activatingReplica(SimpleString nodeID) |
void |
ActiveMQServerLogger.activatingReplica(SimpleString nodeID) |
void |
RoutingContext.addQueue(SimpleString address,
Queue queue) |
void |
RoutingContext.addQueueWithAck(SimpleString address,
Queue queue) |
void |
ActiveMQServer.addScaledDownNode(SimpleString scaledDownNodeId) |
void |
ActiveMQServerLogger_$logger.backupServerStarted(String version,
SimpleString nodeID) |
void |
ActiveMQServerLogger.backupServerStarted(String version,
SimpleString nodeID) |
ActiveMQInternalErrorException |
ActiveMQMessageBundle_$bundle.bindingNotDivert(SimpleString name) |
ActiveMQInternalErrorException |
ActiveMQMessageBundle.bindingNotDivert(SimpleString name) |
BindingQueryResult |
ActiveMQServer.bindingQuery(SimpleString address) |
void |
ActiveMQServerLogger_$logger.blockingMessageProduction(SimpleString addressName,
long currentSize,
long maxSize) |
void |
ActiveMQServerLogger.blockingMessageProduction(SimpleString addressName,
long currentSize,
long maxSize) |
void |
ActiveMQServerLogger_$logger.bridgeAbortStart(SimpleString name,
Integer retryCount,
Integer reconnectAttempts) |
void |
ActiveMQServerLogger.bridgeAbortStart(SimpleString name,
Integer retryCount,
Integer reconnectAttempts) |
void |
ActiveMQServerLogger_$logger.bridgeNoBindings(SimpleString name,
SimpleString forwardingAddress,
SimpleString address) |
void |
ActiveMQServerLogger.bridgeNoBindings(SimpleString name,
SimpleString forwardingAddress,
SimpleString address) |
void |
ActiveMQServerLogger_$logger.bridgePaused(SimpleString name) |
void |
ActiveMQServerLogger.bridgePaused(SimpleString name) |
void |
ActiveMQServerLogger_$logger.bridgeStopped(SimpleString name) |
void |
ActiveMQServerLogger.bridgeStopped(SimpleString name) |
void |
PostQueueCreationCallback.callback(SimpleString queueName) |
void |
PostQueueDeletionCallback.callback(SimpleString address,
SimpleString queueName) |
void |
ActiveMQServer.callPostQueueCreationCallbacks(SimpleString queueName) |
void |
ActiveMQServer.callPostQueueDeletionCallbacks(SimpleString address,
SimpleString queueName) |
ActiveMQIllegalStateException |
ActiveMQMessageBundle_$bundle.cannotDeleteQueue(SimpleString name,
SimpleString queueName,
String s) |
ActiveMQIllegalStateException |
ActiveMQMessageBundle.cannotDeleteQueue(SimpleString name,
SimpleString queueName,
String s) |
ActiveMQIllegalStateException |
ActiveMQMessageBundle_$bundle.consumerNoReference(Long id,
Long messageID,
SimpleString name) |
ActiveMQIllegalStateException |
ActiveMQMessageBundle.consumerNoReference(Long id,
Long messageID,
SimpleString name) |
boolean |
QueueCreator.create(SimpleString address)
You should return true if you even tried to create the queue and the queue was already there.
|
ServerConsumer |
ServerSession.createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
ServerConsumer |
ServerSession.createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage,
Integer credits) |
Queue |
QueueFactory.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary) |
Queue |
ServerSession.createQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated) |
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
boolean durable,
SimpleString filterString) |
void |
ActiveMQServer.createSharedQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable)
Creates a shared queue.
|
boolean |
QueueDeleter.delete(SimpleString queueName) |
void |
ServerSession.deleteQueue(SimpleString name) |
void |
ActiveMQServerLogger_$logger.deployQueue(SimpleString queueName) |
void |
ActiveMQServerLogger.deployQueue(SimpleString queueName) |
Queue |
ActiveMQServer.deployQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServer.deployQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary,
boolean autoCreated) |
void |
ActiveMQServerLogger_$logger.deployTopic(SimpleString topicName) |
void |
ActiveMQServerLogger.deployTopic(SimpleString topicName) |
void |
ActiveMQServer.destroyDivert(SimpleString name) |
void |
ActiveMQServer.destroyQueue(SimpleString queueName) |
void |
ActiveMQServer.destroyQueue(SimpleString queueName,
SecurityAuth session) |
void |
ActiveMQServer.destroyQueue(SimpleString queueName,
SecurityAuth session,
boolean checkConsumerCount) |
void |
ActiveMQServer.destroyQueue(SimpleString queueName,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers) |
void |
ActiveMQServerLogger_$logger.divertBindingNotExists(SimpleString bindingName) |
void |
ActiveMQServerLogger.divertBindingNotExists(SimpleString bindingName) |
void |
ActiveMQServerLogger_$logger.errorExpiringReferencesNoBindings(SimpleString expiryAddress) |
void |
ActiveMQServerLogger.errorExpiringReferencesNoBindings(SimpleString expiryAddress) |
void |
ActiveMQServerLogger_$logger.errorExpiringReferencesNoQueue(SimpleString name) |
void |
ActiveMQServerLogger.errorExpiringReferencesNoQueue(SimpleString name) |
void |
ActiveMQServerLogger_$logger.errorQueryingBridge(SimpleString address,
Integer retryCount) |
void |
ActiveMQServerLogger.errorQueryingBridge(SimpleString address,
Integer retryCount) |
void |
ActiveMQServerLogger_$logger.errorQueryingBridge(Throwable t,
SimpleString name) |
void |
ActiveMQServerLogger.errorQueryingBridge(Throwable t,
SimpleString name) |
void |
ActiveMQServerLogger_$logger.errorRemovingAutoCreatedQueue(Exception e,
SimpleString bindingName) |
void |
ActiveMQServerLogger.errorRemovingAutoCreatedQueue(Exception e,
SimpleString bindingName) |
void |
ActiveMQServerLogger_$logger.errorRemovingTempQueue(Exception e,
SimpleString bindingName) |
void |
ActiveMQServerLogger.errorRemovingTempQueue(Exception e,
SimpleString bindingName) |
void |
ActiveMQServerLogger_$logger.errorStartingBridge(SimpleString name) |
void |
ActiveMQServerLogger.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 |
ActiveMQServerLogger_$logger.groupingQueueRemoved(int size,
SimpleString clusterName) |
void |
ActiveMQServerLogger.groupingQueueRemoved(int size,
SimpleString clusterName) |
boolean |
ActiveMQServer.hasScaledDown(SimpleString scaledDownNodeId) |
void |
ActiveMQServerLogger_$logger.invalidFilter(SimpleString filter) |
void |
ActiveMQServerLogger.invalidFilter(SimpleString filter) |
ActiveMQInvalidFilterExpressionException |
ActiveMQMessageBundle_$bundle.invalidFilter(Throwable e,
SimpleString filter) |
ActiveMQInvalidFilterExpressionException |
ActiveMQMessageBundle.invalidFilter(Throwable e,
SimpleString filter) |
boolean |
RoutingContext.isAlreadyAcked(SimpleString address,
Queue queue) |
Queue |
ActiveMQServer.locateQueue(SimpleString queueName) |
void |
ActiveMQServerLogger_$logger.messageExceededMaxDelivery(MessageReference ref,
SimpleString name) |
void |
ActiveMQServerLogger.messageExceededMaxDelivery(MessageReference ref,
SimpleString name) |
void |
ActiveMQServerLogger_$logger.messageExceededMaxDeliveryNoDLA(SimpleString name) |
void |
ActiveMQServerLogger.messageExceededMaxDeliveryNoDLA(SimpleString name) |
void |
ActiveMQServerLogger_$logger.messageExceededMaxDeliverySendtoDLA(MessageReference ref,
SimpleString name,
SimpleString simpleString) |
void |
ActiveMQServerLogger.messageExceededMaxDeliverySendtoDLA(MessageReference ref,
SimpleString name,
SimpleString simpleString) |
void |
ActiveMQServerLogger_$logger.messageWithDuplicateID(Object duplicateProperty,
SimpleString toAddress,
SimpleString address,
SimpleString simpleString) |
void |
ActiveMQServerLogger.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) |
ActiveMQInternalErrorException |
ActiveMQMessageBundle_$bundle.noBindingForDivert(SimpleString name) |
ActiveMQInternalErrorException |
ActiveMQMessageBundle.noBindingForDivert(SimpleString name) |
void |
ActiveMQServerLogger_$logger.noDLA(SimpleString address) |
void |
ActiveMQServerLogger.noDLA(SimpleString address) |
void |
ActiveMQServerLogger_$logger.noQueueIdDefined(ServerMessage message,
ServerMessage messageCopy,
SimpleString idsHeaderName) |
void |
ActiveMQServerLogger.noQueueIdDefined(ServerMessage message,
ServerMessage messageCopy,
SimpleString idsHeaderName) |
ActiveMQNonExistentQueueException |
ActiveMQMessageBundle_$bundle.noSuchQueue(SimpleString queueName) |
ActiveMQNonExistentQueueException |
ActiveMQMessageBundle.noSuchQueue(SimpleString queueName) |
void |
ActiveMQServerLogger_$logger.pageStoreDropMessages(SimpleString storeName,
long addressSize,
long maxSize) |
void |
ActiveMQServerLogger.pageStoreDropMessages(SimpleString storeName,
long addressSize,
long maxSize) |
void |
ActiveMQServerLogger_$logger.pageStoreStart(SimpleString storeName,
long addressSize,
long maxSize) |
void |
ActiveMQServerLogger.pageStoreStart(SimpleString storeName,
long addressSize,
long maxSize) |
void |
ActiveMQServerLogger_$logger.pageStoreTimeout(SimpleString address) |
void |
ActiveMQServerLogger.pageStoreTimeout(SimpleString address) |
void |
ActiveMQServerLogger_$logger.pageSubscriptionCouldntLoad(long transactionID,
PagePosition position,
SimpleString address,
SimpleString name) |
void |
ActiveMQServerLogger.pageSubscriptionCouldntLoad(long transactionID,
PagePosition position,
SimpleString address,
SimpleString name) |
void |
ActiveMQServerLogger_$logger.problemCleaningPageAddress(Exception e,
SimpleString address) |
void |
ActiveMQServerLogger.problemCleaningPageAddress(Exception e,
SimpleString address) |
ActiveMQQueueExistsException |
ActiveMQMessageBundle_$bundle.queueAlreadyExists(SimpleString queueName) |
ActiveMQQueueExistsException |
ActiveMQMessageBundle.queueAlreadyExists(SimpleString queueName) |
QueueQueryResult |
ActiveMQServer.queueQuery(SimpleString name) |
ActiveMQInvalidTransientQueueUseException |
ActiveMQMessageBundle_$bundle.queueSubscriptionBelongsToDifferentAddress(SimpleString queueName) |
ActiveMQInvalidTransientQueueUseException |
ActiveMQMessageBundle.queueSubscriptionBelongsToDifferentAddress(SimpleString queueName) |
ActiveMQInvalidTransientQueueUseException |
ActiveMQMessageBundle_$bundle.queueSubscriptionBelongsToDifferentFilter(SimpleString queueName) |
ActiveMQInvalidTransientQueueUseException |
ActiveMQMessageBundle.queueSubscriptionBelongsToDifferentFilter(SimpleString queueName) |
void |
ActiveMQServerLogger_$logger.remoteQueueAlreadyBoundOnClusterConnection(Object messageFlowRecord,
SimpleString clusterName) |
void |
ActiveMQServerLogger.remoteQueueAlreadyBoundOnClusterConnection(Object messageFlowRecord,
SimpleString clusterName) |
void |
ServerSession.requestProducerCredits(SimpleString address,
int credits) |
void |
ActiveMQServerLogger_$logger.serverStarted(String fullVersion,
String name,
SimpleString nodeId,
String identity) |
void |
ActiveMQServerLogger.serverStarted(String fullVersion,
String name,
SimpleString nodeId,
String identity) |
void |
ActiveMQServerLogger_$logger.serverStopped(String version,
SimpleString nodeId,
String uptime) |
void |
ActiveMQServerLogger.serverStopped(String version,
SimpleString nodeId,
String uptime) |
void |
ActiveMQServerLogger_$logger.unableToDeleteGroupBindings(Exception e,
SimpleString groupId) |
void |
ActiveMQServerLogger.unableToDeleteGroupBindings(Exception e,
SimpleString groupId) |
void |
ActiveMQServerLogger_$logger.unableToStartBridge(Exception e,
SimpleString name) |
void |
ActiveMQServerLogger.unableToStartBridge(Exception e,
SimpleString name) |
void |
ActiveMQServerLogger_$logger.unableToStartClusterConnection(Exception e,
SimpleString name) |
void |
ActiveMQServerLogger.unableToStartClusterConnection(Exception e,
SimpleString name) |
void |
ActiveMQServerLogger_$logger.unblockingMessageProduction(SimpleString addressName,
long currentSize,
long maxSize) |
void |
ActiveMQServerLogger.unblockingMessageProduction(SimpleString addressName,
long currentSize,
long maxSize) |
void |
Queue.unproposed(SimpleString groupID) |
Constructor and Description |
---|
QueueQueryResult(SimpleString name,
SimpleString address,
boolean durable,
boolean temporary,
SimpleString filterString,
int consumerCount,
long messageCount,
boolean autoCreateJmsQueues) |
QueueQueryResult(SimpleString name,
SimpleString address,
boolean durable,
boolean temporary,
SimpleString filterString,
int consumerCount,
long messageCount,
boolean autoCreateJmsQueues,
boolean exists) |
Constructor and Description |
---|
BindingQueryResult(boolean exists,
List<SimpleString> queueNames,
boolean autoCreateJmsQueues,
boolean autoCreateJmsTopics) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
Bridge.getForwardingAddress() |
SimpleString |
Bridge.getName() |
SimpleString |
ClusterConnection.getName() |
SimpleString |
ClusterController.getNodeID() |
Modifier and Type | Method and Description |
---|---|
void |
ClusterController.addClusterConnection(SimpleString name,
DiscoveryGroupConfiguration dg,
ClusterConnectionConfiguration config)
add a locator for a cluster connection.
|
void |
ClusterController.addClusterConnection(SimpleString name,
TransportConfiguration[] tcConfigs,
ClusterConnectionConfiguration config)
add a locator for a cluster connection.
|
void |
RemoteQueueBinding.addConsumer(SimpleString filterString) |
void |
ClusterControl.announceScaleDown(SimpleString targetNodeId,
SimpleString scaledDownNodeId) |
void |
RemoteQueueBinding.removeConsumer(SimpleString filterString) |
boolean |
ClusterControl.requestReplicatedBackup(int backupSize,
SimpleString nodeID) |
Vote |
ClusterControl.sendQuorumVote(SimpleString handler,
Vote vote) |
void |
ClusterController.setDefaultClusterConnectionName(SimpleString defaultClusterConnection) |
Modifier and Type | Method and Description |
---|---|
boolean |
ColocatedHAManager.activateBackup(int backupSize,
String journalDirectory,
String bindingsDirectory,
String largeMessagesDirectory,
String pagingDirectory,
SimpleString nodeID) |
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) |
void |
RemoteQueueBindingImpl.unproposed(SimpleString groupID) |
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,
MessageLoadBalancingType messageLoadBalancingType,
int confirmationWindowSize,
int producerWindowSize,
ExecutorFactory executorFactory,
ActiveMQServer 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,
MessageLoadBalancingType messageLoadBalancingType,
int confirmationWindowSize,
int producerWindowSize,
ExecutorFactory executorFactory,
ActiveMQServer 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 |
QuorumVoteServerConnect.getName() |
SimpleString |
QuorumVote.getName()
the name of this quorum vote, used for identifying the correct
QuorumVoteHandler |
SimpleString |
QuorumVoteHandler.getQuorumName()
the name of the quorum vote
|
Modifier and Type | Method and Description |
---|---|
QuorumVoteHandler |
QuorumManager.getVoteHandler(SimpleString handler) |
Vote |
QuorumManager.vote(SimpleString handler,
Vote vote)
handle a vote received on the quorum
|
Constructor and Description |
---|
QuorumVote(SimpleString name) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
GroupingHandler.getName() |
Modifier and Type | Method and Description |
---|---|
void |
GroupingHandler.forceRemove(SimpleString groupid,
SimpleString clusterName)
this will force a removal of the group everywhere with an unproposal (dinstance=0).
|
Response |
GroupingHandler.getProposal(SimpleString fullID,
boolean touchTime) |
void |
GroupingHandler.remove(SimpleString groupid,
SimpleString clusterName) |
void |
GroupingHandler.remove(SimpleString groupid,
SimpleString clusterName,
int distance) |
void |
UnproposalListener.unproposed(SimpleString groupID) |
Modifier and Type | Field and Description |
---|---|
protected SimpleString |
GroupHandlingAbstract.address |
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 |
LocalGroupingHandler.getName() |
SimpleString |
RemoteGroupingHandler.getName() |
SimpleString |
GroupingHandlerConfiguration.getName() |
Modifier and Type | Method and Description |
---|---|
protected void |
GroupHandlingAbstract.fireUnproposed(SimpleString groupID) |
void |
GroupHandlingAbstract.forceRemove(SimpleString groupid,
SimpleString clusterName) |
Response |
LocalGroupingHandler.getProposal(SimpleString fullID,
boolean touchTime) |
Response |
RemoteGroupingHandler.getProposal(SimpleString fullID,
boolean touchTime) |
void |
LocalGroupingHandler.remove(SimpleString groupid,
SimpleString clusterName) |
void |
RemoteGroupingHandler.remove(SimpleString groupid,
SimpleString clusterName) |
void |
LocalGroupingHandler.remove(SimpleString groupid,
SimpleString clusterName,
int distance) |
void |
RemoteGroupingHandler.remove(SimpleString groupid,
SimpleString clusterName,
int distance) |
protected void |
GroupHandlingAbstract.sendUnproposal(SimpleString groupid,
SimpleString clusterName,
int distance) |
GroupingHandlerConfiguration |
GroupingHandlerConfiguration.setAddress(SimpleString address) |
GroupingHandlerConfiguration |
GroupingHandlerConfiguration.setName(SimpleString name) |
Constructor and Description |
---|
GroupBinding(long id,
SimpleString groupId,
SimpleString clusterName) |
GroupBinding(SimpleString groupId,
SimpleString clusterName) |
GroupHandlingAbstract(Executor executor,
ManagementService managementService,
SimpleString address) |
LocalGroupingHandler(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
SimpleString name,
SimpleString address,
StorageManager storageManager,
long timeout,
long groupTimeout,
long reaperPeriod) |
Proposal(SimpleString groupId,
SimpleString clusterName) |
RemoteGroupingHandler(ExecutorFactory executorFactory,
ManagementService managementService,
SimpleString name,
SimpleString address,
long timeout,
long groupTimeout) |
RemoteGroupingHandler(ManagementService managementService,
SimpleString name,
SimpleString address,
long timeout,
long groupTimeout) |
Response(SimpleString groupId,
SimpleString clusterName) |
Response(SimpleString groupId,
SimpleString clusterName,
SimpleString alternativeClusterName) |
Modifier and Type | Field and Description |
---|---|
protected Map<SimpleString,Pair<UUID,AtomicLong>> |
ServerSessionImpl.targetAddressInfos |
protected Map<SimpleString,ServerSessionImpl.TempQueueCleanerUpper> |
ServerSessionImpl.tempQueueCleannerUppers |
Modifier and Type | Method and Description |
---|---|
SimpleString |
QueueImpl.getAddress() |
SimpleString |
QueueImpl.getExpiryAddress() |
SimpleString |
QueueImpl.getName() |
SimpleString |
ActiveMQServerImpl.getNodeID() |
SimpleString |
TransientQueueManagerImpl.getQueueName() |
SimpleString |
AutoCreatedQueueManagerImpl.getQueueName() |
SimpleString |
DivertImpl.getRoutingName() |
SimpleString |
QueueImpl.getRoutingName() |
SimpleString |
DivertImpl.getUniqueName() |
SimpleString |
QueueImpl.getUniqueName() |
SimpleString |
QueueImpl.getUser() |
SimpleString |
InVMNodeManager.readNodeId() |
SimpleString |
FileLockNodeManager.readNodeId() |
Modifier and Type | Method and Description |
---|---|
Map<SimpleString,RouteContextList> |
RoutingContextImpl.getContexListing() |
List<SimpleString> |
QueueImpl.getGroupsUsed()
For testing only
|
Modifier and Type | Method and Description |
---|---|
void |
RoutingContextImpl.addQueue(SimpleString address,
Queue queue) |
void |
RoutingContextImpl.addQueueWithAck(SimpleString address,
Queue queue) |
void |
ActiveMQServerImpl.addScaledDownNode(SimpleString scaledDownNodeId) |
BindingQueryResult |
ActiveMQServerImpl.bindingQuery(SimpleString address) |
void |
ActiveMQServerImpl.callPostQueueCreationCallbacks(SimpleString queueName) |
void |
ActiveMQServerImpl.callPostQueueDeletionCallbacks(SimpleString address,
SimpleString queueName) |
ServerConsumer |
ServerSessionImpl.createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
ServerConsumer |
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,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated) |
Queue |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
SimpleString user,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated) |
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
boolean durable,
SimpleString filterString) |
void |
ActiveMQServerImpl.createSharedQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable)
Creates a transient queue.
|
void |
ServerSessionImpl.deleteQueue(SimpleString queueToDelete) |
Queue |
ActiveMQServerImpl.deployQueue(SimpleString address,
SimpleString resourceName,
SimpleString filterString,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServerImpl.deployQueue(SimpleString address,
SimpleString resourceName,
SimpleString filterString,
boolean durable,
boolean temporary,
boolean autoCreated) |
void |
ActiveMQServerImpl.destroyDivert(SimpleString name) |
void |
ActiveMQServerImpl.destroyQueue(SimpleString queueName) |
void |
ActiveMQServerImpl.destroyQueue(SimpleString queueName,
SecurityAuth session) |
void |
ActiveMQServerImpl.destroyQueue(SimpleString queueName,
SecurityAuth session,
boolean checkConsumerCount) |
void |
ActiveMQServerImpl.destroyQueue(SimpleString queueName,
SecurityAuth 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) |
boolean |
ActiveMQServerImpl.hasScaledDown(SimpleString scaledDownNodeId) |
boolean |
RoutingContextImpl.isAlreadyAcked(SimpleString address,
Queue queue) |
Queue |
ActiveMQServerImpl.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) |
int |
QueueImpl.moveReferencesBetweenSnFQueues(SimpleString queueSuffix) |
QueueQueryResult |
ActiveMQServerImpl.queueQuery(SimpleString name) |
void |
ServerSessionImpl.requestProducerCredits(SimpleString address,
int credits) |
long |
ScaleDownHandler.scaleDown(ClientSessionFactory sessionFactory,
ResourceManager resourceManager,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
SimpleString managementAddress,
SimpleString targetNodeId) |
void |
ScaleDownHandler.scaleDownDuplicateIDs(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
ClientSessionFactory sessionFactory,
SimpleString managementAddress,
String user,
String password) |
long |
ScaleDownHandler.scaleDownMessages(ClientSessionFactory sessionFactory,
SimpleString nodeId,
String user,
String password) |
long |
ScaleDownHandler.scaleDownRegularMessages(SimpleString address,
Set<Queue> queues,
ClientSession clientSession,
ClientProducer producer) |
protected void |
ServerSessionImpl.securityCheck(SimpleString address,
CheckType checkType,
SecurityAuth auth) |
void |
QueueImpl.unproposed(SimpleString groupID) |
Modifier and Type | Method and Description |
---|---|
void |
PostOfficeJournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
void |
BackupRecoveryJournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
void |
JournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
void |
PostOfficeJournalLoader.postLoad(Journal messageJournal,
ResourceManager resourceManager,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
void |
BackupRecoveryJournalLoader.postLoad(Journal messageJournal,
ResourceManager resourceManager,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
void |
JournalLoader.postLoad(Journal messageJournal,
ResourceManager resourceManager,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
long |
ScaleDownHandler.scaleDown(ClientSessionFactory sessionFactory,
ResourceManager resourceManager,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
SimpleString managementAddress,
SimpleString targetNodeId) |
void |
ScaleDownHandler.scaleDownDuplicateIDs(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
ClientSessionFactory sessionFactory,
SimpleString managementAddress,
String user,
String password) |
Constructor and Description |
---|
AutoCreatedQueueManagerImpl(QueueDeleter deleter,
SimpleString queueName) |
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,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
ServerSessionImpl(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
boolean xa,
RemotingConnection remotingConnection,
StorageManager storageManager,
PostOffice postOffice,
ResourceManager resourceManager,
SecurityStore securityStore,
ManagementService managementService,
ActiveMQServer server,
SimpleString managementAddress,
SimpleString defaultAddress,
SessionCallback callback,
OperationContext context,
QueueCreator queueCreator) |
TempQueueCleanerUpper(ActiveMQServer server,
SimpleString bindingName) |
TransientQueueManagerImpl(ActiveMQServer 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 | Field and Description |
---|---|
static SimpleString |
ResourceLimitSettings.DEFAULT_MATCH |
Modifier and Type | Method and Description |
---|---|
SimpleString |
AddressSettings.getDeadLetterAddress() |
SimpleString |
AddressSettings.getExpiryAddress() |
SimpleString |
ResourceLimitSettings.getMatch() |
Modifier and Type | Method and Description |
---|---|
AddressSettings |
AddressSettings.setDeadLetterAddress(SimpleString deadLetterAddress) |
AddressSettings |
AddressSettings.setExpiryAddress(SimpleString expiryAddress) |
void |
ResourceLimitSettings.setMatch(SimpleString match) |
Modifier and Type | Field and Description |
---|---|
static SimpleString |
ActiveMQConnection.CONNECTION_ID_PROPERTY_NAME |
Modifier and Type | Method and Description |
---|---|
static SimpleString |
ActiveMQTopic.createAddressFromName(String name) |
static SimpleString |
ActiveMQQueue.createAddressFromName(String name) |
static SimpleString |
ActiveMQDestination.createQueueAddressFromName(String name) |
static SimpleString |
ActiveMQDestination.createTopicAddressFromName(String name) |
SimpleString |
ActiveMQDestination.getSimpleAddress() |
SimpleString |
ActiveMQConnection.getUID() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQConnection.addKnownDestination(SimpleString address) |
void |
ActiveMQConnection.addTemporaryQueue(SimpleString queueAddress) |
boolean |
ActiveMQConnection.containsKnownDestination(SimpleString address) |
boolean |
ActiveMQConnection.containsTemporaryQueue(SimpleString queueAddress) |
ActiveMQNonExistentQueueException |
ActiveMQJMSClientBundle_$bundle.destinationDoesNotExist(SimpleString destination) |
ActiveMQNonExistentQueueException |
ActiveMQJMSClientBundle.destinationDoesNotExist(SimpleString destination) |
ActiveMQInvalidFilterExpressionException |
ActiveMQJMSClientBundle_$bundle.invalidFilter(Throwable e,
SimpleString filter) |
ActiveMQInvalidFilterExpressionException |
ActiveMQJMSClientBundle.invalidFilter(Throwable e,
SimpleString filter) |
void |
ActiveMQConnection.removeTemporaryQueue(SimpleString queueAddress) |
Constructor and Description |
---|
ActiveMQMessageConsumer(ConnectionFactoryOptions options,
ActiveMQConnection connection,
ActiveMQSession session,
ClientConsumer consumer,
boolean noLocal,
ActiveMQDestination destination,
String selector,
SimpleString autoDeleteQueueName) |
Modifier and Type | Field and Description |
---|---|
static SimpleString |
JMSNotificationType.MESSAGE |
Modifier and Type | Method and Description |
---|---|
SimpleString |
ActiveMQActivation.getAddress() |
SimpleString |
ActiveMQActivation.getTopicTemporaryQueue() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQActivation.setTopicTemporaryQueue(SimpleString topicTemporaryQueue) |
Modifier and Type | Field and Description |
---|---|
static SimpleString |
MessageUtil.CONNECTION_ID_PROPERTY_NAME |
static SimpleString |
MessageUtil.CORRELATIONID_HEADER_NAME |
static SimpleString |
MessageUtil.JMS |
static SimpleString |
MessageUtil.JMS_ |
static SimpleString |
MessageUtil.JMSX |
static SimpleString |
MessageUtil.REPLYTO_HEADER_NAME |
static SimpleString |
MessageUtil.TYPE_HEADER_NAME |
Modifier and Type | Method and Description |
---|---|
static SimpleString |
MessageUtil.getJMSReplyTo(Message message) |
static SimpleString |
TextMessageUtil.readBodyText(ActiveMQBuffer buff)
Utility method to set the Text message on a message body
|
Modifier and Type | Method and Description |
---|---|
static void |
MessageUtil.setJMSReplyTo(Message message,
SimpleString dest) |
static void |
TextMessageUtil.writeBodyText(ActiveMQBuffer buff,
SimpleString text)
Utility method to set the Text message on a message body
|
Modifier and Type | Method and Description |
---|---|
void |
RemotingConnection.killMessage(SimpleString nodeID)
if slow consumer is killed,send the msessage to client.
|
void |
SessionCallback.sendProducerCreditsFailMessage(int credits,
SimpleString address) |
void |
SessionCallback.sendProducerCreditsMessage(int credits,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
abstract ClientSession.AddressQuery |
SessionContext.addressQuery(SimpleString address) |
abstract ClientConsumerInternal |
SessionContext.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
int ackBatchSize,
boolean browseOnly,
Executor executor,
Executor flowControlExecutor) |
abstract void |
SessionContext.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temp) |
abstract void |
SessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable) |
abstract void |
SessionContext.deleteQueue(SimpleString queueName) |
protected void |
SessionContext.handleReceiveProducerCredits(SimpleString address,
int credits) |
protected void |
SessionContext.handleReceiveProducerFailCredits(SimpleString address,
int credits) |
abstract void |
SessionContext.linkFlowControl(SimpleString address,
ClientProducerCreditsImpl clientProducerCredits) |
abstract ClientSession.QueueQuery |
SessionContext.queueQuery(SimpleString queueName) |
abstract void |
SessionContext.recreateSession(String username,
String password,
int minLargeMessageSize,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
SimpleString defaultAddress) |
abstract void |
SessionContext.sendFullMessage(MessageInternal msgI,
boolean sendBlocking,
SendAcknowledgementHandler handler,
SimpleString defaultAddress) |
abstract void |
SessionContext.sendProducerCreditsMessage(int credits,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
SimpleString |
UUIDGenerator.generateSimpleStringUUID() |
SimpleString |
TypedProperties.getSimpleStringProperty(SimpleString key) |
static SimpleString |
RandomUtil.randomSimpleString() |
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 © 2016 The Apache Software Foundation. All rights reserved.