Uses of Class
org.apache.activemq.artemis.api.core.SimpleString
Package
Description
-
Uses of SimpleString in org.apache.activemq.artemis.api.config
Modifier and TypeFieldDescriptionstatic final SimpleString
ActiveMQDefaultConfiguration.DEFAULT_GROUP_FIRST_KEY
static final SimpleString
ActiveMQDefaultConfiguration.DEFAULT_LAST_VALUE_KEY
Modifier and TypeMethodDescriptionstatic SimpleString
ActiveMQDefaultConfiguration.getDefaultGroupFirstKey()
static SimpleString
ActiveMQDefaultConfiguration.getDefaultLastValueKey()
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 -
Uses of SimpleString in org.apache.activemq.artemis.api.core
Modifier and TypeFieldDescriptionstatic final SimpleString
FilterConstants.ACTIVEMQ_ADDRESS
Name of the ActiveMQ Artemis Address headerstatic final SimpleString
FilterConstants.ACTIVEMQ_DURABLE
Name of the ActiveMQ Artemis Message durable header.static final SimpleString
FilterConstants.ACTIVEMQ_EXPIRATION
Name of the ActiveMQ Artemis Message expiration header.static final SimpleString
FilterConstants.ACTIVEMQ_GROUP_ID
Name of the ActiveMQ Artemis Message group id header.static final SimpleString
FilterConstants.ACTIVEMQ_PREFIX
All ActiveMQ Artemis headers are prepended by this prefix.static final SimpleString
FilterConstants.ACTIVEMQ_PRIORITY
Name of the ActiveMQ Artemis Message priority header.static final SimpleString
FilterConstants.ACTIVEMQ_SIZE
Name of the ActiveMQ Artemis Message size header.static final SimpleString
FilterConstants.ACTIVEMQ_TIMESTAMP
Name of the ActiveMQ Artemis Message timestamp header.static final SimpleString
FilterConstants.ACTIVEMQ_USERID
Name of the ActiveMQ Artemis UserID header.static final SimpleString
FilterConstants.DURABLE
Value for the Durable header when the message is durable.static final SimpleString
Message.HDR_ACTUAL_EXPIRY_TIME
the actual time the message was expired.static final SimpleString
Message.HDR_BRIDGE_DUPLICATE_ID
static final SimpleString
Message.HDR_CONTENT_TYPE
To define the mime-type of body messages.static final SimpleString
Message.HDR_DUPLICATE_DETECTION_ID
To be used with duplicate detection.static final SimpleString
Message.HDR_GROUP_ID
For the Message Grouping feature.static final SimpleString
Message.HDR_GROUP_SEQUENCE
static final SimpleString
Message.HDR_INGRESS_TIMESTAMP
The time at which the message arrived at the broker.static final SimpleString
Message.HDR_LARGE_BODY_SIZE
The body size of a large message before it was compressed.static final SimpleString
Message.HDR_LARGE_COMPRESSED
to determine if the Large Message was compressed.static final SimpleString
Message.HDR_LAST_VALUE_NAME
To be used with Last value queues.static final SimpleString
Message.HDR_ORIG_MESSAGE_ID
The original message ID before the message was transferred.static final SimpleString
Message.HDR_ORIG_ROUTING_TYPE
The original routing type of a message before getting transferred through DLQ or expirystatic final SimpleString
Message.HDR_ORIGINAL_ADDRESS
The original address of a message when a message is diverted or transferred through DLQ or expirystatic final SimpleString
Message.HDR_ORIGINAL_QUEUE
The original address of a message when a message is transferred through DLQ or expirystatic final SimpleString
Message.HDR_PREFIX
The prefix used (if any) when sending this message.static final SimpleString
Message.HDR_ROUTE_TO_ACK_IDS
static final SimpleString
Message.HDR_ROUTE_TO_IDS
static final SimpleString
Message.HDR_ROUTING_TYPE
The Routing Type for this message.static final SimpleString
Message.HDR_SCALEDOWN_TO_IDS
static final SimpleString
Message.HDR_SCHEDULED_DELIVERY_TIME
To be used with Scheduled Delivery.static final SimpleString
Message.HDR_VALIDATED_USER
The name of the validated user who sent the message.static final SimpleString
FilterConstants.NON_DURABLE
Value for the Durable header when the message is non-durable.static final SimpleString
Message.PREFIX_AMQP_ANNOTATIONS
Modifier and TypeFieldDescriptionstatic final Predicate<SimpleString>
Message.AMQP_PROPERTY_PREDICATE
static final Predicate<SimpleString>
Modifier and TypeMethodDescriptionSimpleString.concat
(char c) Concatenates a SimpleString and a charConcatenates a SimpleString and a StringSimpleString.concat
(SimpleString toAdd) Concatenates 2 SimpleString'sprotected SimpleString
SimpleString.ByteBufSimpleStringPool.create
(io.netty.buffer.ByteBuf byteBuf, int length) protected SimpleString
static SimpleString
ParameterisedAddress.extractAddress
(SimpleString address) ParameterisedAddress.getAddress()
QueueConfiguration.getAddress()
Message.getAddressSimpleString()
QueueAttributes.getFilterString()
Deprecated.QueueConfiguration.getFilterString()
QueueAttributes.getGroupFirstKey()
Deprecated.QueueConfiguration.getGroupFirstKey()
default SimpleString
Message.getGroupID()
QueueAttributes.getLastValueKey()
Deprecated.QueueConfiguration.getLastValueKey()
default SimpleString
Message.getLastValueProperty()
QueueConfiguration.getName()
Message.getReplyTo()
Message.getSimpleStringProperty
(String key) Message.getSimpleStringProperty
(SimpleString key) QueueConfiguration.getUser()
static SimpleString
SimpleString.of
(byte[] data) creates a SimpleString from a byte arraystatic SimpleString
SimpleString.of
(char c) creates a SimpleString from a characterstatic SimpleString
Returns a SimpleString constructed from thestring
parameter.static SimpleString
SimpleString.of
(String string, SimpleString.StringSimpleStringPool pool) Returns a SimpleString constructed from thestring
parameter.ActiveMQBuffer.readNullableSimpleString()
Gets a SimpleString (potentiallynull
) at the currentreaderIndex
static SimpleString
SimpleString.readNullableSimpleString
(io.netty.buffer.ByteBuf buffer) static SimpleString
SimpleString.readNullableSimpleString
(io.netty.buffer.ByteBuf buffer, SimpleString.ByteBufSimpleStringPool pool) ActiveMQBuffer.readSimpleString()
Gets a non-null SimpleString at the currentreaderIndex
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.split
(char delim) Splits this SimpleString into an array of SimpleString using the char param as the delimiter.SimpleString.subSeq
(int start, int end) static SimpleString
ParameterisedAddress.toParameterisedAddress
(SimpleString address, Map<String, String> parameters) static SimpleString
SimpleString.toSimpleString
(String string) Deprecated, for removal: This API element is subject to removal in a future version.static SimpleString
SimpleString.toSimpleString
(String string, SimpleString.StringSimpleStringPool pool) Deprecated, for removal: This API element is subject to removal in a future version.Useof(String, StringSimpleStringPool)
instead.Modifier and TypeMethodDescriptionMessage.getPropertyNames()
Returns all the names of the properties for this message.Modifier and TypeMethodDescriptionint
SimpleString.compareTo
(SimpleString o) SimpleString.concat
(SimpleString toAdd) Concatenates 2 SimpleString'sboolean
Message.containsProperty
(SimpleString key) static SimpleString
ParameterisedAddress.extractAddress
(SimpleString address) Message.getAnnotation
(SimpleString key) default String
Message.getAnnotationString
(SimpleString key) Message.getBooleanProperty
(SimpleString key) default Object
Message.getBrokerProperty
(SimpleString key) Message.getByteProperty
(SimpleString key) byte[]
Message.getBytesProperty
(SimpleString key) Message.getDoubleProperty
(SimpleString key) default byte[]
Message.getExtraBytesProperty
(SimpleString key) Message.getFloatProperty
(SimpleString key) Message.getIntProperty
(SimpleString key) Message.getLongProperty
(SimpleString key) Message.getObjectProperty
(SimpleString key) default Object
Message.getObjectPropertyForFilter
(SimpleString key) Message.getShortProperty
(SimpleString key) Message.getSimpleStringProperty
(SimpleString key) 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) static QueueConfiguration
QueueConfiguration.of
(SimpleString name) Instance factory which invokesQueueConfiguration.setName(SimpleString)
Message.putBooleanProperty
(SimpleString key, boolean value) Callers must callMessage.reencode()
in order to be sent to clientsMessage.putByteProperty
(SimpleString key, byte value) Callers must callMessage.reencode()
in order to be sent to clientsMessage.putBytesProperty
(SimpleString key, byte[] value) Callers must callMessage.reencode()
in order to be sent to clientsMessage.putCharProperty
(SimpleString key, char value) Callers must callMessage.reencode()
in order to be sent to clientsMessage.putDoubleProperty
(SimpleString key, double value) Callers must callMessage.reencode()
in order to be sent to clientsdefault Message
Message.putExtraBytesProperty
(SimpleString key, byte[] value) Message.putFloatProperty
(SimpleString key, float value) Callers must callMessage.reencode()
in order to be sent to clientsMessage.putIntProperty
(SimpleString key, int value) Callers must callMessage.reencode()
in order to be sent to clientsMessage.putLongProperty
(SimpleString key, long value) Callers must callMessage.reencode()
in order to be sent to clientsMessage.putObjectProperty
(SimpleString key, Object value) Callers must callMessage.reencode()
in order to be sent to clientsMessage.putShortProperty
(SimpleString key, short value) Callers must callMessage.reencode()
in order to be sent to clientsMessage.putStringProperty
(SimpleString key, String value) Message.putStringProperty
(SimpleString key, SimpleString value) default void
Message.referenceOriginalMessage
(Message original, SimpleString originalQueue) default Object
Message.removeAnnotation
(SimpleString key) default byte[]
Message.removeExtraBytesProperty
(SimpleString key) Message.removeProperty
(SimpleString key) Message.setAddress
(SimpleString address) This will set the address on CoreMessage.QueueConfiguration.setAddress
(SimpleString address) Set the address.default Message
Message.setAnnotation
(SimpleString key, Object value) Callers must callMessage.reencode()
in order to be sent to clientsdefault Message
Message.setBrokerProperty
(SimpleString key, Object value) To be called by the broker on ocasions such as DLQ and expiry.QueueAttributes.setFilterString
(SimpleString filterString) Deprecated.QueueConfiguration.setFilterString
(SimpleString filterString) QueueAttributes.setGroupFirstKey
(SimpleString groupFirstKey) Deprecated.QueueConfiguration.setGroupFirstKey
(SimpleString groupFirstKey) default Message
Message.setGroupID
(SimpleString groupID) QueueAttributes.setLastValueKey
(SimpleString lastValueKey) Deprecated.QueueConfiguration.setLastValueKey
(SimpleString lastValueKey) default Message
Message.setLastValueProperty
(SimpleString lastValueName) QueueConfiguration.setName
(SimpleString name) Set the name.Message.setReplyTo
(SimpleString address) QueueConfiguration.setUser
(SimpleString user) static int
SimpleString.sizeofNullableString
(SimpleString str) returns the size of a SimpleString which could be nullstatic int
SimpleString.sizeofString
(SimpleString str) returns the size of a SimpleStringboolean
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) void
ActiveMQBuffer.writeNullableSimpleString
(SimpleString val) Sets the specified SimpleString (potentiallynull
) at the currentwriterIndex
static void
SimpleString.writeNullableSimpleString
(io.netty.buffer.ByteBuf buffer, SimpleString val) void
ActiveMQBuffer.writeSimpleString
(SimpleString val) Sets the specified non-null SimpleString at the currentwriterIndex
static void
SimpleString.writeSimpleString
(io.netty.buffer.ByteBuf buffer, SimpleString val) ModifierConstructorDescriptionParameterisedAddress
(SimpleString address) ParameterisedAddress
(SimpleString address, QueueAttributes queueAttributes) Deprecated.ParameterisedAddress
(SimpleString address, QueueConfiguration queueConfiguration) Deprecated, for removal: This API element is subject to removal in a future version.UseQueueConfiguration.of(SimpleString)
instead. -
Uses of SimpleString in org.apache.activemq.artemis.api.core.client
Modifier and TypeMethodDescriptionClientProducer.getAddress()
Returns the address where messages will be sent.ClientSession.QueueQuery.getAddress()
Returns the address that the queue is bound to.ClientSession.AddressQuery.getDefaultLastValueKey()
ClientSession.QueueQuery.getFilterString()
Returns the queue's filter string (ornull
if the queue has no filter).ClientSession.QueueQuery.getGroupFirstKey()
ClientSession.QueueQuery.getLastValueKey()
ClientSession.QueueQuery.getName()
Return the name of the queueModifier and TypeMethodDescriptionClientSession.AddressQuery.getQueueNames()
Returns the names of the queues bound to the binding.Modifier and TypeMethodDescriptionClientSession.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 typevoid
ClientSession.createAddress
(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated) Deprecated.void
ClientSession.createAddress
(SimpleString address, RoutingType routingType, boolean autoCreated) Create Address with a single initial routing typeClientSession.createConsumer
(SimpleString queueName) Creates a ClientConsumer to consume message from the queue with the given name.ClientSession.createConsumer
(SimpleString queueName, boolean browseOnly) Creates a ClientConsumer to consume or browse messages from the queue with the given name.ClientSession.createConsumer
(SimpleString queueName, SimpleString filter) Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.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.ClientSession.createConsumer
(SimpleString queueName, SimpleString filter, int priority, boolean browseOnly) Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.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.ClientSession.createConsumer
(SimpleString queueName, SimpleString filter, int priority, int windowSize, int maxRate, boolean browseOnly) Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.ClientSession.createProducer
(SimpleString address) Creates a producer which sends messages to the given addressClientSession.createProducer
(SimpleString address, int rate) Creates a producer which sends messages to the given addressvoid
ClientSession.createQueue
(SimpleString address, RoutingType routingType, SimpleString queueName) Deprecated.void
ClientSession.createQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable) Deprecated.void
ClientSession.createQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.void
ClientSession.createQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated) Deprecated.void
ClientSession.createQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers) Deprecated.void
ClientSession.createQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.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, boolean autoCreated, QueueAttributes queueAttributes) 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) Deprecated.void
ClientSession.createSharedQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.void
ClientSession.createSharedQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.void
ClientSession.createSharedQueue
(SimpleString address, SimpleString queueName, boolean durable) Deprecated.void
ClientSession.createSharedQueue
(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.void
ClientSession.createSharedQueue
(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.void
ClientSession.createTemporaryQueue
(SimpleString address, RoutingType routingType, SimpleString queueName) Deprecated.void
ClientSession.createTemporaryQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter) Deprecated.void
ClientSession.createTemporaryQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.void
ClientSession.createTemporaryQueue
(SimpleString address, SimpleString queueName) Deprecated.void
ClientSession.createTemporaryQueue
(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.void
ClientSession.createTemporaryQueue
(SimpleString address, SimpleString queueName, SimpleString filter) Deprecated.void
ClientSession.deleteQueue
(SimpleString queueName) Deletes the queue.ClientMessage.putBooleanProperty
(SimpleString key, boolean value) Overridden fromMessage
to enable fluent APIClientMessage.putByteProperty
(SimpleString key, byte value) Overridden fromMessage
to enable fluent APIClientMessage.putBytesProperty
(SimpleString key, byte[] value) Overridden fromMessage
to enable fluent APIClientMessage.putCharProperty
(SimpleString key, char value) Overridden fromMessage
to enable fluent APIClientMessage.putDoubleProperty
(SimpleString key, double value) Overridden fromMessage
to enable fluent APIClientMessage.putFloatProperty
(SimpleString key, float value) Overridden fromMessage
to enable fluent APIClientMessage.putIntProperty
(SimpleString key, int value) Overridden fromMessage
to enable fluent APIClientMessage.putLongProperty
(SimpleString key, long value) Overridden fromMessage
to enable fluent APIClientMessage.putShortProperty
(SimpleString key, short value) Overridden fromMessage
to enable fluent APIClientSession.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.ModifierConstructorDescriptionClientRequestor
(ClientSession session, SimpleString requestAddress) Constructor for the ClientRequestor. -
Uses of SimpleString in org.apache.activemq.artemis.api.core.management
Modifier and TypeFieldDescriptionstatic final SimpleString
ManagementHelper.HDR_ADDRESS
static final SimpleString
ManagementHelper.HDR_ATTRIBUTE
static final SimpleString
ManagementHelper.HDR_BINDING_ID
static final SimpleString
ManagementHelper.HDR_BINDING_TYPE
static final SimpleString
ManagementHelper.HDR_CERT_SUBJECT_DN
static final SimpleString
ManagementHelper.HDR_CHECK_TYPE
static final SimpleString
ManagementHelper.HDR_CLIENT_ID
static final SimpleString
ManagementHelper.HDR_CLUSTER_NAME
static final SimpleString
ManagementHelper.HDR_CONNECTION_NAME
static final SimpleString
ManagementHelper.HDR_CONSUMER_COUNT
static final SimpleString
ManagementHelper.HDR_CONSUMER_NAME
static final SimpleString
ManagementHelper.HDR_DISTANCE
static final SimpleString
ManagementHelper.HDR_FILTERSTRING
static final SimpleString
ManagementHelper.HDR_MESSAGE_ID
static final SimpleString
ManagementHelper.HDR_NOTIFICATION_TIMESTAMP
static final SimpleString
ManagementHelper.HDR_NOTIFICATION_TYPE
static final SimpleString
ManagementHelper.HDR_OPERATION_NAME
static final SimpleString
ManagementHelper.HDR_OPERATION_SUCCEEDED
static final SimpleString
ManagementHelper.HDR_PROPOSAL_ALT_VALUE
static final SimpleString
ManagementHelper.HDR_PROPOSAL_GROUP_ID
static final SimpleString
ManagementHelper.HDR_PROPOSAL_VALUE
static final SimpleString
ManagementHelper.HDR_PROTOCOL_NAME
static final SimpleString
ManagementHelper.HDR_REMOTE_ADDRESS
static final SimpleString
ManagementHelper.HDR_RESOURCE_NAME
static final SimpleString
ManagementHelper.HDR_ROUTING_NAME
static final SimpleString
ManagementHelper.HDR_ROUTING_TYPE
static final SimpleString
ManagementHelper.HDR_SESSION_NAME
static final SimpleString
ManagementHelper.HDR_USER
static final SimpleString
ManagementHelper.HDR_VALIDATED_USER
Modifier and TypeMethodDescriptionstatic SimpleString
ResourceNames.getRetroactiveResourceAddressName
(String prefix, String delimiter, SimpleString address) static SimpleString
ResourceNames.getRetroactiveResourceDivertName
(String prefix, String delimiter, SimpleString address) static SimpleString
ResourceNames.getRetroactiveResourceQueueName
(String prefix, String delimiter, SimpleString address, RoutingType routingType) Modifier and TypeMethodDescriptionObjectNameBuilder.getAddressObjectName
(SimpleString address) Returns the ObjectName used by AddressControl.ObjectNameBuilder.getQueueObjectName
(SimpleString address, SimpleString name, RoutingType routingType) Returns the ObjectName used by QueueControl.static SimpleString
ResourceNames.getRetroactiveResourceAddressName
(String prefix, String delimiter, SimpleString address) static SimpleString
ResourceNames.getRetroactiveResourceDivertName
(String prefix, String delimiter, SimpleString address) static SimpleString
ResourceNames.getRetroactiveResourceQueueName
(String prefix, String delimiter, SimpleString address, RoutingType routingType) static boolean
ResourceNames.isRetroactiveResource
(String prefix, SimpleString address) -
Uses of SimpleString in org.apache.activemq.artemis.core.config
Modifier and TypeMethodDescriptionConfiguration.getManagementAddress()
Returns the management address of this server.Configuration.getManagementNotificationAddress()
Returns the management notification address of this server.Modifier and TypeMethodDescriptionConfiguration.setManagementAddress
(SimpleString address) Sets the management address of this server.Configuration.setManagementNotificationAddress
(SimpleString address) Sets the management notification address of this server. -
Uses of SimpleString in org.apache.activemq.artemis.core.config.amqpBrokerConnectivity
Modifier and TypeMethodDescriptionAMQPBrokerConnectionElement.getMatchAddress()
AMQPMirrorBrokerConnectionElement.getMirrorSNF()
AMQPBrokerConnectionElement.getQueueName()
Modifier and TypeMethodDescriptionstatic boolean
AMQPBrokerConnectionElement.match
(SimpleString matchAddressString, SimpleString checkAddressString, WildcardConfiguration wildcardConfig) boolean
AMQPBrokerConnectionElement.match
(SimpleString checkAddress, WildcardConfiguration wildcardConfig) AMQPBrokerConnectionElement.setMatchAddress
(SimpleString matchAddress) AMQPMirrorBrokerConnectionElement.setMirrorSNF
(SimpleString mirrorSNF) AMQPBrokerConnectionElement.setQueueName
(SimpleString queueName) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.plugin
Modifier and TypeMethodDescriptiondefault void
ActiveMQServerQueuePlugin.afterDestroyQueue
(org.apache.activemq.artemis.core.server.Queue queue, SimpleString address, org.apache.activemq.artemis.core.security.SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) After a queue has been destroyeddefault void
ActiveMQServerAddressPlugin.afterRemoveAddress
(SimpleString address, org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo) After an address has been removeddefault void
ActiveMQServerConsumerPlugin.beforeCreateConsumer
(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) default void
ActiveMQServerConsumerPlugin.beforeCreateConsumer
(long consumerID, org.apache.activemq.artemis.core.postoffice.QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) Before a consumer is createddefault void
ActiveMQServerQueuePlugin.beforeDestroyQueue
(SimpleString queueName, org.apache.activemq.artemis.core.security.SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) default void
ActiveMQServerAddressPlugin.beforeRemoveAddress
(SimpleString address) Before an address is removeddefault void
ActiveMQServerBindingPlugin.beforeRemoveBinding
(SimpleString uniqueName, org.apache.activemq.artemis.core.transaction.Transaction tx, boolean deleteData) Before a binding is removeddefault void
ActiveMQServerAddressPlugin.beforeUpdateAddress
(SimpleString address, EnumSet<RoutingType> routingTypes) Before an address is updateddefault void
ActiveMQServerMessagePlugin.messageExpired
(org.apache.activemq.artemis.core.server.MessageReference message, SimpleString messageExpiryAddress) default void
ActiveMQServerMessagePlugin.messageExpired
(org.apache.activemq.artemis.core.server.MessageReference message, SimpleString messageExpiryAddress, org.apache.activemq.artemis.core.server.ServerConsumer consumer) A message has been expireddefault void
ActiveMQServerMessagePlugin.messageMoved
(org.apache.activemq.artemis.core.transaction.Transaction tx, org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason, SimpleString destAddress, Long destQueueID, org.apache.activemq.artemis.core.server.ServerConsumer consumer, Message newMessage, org.apache.activemq.artemis.core.postoffice.RoutingStatus result) A message has been movedModifier and TypeMethodDescriptiondefault void
ActiveMQServerSessionPlugin.beforeCreateSession
(String name, String username, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, org.apache.activemq.artemis.core.persistence.OperationContext context, Map<SimpleString, RoutingType> prefixes) Before a session is created. -
Uses of SimpleString in org.apache.activemq.artemis.spi.core.protocol
Modifier and TypeMethodDescriptionAbstractProtocolManager.getPrefixes()
ProtocolManager.getPrefixes()
Modifier and TypeMethodDescriptionvoid
AbstractRemotingConnection.killMessage
(SimpleString nodeID) void
RemotingConnection.killMessage
(SimpleString nodeID) if slow consumer is killed,send the msessage to client.void
SessionCallback.sendProducerCreditsFailMessage
(int credits, SimpleString address) void
SessionCallback.sendProducerCreditsMessage
(int credits, SimpleString address) -
Uses of SimpleString in org.apache.activemq.artemis.spi.core.remoting
Modifier and TypeMethodDescriptionabstract ClientSession.AddressQuery
SessionContext.addressQuery
(SimpleString address) abstract void
SessionContext.createAddress
(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) abstract void
SessionContext.createAddress
(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated) Deprecated.abstract org.apache.activemq.artemis.core.client.impl.ClientConsumerInternal
SessionContext.createConsumer
(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout) abstract void
SessionContext.createQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated) Deprecated.abstract void
SessionContext.createQueue
(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated, Boolean exclusive, Boolean lastVale) abstract void
SessionContext.createQueue
(SimpleString address, SimpleString queueName, boolean temp, boolean autoCreated, QueueAttributes queueAttributes) abstract void
SessionContext.createQueue
(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, boolean autoCreated) Deprecated.abstract void
SessionContext.createSharedQueue
(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.abstract void
SessionContext.createSharedQueue
(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable) Deprecated.abstract void
SessionContext.createSharedQueue
(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.abstract void
SessionContext.createSharedQueue
(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable) Deprecated.abstract void
SessionContext.deleteQueue
(SimpleString queueName) protected void
SessionContext.handleReceiveProducerCredits
(SimpleString address, int credits) protected void
SessionContext.handleReceiveProducerFailCredits
(SimpleString address, int credits) abstract void
SessionContext.linkFlowControl
(SimpleString address, org.apache.activemq.artemis.core.client.impl.ClientProducerCredits clientProducerCredits) abstract ClientSession.QueueQuery
SessionContext.queueQuery
(SimpleString queueName) abstract void
SessionContext.sendFullMessage
(ICoreMessage msgI, boolean sendBlocking, SendAcknowledgementHandler handler, SimpleString defaultAddress, int senderID) abstract void
SessionContext.sendProducerCreditsMessage
(int credits, SimpleString address)
of(String)
instead.