| 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_BRIDGE_DUPLICATE_ID |
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 the message was transferred.
|
static SimpleString |
Message.HDR_ORIGINAL_ADDRESS
The original address of a message when a message is diverted or 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_PREFIX
The prefix used (if any) when sending this message.
|
static SimpleString |
Message.HDR_ROUTE_TO_ACK_IDS |
static SimpleString |
Message.HDR_ROUTE_TO_IDS |
static SimpleString |
Message.HDR_ROUTING_TYPE
The Routing Type for this message.
|
static SimpleString |
Message.HDR_SCALEDOWN_TO_IDS |
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
|
protected SimpleString |
SimpleString.ByteBufSimpleStringPool.create(io.netty.buffer.ByteBuf byteBuf,
int length) |
protected SimpleString |
SimpleString.StringSimpleStringPool.create(String value) |
SimpleString |
ParameterisedAddress.getAddress() |
SimpleString |
Message.getAddressSimpleString() |
default SimpleString |
Message.getGroupID() |
default SimpleString |
Message.getLastValueProperty() |
SimpleString |
Message.getReplyTo() |
SimpleString |
Message.getSimpleStringProperty(SimpleString key) |
SimpleString |
Message.getSimpleStringProperty(String key) |
SimpleString |
ActiveMQBuffer.readNullableSimpleString()
Gets a SimpleString (potentially
null) at the current readerIndex |
static SimpleString |
SimpleString.readNullableSimpleString(io.netty.buffer.ByteBuf buffer) |
static SimpleString |
SimpleString.readNullableSimpleString(io.netty.buffer.ByteBuf buffer,
SimpleString.ByteBufSimpleStringPool pool) |
SimpleString |
ActiveMQBuffer.readSimpleString()
Gets a non-null SimpleString at the current
readerIndex |
static SimpleString |
SimpleString.readSimpleString(io.netty.buffer.ByteBuf buffer) |
static SimpleString |
SimpleString.readSimpleString(io.netty.buffer.ByteBuf buffer,
int length) |
static SimpleString |
SimpleString.readSimpleString(io.netty.buffer.ByteBuf buffer,
SimpleString.ByteBufSimpleStringPool pool) |
SimpleString[] |
SimpleString.split(char delim)
Splits this SimpleString into an array of SimpleString using the char param as the delimiter.
|
SimpleString |
SimpleString.subSeq(int start,
int end) |
static SimpleString |
ParameterisedAddress.toParameterisedAddress(SimpleString address,
Map<String,String> parameters) |
static SimpleString |
SimpleString.toSimpleString(String string)
Returns a SimpleString constructed from the
string parameter. |
static SimpleString |
SimpleString.toSimpleString(String string,
SimpleString.StringSimpleStringPool pool) |
| 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) |
Object |
Message.getAnnotation(SimpleString key) |
default String |
Message.getAnnotationString(SimpleString key) |
Boolean |
Message.getBooleanProperty(SimpleString key) |
Byte |
Message.getByteProperty(SimpleString key) |
byte[] |
Message.getBytesProperty(SimpleString key) |
Double |
Message.getDoubleProperty(SimpleString key) |
default byte[] |
Message.getExtraBytesProperty(SimpleString key) |
Float |
Message.getFloatProperty(SimpleString key) |
Integer |
Message.getIntProperty(SimpleString key) |
Long |
Message.getLongProperty(SimpleString key) |
Object |
Message.getObjectProperty(SimpleString key) |
Short |
Message.getShortProperty(SimpleString key) |
SimpleString |
Message.getSimpleStringProperty(SimpleString key) |
String |
Message.getStringProperty(SimpleString key) |
protected boolean |
SimpleString.ByteBufSimpleStringPool.isEqual(SimpleString entry,
io.netty.buffer.ByteBuf byteBuf,
int offset,
int length) |
protected boolean |
SimpleString.StringSimpleStringPool.isEqual(SimpleString entry,
String value) |
static boolean |
ParameterisedAddress.isParameterised(SimpleString address) |
Message |
Message.putBooleanProperty(SimpleString key,
boolean value) |
Message |
Message.putByteProperty(SimpleString key,
byte value) |
Message |
Message.putBytesProperty(SimpleString key,
byte[] value) |
Message |
Message.putCharProperty(SimpleString key,
char value) |
Message |
Message.putDoubleProperty(SimpleString key,
double value) |
default Message |
Message.putExtraBytesProperty(SimpleString key,
byte[] value) |
Message |
Message.putFloatProperty(SimpleString key,
float value) |
Message |
Message.putIntProperty(SimpleString key,
int value) |
Message |
Message.putLongProperty(SimpleString key,
long value) |
Message |
Message.putObjectProperty(SimpleString key,
Object value) |
Message |
Message.putShortProperty(SimpleString key,
short value) |
Message |
Message.putStringProperty(SimpleString key,
SimpleString value) |
Message |
Message.putStringProperty(SimpleString key,
String value) |
default Object |
Message.removeAnnotation(SimpleString key) |
default byte[] |
Message.removeExtraBytesProperty(SimpleString key) |
Object |
Message.removeProperty(SimpleString key) |
Message |
Message.setAddress(SimpleString address)
This will set the address on CoreMessage.
|
default Message |
Message.setAnnotation(SimpleString key,
Object value)
Callers must call
Message.reencode() in order to be sent to clients |
default Message |
Message.setLastValueProperty(SimpleString lastValueName) |
Message |
Message.setReplyTo(SimpleString address) |
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.
|
static SimpleString |
ParameterisedAddress.toParameterisedAddress(SimpleString address,
Map<String,String> parameters) |
static void |
SimpleString.writeNullableSimpleString(io.netty.buffer.ByteBuf buffer,
SimpleString val) |
void |
ActiveMQBuffer.writeNullableSimpleString(SimpleString val)
Sets the specified SimpleString (potentially
null) at the current writerIndex |
static void |
SimpleString.writeSimpleString(io.netty.buffer.ByteBuf buffer,
SimpleString val) |
void |
ActiveMQBuffer.writeSimpleString(SimpleString val)
Sets the specified non-null SimpleString at the current
writerIndex |
| Constructor and Description |
|---|
ParameterisedAddress(SimpleString address) |
ParameterisedAddress(SimpleString address,
QueueAttributes queueAttributes) |
| 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). |
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.
|
void |
ClientSession.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated)
Create Address with a single initial routing type
|
void |
ClientSession.createAddress(SimpleString address,
RoutingType routingType,
boolean autoCreated)
Create Address with a single initial routing type
|
void |
ClientSession.createAddress(SimpleString address,
Set<RoutingType> routingTypes,
boolean autoCreated)
Deprecated.
|
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,
RoutingType routingType,
SimpleString queueName)
Creates a non-temporary queue non-durable queue.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean autoCreated)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName)
Deprecated.
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName,
boolean durable)
Deprecated.
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable)
Deprecated.
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean autoCreated)
Deprecated.
|
void |
ClientSession.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Creates a transient queue.
|
void |
ClientSession.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a transient queue.
|
void |
ClientSession.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Creates Shared queue.
|
void |
ClientSession.createSharedQueue(SimpleString address,
SimpleString queueName,
boolean durable)
Deprecated.
|
void |
ClientSession.createSharedQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable)
Deprecated.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName)
Creates a temporary queue.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter)
Creates a temporary queue with a filter.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Creates a temporary queue with a filter.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
SimpleString queueName)
Deprecated.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
SimpleString queueName,
SimpleString filter)
Deprecated.
|
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 |
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,
RoutingType routingType)
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 |
ChannelBufferWrapper.writeNullableSimpleString(SimpleString val) |
void |
ResetLimitWrappedActiveMQBuffer.writeNullableSimpleString(SimpleString val) |
void |
ChannelBufferWrapper.writeSimpleString(SimpleString val) |
void |
ResetLimitWrappedActiveMQBuffer.writeSimpleString(SimpleString val) |
| Modifier and Type | Field and Description |
|---|---|
protected SimpleString |
AbstractProducerCreditsImpl.address |
static SimpleString |
ClientConsumerImpl.FORCED_DELIVERY_MESSAGE |
static SimpleString |
ClientMessageImpl.REPLYTO_HEADER_NAME |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
QueueQueryImpl.getAddress() |
SimpleString |
ClientProducerImpl.getAddress() |
SimpleString |
ClientProducerCredits.getAddress() |
SimpleString |
AbstractProducerCreditsImpl.getAddress() |
SimpleString |
QueueQueryImpl.getFilterString() |
SimpleString |
ClientConsumerInternal.getFilterString() |
SimpleString |
ClientConsumerImpl.getFilterString() |
SimpleString |
QueueQueryImpl.getName() |
SimpleString |
ClientConsumerInternal.getQueueName() |
SimpleString |
ClientConsumerImpl.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.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
void |
ClientSessionImpl.createAddress(SimpleString address,
RoutingType routingType,
boolean autoCreated) |
void |
ClientSessionImpl.createAddress(SimpleString address,
Set<RoutingType> routingTypes,
boolean autoCreated) |
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,
RoutingType routingType,
SimpleString queueName)
Creates a non-temporary queue non-durable queue.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean autoCreated)
New Queue API
|
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers) |
void |
ClientSessionImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
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.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean autoCreated) |
void |
ClientSessionImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
boolean durable)
Creates a transient queue.
|
void |
ClientSessionImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a transient queue.
|
void |
ClientSessionImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Creates Shared queue.
|
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,
RoutingType routingType,
SimpleString queueName) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
SimpleString queueName) |
void |
ClientSessionImpl.createTemporaryQueue(SimpleString address,
SimpleString queueName,
SimpleString filter) |
void |
ClientSessionImpl.deleteQueue(SimpleString queueName) |
ClientProducerCredits |
ClientSessionInternal.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientSessionImpl.getCredits(SimpleString address,
boolean anon) |
ClientProducerCredits |
ClientProducerCreditManagerImpl.getCredits(SimpleString address,
boolean anon,
SessionContext context) |
ClientProducerCredits |
ClientProducerCreditManager.getCredits(SimpleString address,
boolean anon,
SessionContext context) |
void |
ClientSessionInternal.handleReceiveProducerCredits(SimpleString address,
int credits) |
void |
ClientSessionImpl.handleReceiveProducerCredits(SimpleString address,
int credits) |
void |
ClientSessionInternal.handleReceiveProducerFailCredits(SimpleString address,
int credits) |
void |
ClientSessionImpl.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) |
ClientMessageImpl |
ClientMessageImpl.putStringProperty(SimpleString key,
String 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 |
ClientSessionInternal.returnCredits(SimpleString address) |
void |
ClientSessionImpl.returnCredits(SimpleString address) |
void |
ClientProducerCreditManagerImpl.returnCredits(SimpleString address) |
void |
ClientProducerCreditManager.returnCredits(SimpleString address) |
void |
ClientProducerImpl.send(SimpleString address1,
Message msg) |
void |
ClientProducerImpl.send(SimpleString address1,
Message message,
SendAcknowledgementHandler handler) |
void |
ClientSessionInternal.sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
ClientSessionImpl.sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
ClientSessionInternal.setAddress(Message message,
SimpleString address)
This will set the address at the message
|
void |
ClientSessionImpl.setAddress(Message message,
SimpleString address) |
void |
LargeMessageControllerImpl.writeNullableSimpleString(SimpleString val) |
void |
LargeMessageControllerImpl.writeSimpleString(SimpleString val) |
| Constructor and Description |
|---|
AbstractProducerCreditsImpl(ClientSessionInternal session,
SimpleString address,
int windowSize) |
AsynchronousProducerCreditsImpl(ClientSessionInternal session,
SimpleString address,
int windowSize,
ClientProducerFlowCallback callback) |
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 autoCreateQueues) |
QueueQueryImpl(boolean durable,
boolean temporary,
int consumerCount,
long messageCount,
SimpleString filterString,
SimpleString address,
SimpleString name,
boolean exists,
boolean autoCreateQueues,
int maxConsumers,
boolean autoCreated,
boolean purgeOnNoConsumers,
RoutingType routingType) |
QueueQueryImpl(boolean durable,
boolean temporary,
int consumerCount,
long messageCount,
SimpleString filterString,
SimpleString address,
SimpleString name,
boolean exists,
boolean autoCreateQueues,
int maxConsumers,
boolean autoCreated,
boolean purgeOnNoConsumers,
RoutingType routingType,
Boolean exclusive,
Boolean lastValue) |
| Constructor and Description |
|---|
AddressQueryImpl(boolean exists,
List<SimpleString> queueNames,
boolean autoCreateQueues,
boolean autoCreateAddresses,
boolean defaultPurgeOnNoConsumers,
int defaultMaxConsumers,
Boolean defaultExclusive,
Boolean defaultLastValue) |
| 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) |
| Modifier and Type | Field and Description |
|---|---|
protected SimpleString |
CoreMessage.address |
| Modifier and Type | Method and Description |
|---|---|
static SimpleString |
CoreMessageObjectPools.cachedAddressSimpleString(String address,
CoreMessageObjectPools coreMessageObjectPools) |
SimpleString |
MessageInternalImpl.getAddressSimpleString()
Deprecated.
|
SimpleString |
CoreMessage.getAddressSimpleString() |
SimpleString |
CoreMessage.getGroupID() |
SimpleString |
CoreMessage.getLastValueProperty() |
SimpleString |
MessageInternalImpl.getReplyTo()
Deprecated.
|
SimpleString |
CoreMessage.getReplyTo() |
SimpleString |
MessageInternalImpl.getSimpleStringProperty(SimpleString key)
Deprecated.
|
SimpleString |
CoreMessage.getSimpleStringProperty(SimpleString key) |
SimpleString |
MessageInternalImpl.getSimpleStringProperty(String key)
Deprecated.
|
SimpleString |
CoreMessage.getSimpleStringProperty(String key) |
| Modifier and Type | Method and Description |
|---|---|
Set<SimpleString> |
MessageInternalImpl.getPropertyNames()
Deprecated.
Returns all the names of the properties for this message.
|
Set<SimpleString> |
CoreMessage.getPropertyNames() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
MessageInternalImpl.containsProperty(SimpleString key)
Deprecated.
|
boolean |
CoreMessage.containsProperty(SimpleString key) |
Object |
MessageInternalImpl.getAnnotation(SimpleString key)
Deprecated.
|
Object |
CoreMessage.getAnnotation(SimpleString key)
On core there's no delivery annotation
|
Boolean |
MessageInternalImpl.getBooleanProperty(SimpleString key)
Deprecated.
|
Boolean |
CoreMessage.getBooleanProperty(SimpleString key) |
Byte |
MessageInternalImpl.getByteProperty(SimpleString key)
Deprecated.
|
Byte |
CoreMessage.getByteProperty(SimpleString key) |
byte[] |
MessageInternalImpl.getBytesProperty(SimpleString key)
Deprecated.
|
byte[] |
CoreMessage.getBytesProperty(SimpleString key) |
Double |
MessageInternalImpl.getDoubleProperty(SimpleString key)
Deprecated.
|
Double |
CoreMessage.getDoubleProperty(SimpleString key) |
Float |
MessageInternalImpl.getFloatProperty(SimpleString key)
Deprecated.
|
Float |
CoreMessage.getFloatProperty(SimpleString key) |
Integer |
MessageInternalImpl.getIntProperty(SimpleString key)
Deprecated.
|
Integer |
CoreMessage.getIntProperty(SimpleString key) |
Long |
MessageInternalImpl.getLongProperty(SimpleString key)
Deprecated.
|
Long |
CoreMessage.getLongProperty(SimpleString key) |
Object |
MessageInternalImpl.getObjectProperty(SimpleString key)
Deprecated.
|
Object |
CoreMessage.getObjectProperty(SimpleString key) |
Short |
MessageInternalImpl.getShortProperty(SimpleString key)
Deprecated.
|
Short |
CoreMessage.getShortProperty(SimpleString key) |
SimpleString |
MessageInternalImpl.getSimpleStringProperty(SimpleString key)
Deprecated.
|
SimpleString |
CoreMessage.getSimpleStringProperty(SimpleString key) |
String |
MessageInternalImpl.getStringProperty(SimpleString key)
Deprecated.
|
String |
CoreMessage.getStringProperty(SimpleString key) |
Message |
MessageInternalImpl.putBooleanProperty(SimpleString key,
boolean value)
Deprecated.
|
CoreMessage |
CoreMessage.putBooleanProperty(SimpleString key,
boolean value) |
Message |
MessageInternalImpl.putByteProperty(SimpleString key,
byte value)
Deprecated.
|
CoreMessage |
CoreMessage.putByteProperty(SimpleString key,
byte value) |
Message |
MessageInternalImpl.putBytesProperty(SimpleString key,
byte[] value)
Deprecated.
|
CoreMessage |
CoreMessage.putBytesProperty(SimpleString key,
byte[] value) |
Message |
MessageInternalImpl.putCharProperty(SimpleString key,
char value)
Deprecated.
|
CoreMessage |
CoreMessage.putCharProperty(SimpleString key,
char value) |
Message |
MessageInternalImpl.putDoubleProperty(SimpleString key,
double value)
Deprecated.
|
CoreMessage |
CoreMessage.putDoubleProperty(SimpleString key,
double value) |
Message |
MessageInternalImpl.putFloatProperty(SimpleString key,
float value)
Deprecated.
|
CoreMessage |
CoreMessage.putFloatProperty(SimpleString key,
float value) |
Message |
MessageInternalImpl.putIntProperty(SimpleString key,
int value)
Deprecated.
|
CoreMessage |
CoreMessage.putIntProperty(SimpleString key,
int value) |
Message |
MessageInternalImpl.putLongProperty(SimpleString key,
long value)
Deprecated.
|
CoreMessage |
CoreMessage.putLongProperty(SimpleString key,
long value) |
Message |
MessageInternalImpl.putObjectProperty(SimpleString key,
Object value)
Deprecated.
|
CoreMessage |
CoreMessage.putObjectProperty(SimpleString key,
Object value) |
Message |
MessageInternalImpl.putShortProperty(SimpleString key,
short value)
Deprecated.
|
CoreMessage |
CoreMessage.putShortProperty(SimpleString key,
short value) |
Message |
MessageInternalImpl.putStringProperty(SimpleString key,
SimpleString value)
Deprecated.
|
CoreMessage |
CoreMessage.putStringProperty(SimpleString key,
SimpleString value) |
Message |
MessageInternalImpl.putStringProperty(SimpleString key,
String value)
Deprecated.
|
CoreMessage |
CoreMessage.putStringProperty(SimpleString key,
String value) |
Object |
CoreMessage.removeAnnotation(SimpleString key)
On core there's no delivery annotation
|
Object |
MessageInternalImpl.removeProperty(SimpleString key)
Deprecated.
|
Object |
CoreMessage.removeProperty(SimpleString key) |
Message |
MessageInternalImpl.setAddress(SimpleString address)
Deprecated.
|
CoreMessage |
CoreMessage.setAddress(SimpleString address) |
void |
MessageInternalImpl.setAddressTransient(SimpleString address)
Deprecated.
|
void |
MessageInternal.setAddressTransient(SimpleString address)
Deprecated.
|
Message |
CoreMessage.setLastValueProperty(SimpleString lastValueName) |
Message |
MessageInternalImpl.setReplyTo(SimpleString address)
Deprecated.
|
CoreMessage |
CoreMessage.setReplyTo(SimpleString address) |
| 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) |
SequentialFileFactory |
PagingStoreFactoryDatabase.newFileFactory(SimpleString address) |
PagingStore |
PagingStoreFactoryNIO.newStore(SimpleString address,
AddressSettings settings) |
PagingStore |
PagingStoreFactoryDatabase.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,
ArtemisExecutor executor,
boolean syncNonTransactional) |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
QueueBindingInfo.getAddress() |
SimpleString |
GroupingInfo.getClusterName() |
SimpleString |
QueueBindingInfo.getFilterString() |
SimpleString |
GroupingInfo.getGroupId() |
SimpleString |
AddressBindingInfo.getName() |
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 |
PersistentQueueBindingEncoding.address |
SimpleString |
DuplicateIDEncoding.address |
SimpleString |
GroupingEncoding.clusterName |
SimpleString |
PersistentQueueBindingEncoding.filterString |
SimpleString |
GroupingEncoding.groupId |
SimpleString |
PersistentQueueBindingEncoding.name |
SimpleString |
PersistentAddressBindingEncoding.name |
SimpleString |
PersistentQueueBindingEncoding.user |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
PersistentQueueBindingEncoding.getAddress() |
SimpleString |
GroupingEncoding.getClusterName() |
SimpleString |
PersistentQueueBindingEncoding.getFilterString() |
SimpleString |
GroupingEncoding.getGroupId() |
SimpleString |
PersistentAddressBindingEncoding.getName() |
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) |
PersistentAddressBindingEncoding(SimpleString name,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
PersistentQueueBindingEncoding(SimpleString name,
SimpleString address,
SimpleString filterString,
SimpleString user,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue,
byte routingType) |
| 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 |
Binding.getAddress() |
SimpleString |
Address.getAddress() |
SimpleString[] |
Address.getAddressParts() |
SimpleString |
QueueInfo.getClusterName() |
SimpleString |
Binding.getClusterName() |
SimpleString |
QueueInfo.getFilterString() |
SimpleString |
PostOffice.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
AddressManager.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
PostOffice.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
AddressManager.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
QueueInfo.getRoutingName() |
SimpleString |
Binding.getRoutingName() |
SimpleString |
Binding.getUniqueName() |
| Modifier and Type | Method and Description |
|---|---|
Set<SimpleString> |
PostOffice.getAddresses() |
Set<SimpleString> |
AddressManager.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) |
AddressInfo |
PostOffice.getAddressInfo(SimpleString address) |
AddressInfo |
AddressManager.getAddressInfo(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) |
Bindings |
PostOffice.getDirectBindings(SimpleString address) |
Bindings |
AddressManager.getDirectBindings(SimpleString address) |
DuplicateIDCache |
PostOffice.getDuplicateIDCache(SimpleString address) |
Bindings |
PostOffice.getMatchingBindings(SimpleString address) |
Bindings |
AddressManager.getMatchingBindings(SimpleString address) |
SimpleString |
PostOffice.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
AddressManager.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
PostOffice.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
AddressManager.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
boolean |
PostOffice.isAddressBound(SimpleString address) |
List<Queue> |
PostOffice.listQueuesForAddress(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) |
AddressInfo |
PostOffice.removeAddressInfo(SimpleString address) |
AddressInfo |
AddressManager.removeAddressInfo(SimpleString address) |
AddressInfo |
PostOffice.removeAddressInfo(SimpleString address,
boolean force) |
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) |
AddressInfo |
PostOffice.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes) |
AddressInfo |
AddressManager.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes)
it will return null if there are no updates.
|
void |
PostOffice.updateMessageLoadBalancingTypeForAddress(SimpleString address,
MessageLoadBalancingType messageLoadBalancingType) |
void |
AddressManager.updateMessageLoadBalancingTypeForAddress(SimpleString address,
MessageLoadBalancingType messageLoadBalancingType) |
QueueBinding |
PostOffice.updateQueue(SimpleString name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive) |
| 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 | Field and Description |
|---|---|
protected ConcurrentMap<SimpleString,Bindings> |
SimpleAddressManager.mappings
HashMap
|
| 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 |
SimpleAddressManager.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
PostOfficeImpl.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
SimpleAddressManager.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
PostOfficeImpl.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
LocalQueueBinding.getRoutingName() |
SimpleString |
DivertBinding.getRoutingName() |
SimpleString |
LocalQueueBinding.getUniqueName() |
SimpleString |
DivertBinding.getUniqueName() |
| Modifier and Type | Method and Description |
|---|---|
Set<SimpleString> |
SimpleAddressManager.getAddresses() |
Set<SimpleString> |
PostOfficeImpl.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) |
AddressInfo |
SimpleAddressManager.getAddressInfo(SimpleString addressName) |
AddressInfo |
PostOfficeImpl.getAddressInfo(SimpleString addressName) |
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) |
Bindings |
SimpleAddressManager.getDirectBindings(SimpleString address) |
Bindings |
PostOfficeImpl.getDirectBindings(SimpleString address) |
DuplicateIDCache |
PostOfficeImpl.getDuplicateIDCache(SimpleString address) |
Bindings |
SimpleAddressManager.getMatchingBindings(SimpleString address) |
Bindings |
PostOfficeImpl.getMatchingBindings(SimpleString address) |
SimpleString |
SimpleAddressManager.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
PostOfficeImpl.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
SimpleAddressManager.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
PostOfficeImpl.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
boolean |
PostOfficeImpl.isAddressBound(SimpleString address) |
List<Queue> |
PostOfficeImpl.listQueuesForAddress(SimpleString address) |
Bindings |
PostOfficeImpl.lookupBindingsForAddress(SimpleString address) |
AddressInfo |
WildcardAddressManager.removeAddressInfo(SimpleString address) |
AddressInfo |
SimpleAddressManager.removeAddressInfo(SimpleString address) |
AddressInfo |
PostOfficeImpl.removeAddressInfo(SimpleString address) |
AddressInfo |
PostOfficeImpl.removeAddressInfo(SimpleString address,
boolean force) |
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) |
AddressInfo |
SimpleAddressManager.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes) |
AddressInfo |
PostOfficeImpl.updateAddressInfo(SimpleString addressName,
EnumSet<RoutingType> routingTypes) |
void |
WildcardAddressManager.updateMessageLoadBalancingTypeForAddress(SimpleString address,
MessageLoadBalancingType messageLoadBalancingType) |
void |
SimpleAddressManager.updateMessageLoadBalancingTypeForAddress(SimpleString address,
MessageLoadBalancingType messageLoadBalancingType) |
void |
PostOfficeImpl.updateMessageLoadBalancingTypeForAddress(SimpleString address,
MessageLoadBalancingType messageLoadBalancingType) |
QueueBinding |
PostOfficeImpl.updateQueue(SimpleString name,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive) |
| Constructor and Description |
|---|
AddressImpl(SimpleString address) |
AddressImpl(SimpleString address,
WildcardConfiguration wildcardConfiguration) |
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 | Field and Description |
|---|---|
static SimpleString |
PacketImpl.OLD_QUEUE_PREFIX |
static SimpleString |
PacketImpl.OLD_TEMP_QUEUE_PREFIX |
static SimpleString |
PacketImpl.OLD_TEMP_TOPIC_PREFIX |
static SimpleString |
PacketImpl.OLD_TOPIC_PREFIX |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
PacketImpl.convertName(SimpleString name) |
| Modifier and Type | Method and Description |
|---|---|
Map<SimpleString,RoutingType> |
CoreProtocolManager.getPrefixes() |
| Modifier and Type | Method and Description |
|---|---|
ClientSession.AddressQuery |
ActiveMQSessionContext.addressQuery(SimpleString address) |
SimpleString |
PacketImpl.convertName(SimpleString name) |
void |
ActiveMQSessionContext.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
void |
ActiveMQSessionContext.createAddress(SimpleString address,
Set<RoutingType> routingTypes,
boolean autoCreated) |
ClientConsumerInternal |
ActiveMQSessionContext.createConsumer(SimpleString queueName,
SimpleString filterString,
int windowSize,
int maxRate,
int ackBatchSize,
boolean browseOnly,
Executor executor,
Executor flowControlExecutor) |
void |
ActiveMQSessionContext.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temp,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated)
Deprecated.
|
void |
ActiveMQSessionContext.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temp,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated,
Boolean exclusive,
Boolean lastValue) |
void |
ActiveMQSessionContext.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temp,
boolean autoCreated)
Deprecated.
|
void |
ActiveMQSessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable) |
void |
ActiveMQSessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
void |
ActiveMQSessionContext.createSharedQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable) |
void |
ActiveMQSessionContext.deleteQueue(SimpleString queueName) |
void |
CoreSessionCallback.disconnect(ServerConsumer consumerId,
SimpleString queueName) |
void |
RemotingConnectionImpl.killMessage(SimpleString nodeID) |
void |
ActiveMQSessionContext.linkFlowControl(SimpleString address,
ClientProducerCredits clientProducerCredits) |
ClientSession.QueueQuery |
ActiveMQSessionContext.queueQuery(SimpleString queueName) |
void |
ActiveMQSessionContext.sendFullMessage(ICoreMessage 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 |
QueueAbstractPacket.address |
protected SimpleString |
CreateSharedQueueMessage.address |
protected SimpleString |
CreateQueueMessage.address |
protected SimpleString |
SessionQueueQueryResponseMessage.filterString |
protected SimpleString |
CreateSharedQueueMessage.filterString |
protected SimpleString |
CreateQueueMessage.filterString |
protected SimpleString |
SessionQueueQueryResponseMessage.name |
protected SimpleString |
DisconnectMessage.nodeID |
protected SimpleString |
QueueAbstractPacket.queueName |
protected SimpleString |
CreateSharedQueueMessage.queueName |
protected SimpleString |
CreateQueueMessage.queueName |
| Modifier and Type | Field and Description |
|---|---|
protected List<SimpleString> |
SessionBindingQueryResponseMessage.queueNames |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
SessionRequestProducerCreditsMessage.getAddress() |
SimpleString |
SessionQueueQueryResponseMessage.getAddress() |
SimpleString |
SessionProducerCreditsMessage.getAddress() |
SimpleString |
SessionProducerCreditsFailMessage.getAddress() |
SimpleString |
QueueAbstractPacket.getAddress() |
SimpleString |
CreateSharedQueueMessage.getAddress() |
SimpleString |
CreateQueueMessage.getAddress() |
SimpleString |
CreateAddressMessage.getAddress() |
SimpleString |
SessionQueueQueryResponseMessage.getFilterString() |
SimpleString |
SessionCreateConsumerMessage.getFilterString() |
SimpleString |
CreateSharedQueueMessage.getFilterString() |
SimpleString |
CreateQueueMessage.getFilterString() |
SimpleString |
QuorumVoteReplyMessage.getHandler() |
SimpleString |
QuorumVoteMessage.getHandler() |
SimpleString |
SessionQueueQueryResponseMessage.getName() |
SimpleString |
BackupRequestMessage.getNodeID() |
SimpleString |
DisconnectMessage.getNodeID() |
SimpleString |
DisconnectConsumerWithKillMessage.getNodeID() |
static SimpleString |
QueueAbstractPacket.getOldPrefixedAddress(SimpleString address,
RoutingType routingType) |
SimpleString |
ReplicationSyncFileMessage.getPageStore() |
SimpleString |
SessionDeleteQueueMessage.getQueueName() |
SimpleString |
QueueAbstractPacket.getQueueName() |
SimpleString |
CreateSharedQueueMessage.getQueueName() |
SimpleString |
CreateQueueMessage.getQueueName() |
SimpleString |
ScaleDownAnnounceMessage.getScaledDownNodeId() |
SimpleString |
DisconnectMessage_V2.getScaleDownNodeID() |
SimpleString |
ReplicationPageEventMessage.getStoreName() |
SimpleString |
ScaleDownAnnounceMessage.getTargetNodeId() |
| Modifier and Type | Method and Description |
|---|---|
List<SimpleString> |
QueueAbstractPacket.convertQueueNames(int clientVersion,
List<SimpleString> queueNames)
It converts the given
queueNames using the JMS prefix found on QueueAbstractPacket.address when clientVersion < PacketImpl.ADDRESSING_CHANGE_VERSION. |
List<SimpleString> |
SessionBindingQueryResponseMessage.getQueueNames() |
| Modifier and Type | Method and Description |
|---|---|
static SimpleString |
QueueAbstractPacket.getOldPrefixedAddress(SimpleString address,
RoutingType routingType) |
void |
CreateSharedQueueMessage.setAddress(SimpleString address) |
void |
CreateQueueMessage.setAddress(SimpleString address) |
void |
CreateAddressMessage.setAddress(SimpleString address) |
void |
SessionCreateConsumerMessage.setFilterString(SimpleString filterString) |
void |
CreateSharedQueueMessage.setFilterString(SimpleString filterString) |
void |
CreateQueueMessage.setFilterString(SimpleString filterString) |
void |
SessionCreateConsumerMessage.setQueueName(SimpleString queueName) |
void |
CreateSharedQueueMessage.setQueueName(SimpleString queueName) |
void |
CreateQueueMessage.setQueueName(SimpleString queueName) |
| Modifier and Type | Method and Description |
|---|---|
List<SimpleString> |
QueueAbstractPacket.convertQueueNames(int clientVersion,
List<SimpleString> queueNames)
It converts the given
queueNames using the JMS prefix found on QueueAbstractPacket.address when clientVersion < PacketImpl.ADDRESSING_CHANGE_VERSION. |
| Constructor and Description |
|---|
BackupRequestMessage(int backupSize,
SimpleString nodeID) |
CreateAddressMessage(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated,
boolean requiresResponse) |
CreateQueueMessage_V2(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
boolean temporary,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated,
boolean requiresResponse,
Boolean exclusive,
Boolean lastValue) |
CreateQueueMessage(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary,
boolean requiresResponse) |
CreateSharedQueueMessage_V2(SimpleString address,
SimpleString queueName,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean requiresResponse) |
CreateSharedQueueMessage(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean requiresResponse) |
DisconnectConsumerWithKillMessage(SimpleString nodeID) |
DisconnectMessage_V2(SimpleString nodeID,
String scaleDownNodeID) |
DisconnectMessage(SimpleString nodeID) |
QuorumVoteMessage(SimpleString handler,
Vote vote) |
QuorumVoteReplyMessage(SimpleString handler,
Vote vote) |
ReplicationPageEventMessage(SimpleString storeName,
int pageNumber,
boolean isDelete) |
ReplicationSyncFileMessage(AbstractJournalStorageManager.JournalContent content,
SimpleString storeName,
long id,
int size,
io.netty.buffer.ByteBuf buffer) |
ScaleDownAnnounceMessage(SimpleString targetNodeId,
SimpleString scaledDownNodeId) |
SessionBindingQueryMessage(SimpleString address) |
SessionCreateConsumerMessage(long id,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
boolean requiresResponse) |
SessionDeleteQueueMessage(SimpleString queueName) |
SessionProducerCreditsFailMessage(int credits,
SimpleString address) |
SessionProducerCreditsMessage(int credits,
SimpleString address) |
SessionQueueQueryMessage(SimpleString queueName) |
SessionRequestProducerCreditsMessage(int credits,
SimpleString address) |
| Constructor and Description |
|---|
SessionBindingQueryResponseMessage_V2(boolean exists,
List<SimpleString> queueNames,
boolean autoCreateQueues) |
SessionBindingQueryResponseMessage_V3(boolean exists,
List<SimpleString> queueNames,
boolean autoCreateQueues,
boolean autoCreateAddresses) |
SessionBindingQueryResponseMessage_V4(boolean exists,
List<SimpleString> queueNames,
boolean autoCreateQueues,
boolean autoCreateAddresses,
boolean defaultPurgeOnNoConsumers,
int defaultMaxConsumers,
Boolean defaultExclusive,
Boolean defaultLastValue) |
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) |
ClientSession.QueueQuery |
HornetQClientSessionContext.queueQuery(SimpleString queueName) |
| 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) |
void |
SecurityStore.check(SimpleString address,
SimpleString queue,
CheckType checkType,
SecurityAuth session) |
| Modifier and Type | Method and Description |
|---|---|
void |
SecurityStoreImpl.check(SimpleString address,
CheckType checkType,
SecurityAuth session) |
void |
SecurityStoreImpl.check(SimpleString address,
SimpleString queue,
CheckType checkType,
SecurityAuth session) |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
QueueConfig.address() |
SimpleString |
Queue.getAddress() |
SimpleString |
QueueQueryResult.getAddress() |
SimpleString |
RoutingContext.getAddress(Message message) |
SimpleString |
Queue.getExpiryAddress() |
SimpleString |
QueueQueryResult.getFilterString() |
SimpleString |
ServerSession.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
ServerSession.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
SimpleString |
Queue.getName() |
SimpleString |
QueueQueryResult.getName() |
SimpleString |
AddressQueryResult.getName() |
SimpleString |
NodeManager.getNodeId() |
SimpleString |
ActiveMQServer.getNodeID() |
SimpleString |
ServerSession.getPrefix(SimpleString address)
Get the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.
|
SimpleString |
ConsumerInfo.getQueueAddress() |
SimpleString |
TransientQueueManager.getQueueName() |
SimpleString |
QueueManager.getQueueName() |
SimpleString |
ConsumerInfo.getQueueName() |
SimpleString |
Divert.getRoutingName() |
SimpleString |
Divert.getUniqueName() |
SimpleString |
Queue.getUser() |
SimpleString |
QueueConfig.name() |
abstract SimpleString |
NodeManager.readNodeId() |
SimpleString |
ServerSession.removePrefix(SimpleString address)
Strip the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.
|
SimpleString |
QueueConfig.user() |
| Modifier and Type | Method and Description |
|---|---|
Pair<SimpleString,EnumSet<RoutingType>> |
ServerSession.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes)
Get the canonical (i.e.
|
Map<SimpleString,RouteContextList> |
RoutingContext.getContexListing() |
Map<SimpleString,Consumer> |
Queue.getGroups() |
List<SimpleString> |
BindingQueryResult.getQueueNames() |
| Modifier and Type | Method and Description |
|---|---|
void |
ActiveMQServerLogger.activatingReplica(SimpleString nodeID) |
void |
RoutingContext.addQueue(SimpleString address,
Queue queue) |
void |
RoutingContext.addQueueWithAck(SimpleString address,
Queue queue) |
ActiveMQAddressExistsException |
ActiveMQMessageBundle.addressAlreadyExists(SimpleString address) |
ActiveMQAddressDoesNotExistException |
ActiveMQMessageBundle.addressDoesNotExist(SimpleString address) |
ActiveMQDeleteAddressException |
ActiveMQMessageBundle.addressHasBindings(SimpleString address) |
AddressQueryResult |
ActiveMQServer.addressQuery(SimpleString name) |
void |
ActiveMQServerLogger.AddressSettingsNoDLA(SimpleString name) |
void |
ActiveMQServerLogger.AddressSettingsNoExpiryAddress(SimpleString name) |
void |
ActiveMQServer.addScaledDownNode(SimpleString scaledDownNodeId) |
void |
ActiveMQServerLogger.backupServerStarted(String version,
SimpleString nodeID) |
ActiveMQInternalErrorException |
ActiveMQMessageBundle.bindingNotDivert(SimpleString name) |
BindingQueryResult |
ActiveMQServer.bindingQuery(SimpleString address) |
void |
ActiveMQServerLogger.blockingDiskFull(SimpleString addressName) |
void |
ActiveMQServerLogger.blockingMessageProduction(SimpleString addressName,
long currentSize,
long maxSize,
long globalMaxSize) |
void |
ActiveMQServerLogger.bridgeAbortStart(SimpleString name,
Integer retryCount,
Integer reconnectAttempts) |
void |
ActiveMQServerLogger.bridgeNoBindings(SimpleString name,
SimpleString forwardingAddress,
SimpleString address) |
void |
ActiveMQServerLogger.bridgePaused(SimpleString name) |
void |
ActiveMQServerLogger.bridgeStopped(SimpleString name) |
static QueueConfig.Builder |
QueueConfig.builderWith(long id,
SimpleString name)
Returns a new
QueueConfig.Builder of a durable, not temporary and autoCreated QueueConfig with the given id and name. |
static QueueConfig.Builder |
QueueConfig.builderWith(long id,
SimpleString name,
SimpleString address)
Returns a new
QueueConfig.Builder of a durable, not temporary and autoCreated QueueConfig with the given id, name and address. |
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.cannotDeleteQueue(SimpleString name,
SimpleString queueName,
String s) |
ActiveMQIllegalStateException |
ActiveMQMessageBundle.consumerNoReference(Long id,
Long messageID,
SimpleString name) |
AddressInfo |
ServerSession.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
AddressInfo |
ServerSession.createAddress(SimpleString address,
RoutingType routingType,
boolean autoCreated) |
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 |
ServerSession.createQueue(AddressInfo address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
ServerSession.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
boolean autoCreated) |
Queue |
ServerSession.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
Boolean exclusive,
Boolean lastValue,
boolean autoCreated) |
Queue |
ActiveMQServer.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServer.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean autoCreateAddress) |
Queue |
QueueFactory.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated)
Deprecated.
|
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString user,
SimpleString filterString,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue,
boolean autoCreateAddress) |
Queue |
ActiveMQServer.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ServerSession.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
ServerSession.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
boolean autoCreated) |
Queue |
ServerSession.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated) |
Queue |
ServerSession.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean autoCreated) |
Queue |
ServerSession.createQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable)
Create queue with default delivery mode
|
Queue |
ActiveMQServer.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary)
Deprecated.
|
void |
ActiveMQServer.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable)
Creates a transient queue.
|
void |
ActiveMQServer.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue) |
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
boolean durable,
SimpleString filterString) |
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
boolean durable,
SimpleString filterString) |
void |
ServerSession.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
void |
ServerSession.deleteQueue(SimpleString name) |
Queue |
ActiveMQServer.deployQueue(SimpleString address,
SimpleString queue,
SimpleString filter,
boolean durable,
boolean temporary)
Deprecated.
|
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 |
ActiveMQServer.destroyQueue(SimpleString queueName,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress) |
void |
ActiveMQServerLogger.divertBindingAlreadyExists(SimpleString bindingName) |
RoutingStatus |
ServerSession.doSend(Transaction tx,
Message msg,
SimpleString originalAddress,
boolean direct,
boolean noAutoCreateQueue) |
void |
ActiveMQServerLogger.errorExpiringReferencesNoBindings(SimpleString expiryAddress) |
void |
ActiveMQServerLogger.errorExpiringReferencesNoQueue(SimpleString name) |
void |
ActiveMQServerLogger.errorQueryingBridge(SimpleString address,
Integer retryCount) |
void |
ActiveMQServerLogger.errorQueryingBridge(Throwable t,
SimpleString name) |
void |
ActiveMQServerLogger.errorRemovingAutoCreatedQueue(Exception e,
SimpleString bindingName) |
void |
ActiveMQServerLogger.errorRemovingTempQueue(Exception e,
SimpleString bindingName) |
void |
ActiveMQServerLogger.errorStartingBridge(SimpleString name) |
AddressQueryResult |
ServerSession.executeAddressQuery(SimpleString name) |
BindingQueryResult |
ServerSession.executeBindingQuery(SimpleString address) |
QueueQueryResult |
ServerSession.executeQueueQuery(SimpleString name) |
void |
ActiveMQServerLogger.failedToPurgeQueue(Exception e,
SimpleString bindingName) |
void |
ServerMessage.forceAddress(SimpleString address)
Deprecated.
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
|
AddressInfo |
ServerSession.getAddress(SimpleString address) |
Pair<SimpleString,EnumSet<RoutingType>> |
ServerSession.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes)
Get the canonical (i.e.
|
AddressInfo |
ActiveMQServer.getAddressInfo(SimpleString address) |
RouteContextList |
RoutingContext.getContextListing(SimpleString address) |
List<Queue> |
RoutingContext.getDurableQueues(SimpleString address) |
SimpleString |
ServerSession.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
ServerSession.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
List<Queue> |
RoutingContext.getNonDurableQueues(SimpleString address) |
SimpleString |
ServerSession.getPrefix(SimpleString address)
Get the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.
|
void |
ActiveMQServerLogger.groupingQueueRemoved(int size,
SimpleString clusterName) |
boolean |
ActiveMQServer.hasScaledDown(SimpleString scaledDownNodeId) |
void |
ActiveMQServerLogger.initiatingQuorumVote(SimpleString vote) |
void |
ActiveMQServerLogger.invalidFilter(SimpleString filter) |
ActiveMQInvalidFilterExpressionException |
ActiveMQMessageBundle.invalidFilter(Throwable e,
SimpleString filter) |
ActiveMQInvalidQueueConfiguration |
ActiveMQMessageBundle.invalidQueueConfiguration(SimpleString address,
SimpleString queueName,
String queuePropertyName,
Object expectedValue,
Object actualValue) |
boolean |
RoutingContext.isAlreadyAcked(SimpleString address,
Queue queue) |
Queue |
ActiveMQServer.locateQueue(SimpleString queueName) |
ActiveMQQueueMaxConsumerLimitReached |
ActiveMQMessageBundle.maxConsumerLimitReachedForQueue(SimpleString address,
SimpleString queueName) |
void |
ActiveMQServerLogger.messageExceededMaxDelivery(MessageReference ref,
SimpleString name) |
void |
ActiveMQServerLogger.messageExceededMaxDeliveryNoDLA(MessageReference ref,
SimpleString name) |
void |
ActiveMQServerLogger.messageExceededMaxDeliverySendtoDLA(MessageReference ref,
SimpleString name,
SimpleString simpleString) |
void |
ActiveMQServerLogger.messageWithDuplicateID(Object duplicateProperty,
SimpleString toAddress,
SimpleString address,
SimpleString simpleString) |
boolean |
Queue.moveReference(long messageID,
SimpleString toAddress,
Binding binding,
boolean rejectDuplicates) |
int |
Queue.moveReferences(Filter filter,
SimpleString toAddress,
Binding binding) |
int |
Queue.moveReferences(int flushLimit,
Filter filter,
SimpleString toAddress,
boolean rejectDuplicates,
Binding binding) |
ActiveMQInternalErrorException |
ActiveMQMessageBundle.noBindingForDivert(SimpleString name) |
void |
ActiveMQServerLogger.noDLA(SimpleString address) |
void |
ActiveMQServerLogger.noQueueIdDefined(Message message,
Message messageCopy,
SimpleString idsHeaderName) |
ActiveMQNonExistentQueueException |
ActiveMQMessageBundle.noSuchQueue(SimpleString queueName) |
void |
ActiveMQServerLogger.pageStoreDropMessages(SimpleString storeName,
long addressSize,
long maxSize,
long globalMaxSize) |
void |
ActiveMQServerLogger.pageStoreStart(SimpleString storeName,
long addressSize,
long maxSize,
long globalMaxSize) |
void |
ActiveMQServerLogger.pageStoreTimeout(SimpleString address) |
void |
ActiveMQServerLogger.pageSubscriptionCouldntLoad(long transactionID,
PagePosition position,
SimpleString address,
SimpleString name) |
void |
ActiveMQServerLogger.problemCleaningPageAddress(Exception e,
SimpleString address) |
ActiveMQQueueExistsException |
ActiveMQMessageBundle.queueAlreadyExists(SimpleString queueName,
SimpleString addressName) |
QueueQueryResult |
ActiveMQServer.queueQuery(SimpleString name) |
ActiveMQInvalidTransientQueueUseException |
ActiveMQMessageBundle.queueSubscriptionBelongsToDifferentAddress(SimpleString queueName) |
ActiveMQInvalidTransientQueueUseException |
ActiveMQMessageBundle.queueSubscriptionBelongsToDifferentFilter(SimpleString queueName) |
void |
ActiveMQServerLogger.remoteQueueAlreadyBoundOnClusterConnection(Object messageFlowRecord,
SimpleString clusterName) |
void |
ActiveMQServer.removeAddressInfo(SimpleString address,
SecurityAuth auth)
Remove an
AddressInfo from the broker. |
void |
ActiveMQServer.removeAddressInfo(SimpleString address,
SecurityAuth auth,
boolean force)
Remove an
AddressInfo from the broker. |
SimpleString |
ServerSession.removePrefix(SimpleString address)
Strip the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.
|
void |
ServerSession.requestProducerCredits(SimpleString address,
int credits) |
void |
Queue.resetGroup(SimpleString groupID) |
void |
ActiveMQServerLogger.serverStarted(String fullVersion,
String name,
SimpleString nodeId,
String identity) |
void |
ActiveMQServerLogger.serverStopped(String version,
SimpleString nodeId,
String uptime) |
void |
RoutingContext.setAddress(SimpleString address) |
void |
QueueQueryResult.setAddress(SimpleString address) |
void |
TempQueueObserver.tempQueueDeleted(SimpleString bindingName) |
void |
ActiveMQServerLogger.unableToCreateManagementNotificationAddress(SimpleString addressName,
Exception e) |
void |
ActiveMQServerLogger.unableToDeleteGroupBindings(Exception e,
SimpleString groupId) |
void |
ActiveMQServerLogger.unableToStartBridge(Exception e,
SimpleString name) |
void |
ActiveMQServerLogger.unableToStartClusterConnection(Exception e,
SimpleString name) |
void |
ActiveMQServerLogger.unblockingMessageProduction(SimpleString addressName,
long currentSize,
long maxSize) |
void |
ActiveMQServerLogger.undeployAddress(SimpleString addressName) |
void |
ActiveMQServerLogger.undeployQueue(RoutingType routingType,
SimpleString queueName) |
ActiveMQUnexpectedRoutingTypeForAddress |
ActiveMQMessageBundle.unexpectedRoutingTypeForAddress(SimpleString address,
RoutingType expectedRoutingType,
Set<RoutingType> supportedRoutingTypes) |
void |
Queue.unproposed(SimpleString groupID) |
boolean |
ActiveMQServer.updateAddressInfo(SimpleString address,
Collection<RoutingType> routingTypes)
Deprecated.
|
boolean |
ActiveMQServer.updateAddressInfo(SimpleString address,
EnumSet<RoutingType> routingTypes)
Updates an
AddressInfo on the broker with the specified routing types. |
QueueConfig.Builder |
QueueConfig.Builder.user(SimpleString user) |
| Modifier and Type | Method and Description |
|---|---|
ServerSession |
ActiveMQServer.createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes) |
| Constructor and Description |
|---|
AddressQueryResult(SimpleString name,
Set<RoutingType> routingTypes,
long id,
boolean autoCreated,
boolean exists,
boolean autoCreateAddresses,
boolean defaultPurgeOnNoConsumers,
int defaultMaxConsumers) |
QueueQueryResult(SimpleString name,
SimpleString address,
boolean durable,
boolean temporary,
SimpleString filterString,
int consumerCount,
long messageCount,
boolean autoCreateQueues,
boolean exists,
boolean autoCreated,
boolean purgeOnNoConsumers,
RoutingType routingType,
int maxConsumers,
Boolean exclusive,
Boolean lastValue) |
| Constructor and Description |
|---|
BindingQueryResult(boolean exists,
AddressInfo addressInfo,
List<SimpleString> queueNames,
boolean autoCreateQueues,
boolean autoCreateAddresses,
boolean defaultPurgeOnNoConsumers,
int defaultMaxConsumers,
boolean defaultExclusive,
boolean defaultLastValue) |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
Bridge.getForwardingAddress() |
SimpleString |
ClusterConnection.getName() |
SimpleString |
Bridge.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) |
protected Message |
ClusterConnectionBridge.beforeForward(Message message,
SimpleString forwardingAddress) |
protected Message |
BridgeImpl.beforeForward(Message message,
SimpleString forwardingAddress) |
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,
ActiveMQServer server) |
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,
ActiveMQServer server,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector,
String storeAndForwardPrefix) |
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 | Field and Description |
|---|---|
static SimpleString |
QuorumVoteServerConnect.LIVE_FAILOVER_VOTE |
| Modifier and Type | Method and Description |
|---|---|
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 |
RemoteGroupingHandler.getName() |
SimpleString |
LocalGroupingHandler.getName() |
SimpleString |
GroupingHandlerConfiguration.getName() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
GroupHandlingAbstract.fireUnproposed(SimpleString groupID) |
void |
GroupHandlingAbstract.forceRemove(SimpleString groupid,
SimpleString clusterName) |
Response |
RemoteGroupingHandler.getProposal(SimpleString fullID,
boolean touchTime) |
Response |
LocalGroupingHandler.getProposal(SimpleString fullID,
boolean touchTime) |
void |
RemoteGroupingHandler.remove(SimpleString groupid,
SimpleString clusterName) |
void |
LocalGroupingHandler.remove(SimpleString groupid,
SimpleString clusterName) |
void |
RemoteGroupingHandler.remove(SimpleString groupid,
SimpleString clusterName,
int distance) |
void |
LocalGroupingHandler.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<Object,AtomicLong>> |
ServerSessionImpl.targetAddressInfos |
protected Map<SimpleString,ServerSessionImpl.TempQueueCleanerUpper> |
ServerSessionImpl.tempQueueCleannerUppers |
| Modifier and Type | Method and Description |
|---|---|
Pair<SimpleString,EnumSet<RoutingType>> |
ServerSessionImpl.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes) |
Map<SimpleString,RouteContextList> |
RoutingContextImpl.getContexListing() |
Map<SimpleString,Consumer> |
QueueImpl.getGroups() |
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) |
AddressQueryResult |
ActiveMQServerImpl.addressQuery(SimpleString name) |
void |
ActiveMQServerImpl.addScaledDownNode(SimpleString scaledDownNodeId) |
BindingQueryResult |
ActiveMQServerImpl.bindingQuery(SimpleString address) |
void |
ActiveMQServerImpl.callPostQueueCreationCallbacks(SimpleString queueName) |
void |
ActiveMQServerImpl.callPostQueueDeletionCallbacks(SimpleString address,
SimpleString queueName) |
AddressInfo |
AddressInfo.create(SimpleString name,
RoutingType routingType) |
AddressInfo |
ServerSessionImpl.createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
AddressInfo |
ServerSessionImpl.createAddress(SimpleString address,
RoutingType routingType,
boolean autoCreated) |
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 |
ServerSessionImpl.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
ServerSessionImpl.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
boolean autoCreated) |
Queue |
ServerSessionImpl.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
Boolean exclusive,
Boolean lastValue,
boolean autoCreated) |
Queue |
ServerSessionImpl.createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue,
boolean autoCreated) |
Queue |
ActiveMQServerImpl.createQueue(AddressInfo addrInfo,
SimpleString queueName,
SimpleString filterString,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(AddressInfo addressInfo,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean autoCreateAddress) |
Queue |
QueueFactoryImpl.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated)
Deprecated.
|
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
boolean durable,
boolean temporary,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString user,
SimpleString filterString,
boolean durable,
boolean temporary) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filterString,
SimpleString user,
boolean durable,
boolean temporary,
boolean ignoreIfExists,
boolean transientQueue,
boolean autoCreated,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue,
boolean autoCreateAddress) |
Queue |
ActiveMQServerImpl.createQueue(SimpleString address,
RoutingType routingType,
SimpleString queueName,
SimpleString filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
boolean autoCreateAddress)
Deprecated.
|
Queue |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable) |
Queue |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
boolean autoCreated) |
Queue |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated) |
Queue |
ServerSessionImpl.createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
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)
Deprecated.
|
void |
ActiveMQServerImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable) |
void |
ActiveMQServerImpl.createSharedQueue(SimpleString address,
RoutingType routingType,
SimpleString name,
SimpleString filterString,
SimpleString user,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean exclusive,
boolean lastValue) |
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
boolean durable,
SimpleString filterString) |
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
boolean durable,
SimpleString filterString) |
void |
ServerSessionImpl.createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue) |
void |
ServerSessionImpl.deleteQueue(SimpleString queueToDelete) |
Queue |
ActiveMQServerImpl.deployQueue(SimpleString address,
SimpleString resourceName,
SimpleString filterString,
boolean durable,
boolean temporary)
Deprecated.
|
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) |
void |
ActiveMQServerImpl.destroyQueue(SimpleString queueName,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress) |
RoutingStatus |
ServerSessionImpl.doSend(Transaction tx,
Message msg,
SimpleString originalAddress,
boolean direct,
boolean noAutoCreateQueue) |
AddressQueryResult |
ServerSessionImpl.executeAddressQuery(SimpleString name) |
BindingQueryResult |
ServerSessionImpl.executeBindingQuery(SimpleString address) |
QueueQueryResult |
ServerSessionImpl.executeQueueQuery(SimpleString name) |
AddressInfo |
ServerSessionImpl.getAddress(SimpleString address) |
Pair<SimpleString,EnumSet<RoutingType>> |
ServerSessionImpl.getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes) |
AddressInfo |
ActiveMQServerImpl.getAddressInfo(SimpleString address) |
RouteContextList |
RoutingContextImpl.getContextListing(SimpleString address) |
List<Queue> |
RoutingContextImpl.getDurableQueues(SimpleString address) |
SimpleString |
ServerSessionImpl.getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
ServerSessionImpl.getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
List<Queue> |
RoutingContextImpl.getNonDurableQueues(SimpleString address) |
SimpleString |
ServerSessionImpl.getPrefix(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,
Binding binding,
boolean rejectDuplicate) |
int |
QueueImpl.moveReferences(Filter filter,
SimpleString toAddress,
Binding binding) |
int |
QueueImpl.moveReferences(int flushLimit,
Filter filter,
SimpleString toAddress,
boolean rejectDuplicates,
Binding binding) |
int |
QueueImpl.moveReferencesBetweenSnFQueues(SimpleString queueSuffix) |
QueueQueryResult |
ActiveMQServerImpl.queueQuery(SimpleString name) |
void |
ActiveMQServerImpl.removeAddressInfo(SimpleString address,
SecurityAuth auth) |
void |
ActiveMQServerImpl.removeAddressInfo(SimpleString address,
SecurityAuth auth,
boolean force) |
SimpleString |
ServerSessionImpl.removePrefix(SimpleString address) |
void |
ServerSessionImpl.requestProducerCredits(SimpleString address,
int credits) |
void |
QueueImpl.resetGroup(SimpleString groupId) |
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) |
void |
RoutingContextImpl.setAddress(SimpleString address) |
void |
QueueImpl.unproposed(SimpleString groupID) |
boolean |
ActiveMQServerImpl.updateAddressInfo(SimpleString address,
Collection<RoutingType> routingTypes) |
boolean |
ActiveMQServerImpl.updateAddressInfo(SimpleString address,
EnumSet<RoutingType> routingTypes) |
| Modifier and Type | Method and Description |
|---|---|
ServerSession |
ActiveMQServerImpl.createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes) |
AddressInfo |
AddressInfo.getAddressAndRoutingType(Map<SimpleString,RoutingType> prefixes) |
void |
PostOfficeJournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
void |
JournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
void |
BackupRecoveryJournalLoader.handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) |
protected ServerSessionImpl |
ActiveMQServerImpl.internalCreateSession(String name,
String username,
String password,
String validatedUser,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
OperationContext context,
boolean autoCreateJMSQueues,
Map<SimpleString,RoutingType> prefixes) |
void |
PostOfficeJournalLoader.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) |
void |
BackupRecoveryJournalLoader.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 |
|---|
AddressInfo(SimpleString name) |
AddressInfo(SimpleString name,
EnumSet<RoutingType> routingTypes)
Creates an AddressInfo object with a Set of routing types
|
AddressInfo(SimpleString name,
RoutingType routingType)
Creates an AddressInfo object with a single RoutingType associated with it.
|
DivertImpl(SimpleString forwardAddress,
SimpleString uniqueName,
SimpleString routingName,
boolean exclusive,
Filter filter,
Transformer transformer,
PostOffice postOffice,
StorageManager storageManager,
DivertConfigurationRoutingType routingType) |
LastValueQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean purgeOnNoConsumers,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean exclusive,
Boolean purgeOnNoConsumers,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
RoutingType routingType,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
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,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
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,
ArtemisExecutor executor,
ActiveMQServer server,
QueueFactory factory) |
QueueManagerImpl(ActiveMQServer server,
SimpleString queueName) |
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,
PagingManager pagingManager,
Map<SimpleString,RoutingType> prefixes) |
TempQueueCleanerUpper(ActiveMQServer server,
SimpleString bindingName) |
TransientQueueManagerImpl(ActiveMQServer server,
SimpleString queueName) |
| Constructor and Description |
|---|
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,
PagingManager pagingManager,
Map<SimpleString,RoutingType> prefixes) |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
JdbcNodeManager.readNodeId() |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
ManagementService.getManagementAddress() |
SimpleString |
ManagementService.getManagementNotificationAddress() |
| Modifier and Type | Method and Description |
|---|---|
void |
ManagementService.registerQueue(Queue queue,
SimpleString address,
StorageManager storageManager) |
void |
ManagementService.unregisterAddress(SimpleString address) |
void |
ManagementService.unregisterDivert(SimpleString name,
SimpleString address) |
void |
ManagementService.unregisterQueue(SimpleString name,
SimpleString address,
RoutingType routingType) |
| Modifier and Type | Method and Description |
|---|---|
SimpleString |
ManagementServiceImpl.getManagementAddress() |
SimpleString |
ManagementServiceImpl.getManagementNotificationAddress() |
| Modifier and Type | Method and Description |
|---|---|
void |
ManagementServiceImpl.registerQueue(Queue queue,
SimpleString address,
StorageManager storageManager) |
void |
ManagementServiceImpl.unregisterAddress(SimpleString address) |
void |
ManagementServiceImpl.unregisterDivert(SimpleString name,
SimpleString address) |
void |
ManagementServiceImpl.unregisterQueue(SimpleString name,
SimpleString address,
RoutingType routingType) |
| Modifier and Type | Method and Description |
|---|---|
default void |
ActiveMQServerPlugin.afterDestroyQueue(Queue queue,
SimpleString address,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress)
After a queue has been destroyed
|
default void |
ActiveMQServerPlugin.afterRemoveAddress(SimpleString address,
AddressInfo addressInfo)
After an address has been removed
|
default void |
ActiveMQServerPlugin.beforeCreateConsumer(long consumerID,
QueueBinding queueBinding,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage)
Before a consumer is created
|
default void |
ActiveMQServerPlugin.beforeCreateConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage)
Deprecated.
use {@link #beforeCreateConsumer(long, QueueBinding, SimpleString, boolean, boolean)
|
default void |
ActiveMQServerPlugin.beforeDestroyQueue(SimpleString queueName,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress)
Before a queue is destroyed
|
default void |
ActiveMQServerPlugin.beforeRemoveAddress(SimpleString address)
Before an address is removed
|
default void |
ActiveMQServerPlugin.beforeRemoveBinding(SimpleString uniqueName,
Transaction tx,
boolean deleteData)
Before a binding is removed
|
default void |
ActiveMQServerPlugin.beforeUpdateAddress(SimpleString address,
EnumSet<RoutingType> routingTypes)
Before an address is updated
|
default void |
ActiveMQServerPlugin.messageExpired(MessageReference message,
SimpleString messageExpiryAddress)
Deprecated.
use |