Uses of Class
org.apache.activemq.artemis.api.core.SimpleString
Packages that use SimpleString
Package
Description
-
Uses of SimpleString in org.apache.activemq.artemis.api.config
Fields in org.apache.activemq.artemis.api.config declared as SimpleStringModifier and TypeFieldDescriptionstatic final SimpleStringActiveMQDefaultConfiguration.DEFAULT_GROUP_FIRST_KEYstatic final SimpleStringActiveMQDefaultConfiguration.DEFAULT_LAST_VALUE_KEYMethods in org.apache.activemq.artemis.api.config that return SimpleStringModifier and TypeMethodDescriptionstatic SimpleStringActiveMQDefaultConfiguration.getDefaultGroupFirstKey()static SimpleStringActiveMQDefaultConfiguration.getDefaultLastValueKey()static SimpleStringActiveMQDefaultConfiguration.getDefaultManagementAddress()the name of the management address to send management messages to.static SimpleStringActiveMQDefaultConfiguration.getDefaultManagementNotificationAddress()the name of the address that consumers bind to receive management notifications -
Uses of SimpleString in org.apache.activemq.artemis.api.core
Fields in org.apache.activemq.artemis.api.core declared as SimpleStringModifier and TypeFieldDescriptionstatic final SimpleStringFilterConstants.ACTIVEMQ_ADDRESSName of the ActiveMQ Artemis Address headerstatic final SimpleStringFilterConstants.ACTIVEMQ_DURABLEName of the ActiveMQ Artemis Message durable header.static final SimpleStringFilterConstants.ACTIVEMQ_EXPIRATIONName of the ActiveMQ Artemis Message expiration header.static final SimpleStringFilterConstants.ACTIVEMQ_GROUP_IDName of the ActiveMQ Artemis Message group id header.static final SimpleStringFilterConstants.ACTIVEMQ_PREFIXAll ActiveMQ Artemis headers are prepended by this prefix.static final SimpleStringFilterConstants.ACTIVEMQ_PRIORITYName of the ActiveMQ Artemis Message priority header.static final SimpleStringFilterConstants.ACTIVEMQ_SIZEName of the ActiveMQ Artemis Message size header.static final SimpleStringFilterConstants.ACTIVEMQ_TIMESTAMPName of the ActiveMQ Artemis Message timestamp header.static final SimpleStringFilterConstants.ACTIVEMQ_USERIDName of the ActiveMQ Artemis UserID header.static final SimpleStringFilterConstants.DURABLEValue for the Durable header when the message is durable.static final SimpleStringMessage.HDR_ACTUAL_EXPIRY_TIMEthe actual time the message was expiredstatic final SimpleStringMessage.HDR_BRIDGE_DUPLICATE_IDstatic final SimpleStringMessage.HDR_CONTENT_TYPETo define the mime-type of body messages.static final SimpleStringMessage.HDR_DUPLICATE_DETECTION_IDTo be used with duplicate detection.static final SimpleStringMessage.HDR_GROUP_IDFor the Message Grouping feature.static final SimpleStringMessage.HDR_GROUP_SEQUENCEstatic final SimpleStringMessage.HDR_INGRESS_TIMESTAMPThe time at which the message arrived at the broker.static final SimpleStringMessage.HDR_LARGE_BODY_SIZEThe body size of a large message before it was compressed.static final SimpleStringMessage.HDR_LARGE_COMPRESSEDto determine if the Large Message was compressed.static final SimpleStringMessage.HDR_LAST_VALUE_NAMETo be used with Last value queues.static final SimpleStringMessage.HDR_ORIG_MESSAGE_IDThe original message ID before the message was transferred.static final SimpleStringMessage.HDR_ORIG_ROUTING_TYPEThe original routing type of a message before getting transferred through DLQ or expirystatic final SimpleStringMessage.HDR_ORIGINAL_ADDRESSThe original address of a message when a message is diverted or transferred through DLQ or expirystatic final SimpleStringMessage.HDR_ORIGINAL_QUEUEThe original address of a message when a message is transferred through DLQ or expirystatic final SimpleStringMessage.HDR_PREFIXThe prefix used (if any) when sending this message.static final SimpleStringMessage.HDR_ROUTE_TO_ACK_IDSstatic final SimpleStringMessage.HDR_ROUTE_TO_IDSstatic final SimpleStringMessage.HDR_ROUTING_TYPEThe Routing Type for this message.static final SimpleStringMessage.HDR_SCALEDOWN_TO_IDSstatic final SimpleStringMessage.HDR_SCHEDULED_DELIVERY_TIMETo be used with Scheduled Delivery.static final SimpleStringMessage.HDR_VALIDATED_USERThe name of the validated user who sent the message.static final SimpleStringFilterConstants.NON_DURABLEValue for the Durable header when the message is non-durable.static final SimpleStringMessage.PREFIX_AMQP_ANNOTATIONSFields in org.apache.activemq.artemis.api.core with type parameters of type SimpleStringModifier and TypeFieldDescriptionstatic final Predicate<SimpleString>Message.AMQP_PROPERTY_PREDICATEstatic final Predicate<SimpleString>Methods in org.apache.activemq.artemis.api.core that return SimpleStringModifier and TypeMethodDescriptionSimpleString.concat(char c) Concatenates a SimpleString and a charConcatenates a SimpleString and a StringSimpleString.concat(SimpleString toAdd) Concatenates 2 SimpleString'sprotected SimpleStringSimpleString.ByteBufSimpleStringPool.create(io.netty.buffer.ByteBuf byteBuf, int length) protected SimpleStringstatic SimpleStringParameterisedAddress.extractAddress(SimpleString address) ParameterisedAddress.getAddress()QueueConfiguration.getAddress()Returns the name of the address; if the address isnullthen return the value ofQueueConfiguration.getName().Message.getAddressSimpleString()QueueAttributes.getFilterString()Deprecated.QueueConfiguration.getFilterString()QueueAttributes.getGroupFirstKey()Deprecated.QueueConfiguration.getGroupFirstKey()default SimpleStringMessage.getGroupID()QueueAttributes.getLastValueKey()Deprecated.QueueConfiguration.getLastValueKey()default SimpleStringMessage.getLastValueProperty()QueueConfiguration.getName()Message.getReplyTo()Message.getSimpleStringProperty(String key) Message.getSimpleStringProperty(SimpleString key) QueueConfiguration.getUser()static SimpleStringSimpleString.of(byte[] data) creates a SimpleString from a byte arraystatic SimpleStringSimpleString.of(char c) creates a SimpleString from a characterstatic SimpleStringReturns a SimpleString constructed from thestringparameter.static SimpleStringSimpleString.of(String string, SimpleString.StringSimpleStringPool pool) Returns a SimpleString constructed from thestringparameter.ActiveMQBuffer.readNullableSimpleString()Gets a SimpleString (potentiallynull) at the currentreaderIndexstatic SimpleStringSimpleString.readNullableSimpleString(io.netty.buffer.ByteBuf buffer) static SimpleStringSimpleString.readNullableSimpleString(io.netty.buffer.ByteBuf buffer, SimpleString.ByteBufSimpleStringPool pool) ActiveMQBuffer.readSimpleString()Gets a non-null SimpleString at the currentreaderIndexstatic SimpleStringSimpleString.readSimpleString(io.netty.buffer.ByteBuf buffer) static SimpleStringSimpleString.readSimpleString(io.netty.buffer.ByteBuf buffer, int length) static SimpleStringSimpleString.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. i.e.SimpleString.subSeq(int start, int end) static SimpleStringParameterisedAddress.toParameterisedAddress(SimpleString address, Map<String, String> parameters) static SimpleStringSimpleString.toSimpleString(String string) Deprecated, for removal: This API element is subject to removal in a future version.static SimpleStringSimpleString.toSimpleString(String string, SimpleString.StringSimpleStringPool pool) Deprecated, for removal: This API element is subject to removal in a future version.Useof(String, StringSimpleStringPool)instead.Methods in org.apache.activemq.artemis.api.core that return types with arguments of type SimpleStringModifier and TypeMethodDescriptionMessage.getPropertyNames()Returns all the names of the properties for this message.Methods in org.apache.activemq.artemis.api.core with parameters of type SimpleStringModifier and TypeMethodDescriptionintSimpleString.compareTo(SimpleString o) SimpleString.concat(SimpleString toAdd) Concatenates 2 SimpleString'sbooleanMessage.containsProperty(SimpleString key) static SimpleStringParameterisedAddress.extractAddress(SimpleString address) Message.getAnnotation(SimpleString key) default StringMessage.getAnnotationString(SimpleString key) Message.getBooleanProperty(SimpleString key) default ObjectMessage.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 ObjectMessage.getObjectPropertyForFilter(SimpleString key) Message.getShortProperty(SimpleString key) Message.getSimpleStringProperty(SimpleString key) Message.getStringProperty(SimpleString key) protected booleanSimpleString.ByteBufSimpleStringPool.isEqual(SimpleString entry, io.netty.buffer.ByteBuf byteBuf, int offset, int length) protected booleanSimpleString.StringSimpleStringPool.isEqual(SimpleString entry, String value) static booleanParameterisedAddress.isParameterised(SimpleString address) static QueueConfigurationQueueConfiguration.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 MessageMessage.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 voidMessage.referenceOriginalMessage(Message original, SimpleString originalQueue) default ObjectMessage.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 MessageMessage.setAnnotation(SimpleString key, Object value) Callers must callMessage.reencode()in order to be sent to clientsdefault MessageMessage.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) This sets theSimpleStringvalue that will be used to create aFilterfor theQueueimplementation on the broker.QueueAttributes.setGroupFirstKey(SimpleString groupFirstKey) Deprecated.QueueConfiguration.setGroupFirstKey(SimpleString groupFirstKey) default MessageMessage.setGroupID(SimpleString groupID) QueueAttributes.setLastValueKey(SimpleString lastValueKey) Deprecated.QueueConfiguration.setLastValueKey(SimpleString lastValueKey) default MessageMessage.setLastValueProperty(SimpleString lastValueName) QueueConfiguration.setName(SimpleString name) Set the name.Message.setReplyTo(SimpleString address) QueueConfiguration.setUser(SimpleString user) static intSimpleString.sizeofNullableString(SimpleString str) Returns the size of a SimpleString which could benull.static intSimpleString.sizeofString(SimpleString str) Returns the size of a SimpleString.booleanSimpleString.startsWith(SimpleString other) Returnstrueif theSimpleStringparameter starts with the same data as this one, otherwisefalse.static SimpleStringParameterisedAddress.toParameterisedAddress(SimpleString address, Map<String, String> parameters) voidActiveMQBuffer.writeNullableSimpleString(SimpleString val) Sets the specified SimpleString (potentiallynull) at the currentwriterIndexstatic voidSimpleString.writeNullableSimpleString(io.netty.buffer.ByteBuf buffer, SimpleString val) voidActiveMQBuffer.writeSimpleString(SimpleString val) Sets the specified non-null SimpleString at the currentwriterIndexstatic voidSimpleString.writeSimpleString(io.netty.buffer.ByteBuf buffer, SimpleString val) Constructors in org.apache.activemq.artemis.api.core with parameters of type SimpleStringModifierConstructorDescriptionParameterisedAddress(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
Methods in org.apache.activemq.artemis.api.core.client that return SimpleStringModifier and TypeMethodDescriptionClientProducer.getAddress()Returns the address where messages will be sent; the address can benullif theClientProducerwas created without specifying an address, e.g. by usingClientSession.createProducer().ClientSession.QueueQuery.getAddress()Returns the address that the queue is bound to.ClientSession.AddressQuery.getDefaultLastValueKey()ClientSession.QueueQuery.getFilterString()Returns the queue's filter string (ornullif the queue has no filter).ClientSession.QueueQuery.getGroupFirstKey()ClientSession.QueueQuery.getLastValueKey()ClientSession.QueueQuery.getName()Return the name of the queueMethods in org.apache.activemq.artemis.api.core.client that return types with arguments of type SimpleStringModifier and TypeMethodDescriptionClientSession.AddressQuery.getQueueNames()Returns the names of the queues bound to the binding.Methods in org.apache.activemq.artemis.api.core.client with parameters of type SimpleStringModifier and TypeMethodDescriptionClientSession.addressQuery(SimpleString address) Queries information on a binding.voidClientSession.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) Create Address with a single initial routing typevoidClientSession.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated) Deprecated.voidClientSession.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 addressvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, SimpleString queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, SimpleString queueName, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, SimpleString queueName, boolean autoCreated, QueueAttributes queueAttributes) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable) Deprecated.voidClientSession.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.voidClientSession.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidClientSession.createSharedQueue(SimpleString address, SimpleString queueName, boolean durable) Deprecated.voidClientSession.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.voidClientSession.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.voidClientSession.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, SimpleString queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.deleteQueue(SimpleString queueName) Deletes the queue.ClientMessage.putBooleanProperty(SimpleString key, boolean value) Overridden fromMessageto enable fluent APIClientMessage.putByteProperty(SimpleString key, byte value) Overridden fromMessageto enable fluent APIClientMessage.putBytesProperty(SimpleString key, byte[] value) Overridden fromMessageto enable fluent APIClientMessage.putCharProperty(SimpleString key, char value) Overridden fromMessageto enable fluent APIClientMessage.putDoubleProperty(SimpleString key, double value) Overridden fromMessageto enable fluent APIClientMessage.putFloatProperty(SimpleString key, float value) Overridden fromMessageto enable fluent APIClientMessage.putIntProperty(SimpleString key, int value) Overridden fromMessageto enable fluent APIClientMessage.putLongProperty(SimpleString key, long value) Overridden fromMessageto enable fluent APIClientMessage.putShortProperty(SimpleString key, short value) Overridden fromMessageto enable fluent APIClientSession.queueQuery(SimpleString queueName) Queries information on a queue.voidClientProducer.send(SimpleString address, Message message) Sends a message to the specified address instead of the ClientProducer's address.voidClientProducer.send(SimpleString address, Message message, SendAcknowledgementHandler handler) Sends a message to the specified address instead of the ClientProducer's address.Constructors in org.apache.activemq.artemis.api.core.client with parameters of type SimpleStringModifierConstructorDescriptionClientRequestor(ClientSession session, SimpleString requestAddress) Constructor for the ClientRequestor. -
Uses of SimpleString in org.apache.activemq.artemis.api.core.management
Fields in org.apache.activemq.artemis.api.core.management declared as SimpleStringModifier and TypeFieldDescriptionstatic final SimpleStringManagementHelper.HDR_ADDRESSstatic final SimpleStringManagementHelper.HDR_ATTRIBUTEstatic final SimpleStringManagementHelper.HDR_BINDING_IDstatic final SimpleStringManagementHelper.HDR_BINDING_TYPEstatic final SimpleStringManagementHelper.HDR_CERT_SUBJECT_DNstatic final SimpleStringManagementHelper.HDR_CHECK_TYPEstatic final SimpleStringManagementHelper.HDR_CLIENT_IDstatic final SimpleStringManagementHelper.HDR_CLUSTER_NAMEstatic final SimpleStringManagementHelper.HDR_CONNECTION_NAMEstatic final SimpleStringManagementHelper.HDR_CONSUMER_COUNTstatic final SimpleStringManagementHelper.HDR_CONSUMER_NAMEstatic final SimpleStringManagementHelper.HDR_DISTANCEstatic final SimpleStringManagementHelper.HDR_FILTERSTRINGstatic final SimpleStringManagementHelper.HDR_MESSAGE_IDstatic final SimpleStringManagementHelper.HDR_NOTIFICATION_TIMESTAMPstatic final SimpleStringManagementHelper.HDR_NOTIFICATION_TYPEstatic final SimpleStringManagementHelper.HDR_OPERATION_NAMEstatic final SimpleStringManagementHelper.HDR_OPERATION_SUCCEEDEDstatic final SimpleStringManagementHelper.HDR_PROPOSAL_ALT_VALUEstatic final SimpleStringManagementHelper.HDR_PROPOSAL_GROUP_IDstatic final SimpleStringManagementHelper.HDR_PROPOSAL_VALUEstatic final SimpleStringManagementHelper.HDR_PROTOCOL_NAMEstatic final SimpleStringManagementHelper.HDR_REMOTE_ADDRESSstatic final SimpleStringManagementHelper.HDR_RESOURCE_NAMEstatic final SimpleStringManagementHelper.HDR_ROUTING_NAMEstatic final SimpleStringManagementHelper.HDR_ROUTING_TYPEstatic final SimpleStringManagementHelper.HDR_SESSION_NAMEstatic final SimpleStringManagementHelper.HDR_USERstatic final SimpleStringManagementHelper.HDR_VALIDATED_USERMethods in org.apache.activemq.artemis.api.core.management that return SimpleStringModifier and TypeMethodDescriptionstatic SimpleStringResourceNames.getRetroactiveResourceAddressName(String prefix, String delimiter, SimpleString address) static SimpleStringResourceNames.getRetroactiveResourceDivertName(String prefix, String delimiter, SimpleString address) static SimpleStringResourceNames.getRetroactiveResourceQueueName(String prefix, String delimiter, SimpleString address, RoutingType routingType) Methods in org.apache.activemq.artemis.api.core.management with parameters of type SimpleStringModifier 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 SimpleStringResourceNames.getRetroactiveResourceAddressName(String prefix, String delimiter, SimpleString address) static SimpleStringResourceNames.getRetroactiveResourceDivertName(String prefix, String delimiter, SimpleString address) static SimpleStringResourceNames.getRetroactiveResourceQueueName(String prefix, String delimiter, SimpleString address, RoutingType routingType) static booleanResourceNames.isRetroactiveResource(String prefix, SimpleString address) -
Uses of SimpleString in org.apache.activemq.artemis.core.buffers.impl
Methods in org.apache.activemq.artemis.core.buffers.impl that return SimpleStringModifier and TypeMethodDescriptionChannelBufferWrapper.readNullableSimpleString()ChannelBufferWrapper.readSimpleString()Methods in org.apache.activemq.artemis.core.buffers.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidChannelBufferWrapper.writeNullableSimpleString(SimpleString val) voidResetLimitWrappedActiveMQBuffer.writeNullableSimpleString(SimpleString val) voidChannelBufferWrapper.writeSimpleString(SimpleString val) voidResetLimitWrappedActiveMQBuffer.writeSimpleString(SimpleString val) -
Uses of SimpleString in org.apache.activemq.artemis.core.client.impl
Fields in org.apache.activemq.artemis.core.client.impl declared as SimpleStringModifier and TypeFieldDescriptionprotected final SimpleStringAbstractProducerCreditsImpl.addressstatic final SimpleStringClientConsumerImpl.FORCED_DELIVERY_MESSAGEstatic final SimpleStringClientMessageImpl.REPLYTO_HEADER_NAMEMethods in org.apache.activemq.artemis.core.client.impl that return SimpleStringModifier and TypeMethodDescriptionAbstractProducerCreditsImpl.getAddress()ClientProducerCredits.getAddress()ClientProducerImpl.getAddress()QueueQueryImpl.getAddress()AddressQueryImpl.getDefaultLastValueKey()ClientConsumerImpl.getFilterString()ClientConsumerInternal.getFilterString()QueueQueryImpl.getFilterString()QueueQueryImpl.getGroupFirstKey()QueueQueryImpl.getLastValueKey()QueueQueryImpl.getName()ClientConsumerImpl.getQueueName()ClientConsumerInternal.getQueueName()LargeMessageControllerImpl.readNullableSimpleString()LargeMessageControllerImpl.readSimpleString()Methods in org.apache.activemq.artemis.core.client.impl that return types with arguments of type SimpleStringMethods in org.apache.activemq.artemis.core.client.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionClientSessionImpl.addressQuery(SimpleString address) voidClientSessionImpl.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) voidClientSessionImpl.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated) voidClientSessionImpl.createAddress(SimpleString address, RoutingType routingType, boolean autoCreated) ClientSessionImpl.createConsumer(SimpleString queueName) ClientSessionImpl.createConsumer(SimpleString queueName, boolean browseOnly) ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString) ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, boolean browseOnly) ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly) ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int windowSize, int maxRate, boolean browseOnly) ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, boolean browseOnly) Note, we DO NOT currently support direct consumers (i.e. consumers where delivery occurs on the remoting thread).ClientSessionImpl.createProducer(SimpleString address) ClientSessionImpl.createProducer(SimpleString address, int maxRate) voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, SimpleString queueName) voidClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, boolean durable) voidClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, boolean autoCreated, QueueAttributes queueAttributes) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable) voidClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated) voidClientSessionImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable) voidClientSessionImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable) voidClientSessionImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidClientSessionImpl.createSharedQueue(SimpleString address, SimpleString queueName, boolean durable) voidClientSessionImpl.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.voidClientSessionImpl.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable) voidClientSessionImpl.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName) voidClientSessionImpl.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter) Deprecated.voidClientSessionImpl.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidClientSessionImpl.createTemporaryQueue(SimpleString address, SimpleString queueName) voidClientSessionImpl.createTemporaryQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.voidClientSessionImpl.createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter) voidClientSessionImpl.deleteQueue(SimpleString queueName) ClientProducerCreditManager.getCredits(SimpleString address, boolean anon, SessionContext context) ClientProducerCreditManagerImpl.getCredits(SimpleString address, boolean anon, SessionContext context) ClientSessionImpl.getCredits(SimpleString address, boolean anon) ClientSessionInternal.getCredits(SimpleString address, boolean anon) voidClientSessionImpl.handleReceiveProducerCredits(SimpleString address, int credits) voidClientSessionInternal.handleReceiveProducerCredits(SimpleString address, int credits) voidClientSessionImpl.handleReceiveProducerFailCredits(SimpleString address, int credits) voidClientSessionInternal.handleReceiveProducerFailCredits(SimpleString address, int credits) ClientMessageImpl.putBooleanProperty(SimpleString key, boolean value) ClientMessageImpl.putByteProperty(SimpleString key, byte value) ClientMessageImpl.putBytesProperty(SimpleString key, byte[] value) ClientMessageImpl.putCharProperty(SimpleString key, char value) ClientMessageImpl.putDoubleProperty(SimpleString key, double value) ClientMessageImpl.putFloatProperty(SimpleString key, float value) ClientMessageImpl.putIntProperty(SimpleString key, int value) ClientMessageImpl.putLongProperty(SimpleString key, long value) ClientMessageImpl.putObjectProperty(SimpleString key, Object value) ClientMessageImpl.putShortProperty(SimpleString key, short value) ClientMessageImpl.putStringProperty(SimpleString key, String value) ClientMessageImpl.putStringProperty(SimpleString key, SimpleString value) ClientSessionImpl.queueQuery(SimpleString queueName) voidClientProducerCreditManager.receiveCredits(SimpleString address, int credits) voidClientProducerCreditManagerImpl.receiveCredits(SimpleString address, int credits) voidClientProducerCreditManager.receiveFailCredits(SimpleString address, int credits) voidClientProducerCreditManagerImpl.receiveFailCredits(SimpleString address, int credits) voidClientProducerCreditManager.returnCredits(SimpleString address) voidClientProducerCreditManagerImpl.returnCredits(SimpleString address) voidClientSessionImpl.returnCredits(SimpleString address) voidClientSessionInternal.returnCredits(SimpleString address) voidClientProducerImpl.send(SimpleString address1, Message msg) voidClientProducerImpl.send(SimpleString address1, Message message, SendAcknowledgementHandler handler) voidClientSessionImpl.sendProducerCreditsMessage(int credits, SimpleString address) voidClientSessionInternal.sendProducerCreditsMessage(int credits, SimpleString address) voidClientSessionImpl.setAddress(Message message, SimpleString address) voidClientSessionInternal.setAddress(Message message, SimpleString address) This will set the address at the messagevoidLargeMessageControllerImpl.writeNullableSimpleString(SimpleString val) voidLargeMessageControllerImpl.writeSimpleString(SimpleString val) Constructors in org.apache.activemq.artemis.core.client.impl with parameters of type SimpleStringModifierConstructorDescriptionAbstractProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize) AddressQueryImpl(boolean exists, List<SimpleString> queueNames, boolean autoCreateQueues, boolean autoCreateAddresses, boolean defaultPurgeOnNoConsumers, int defaultMaxConsumers, Boolean defaultExclusive, Boolean defaultLastValue, SimpleString defaultLastValueKey, Boolean defaultNonDestructive, Integer defaultConsumersBeforeDispatch, Long defaultDelayBeforeDispatch, boolean supportsMulticast, boolean supportsAnycast) AsynchronousProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize, ClientProducerFlowCallback callback) ClientConsumerImpl(ClientSessionInternal session, ConsumerContext consumerContext, SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly, int initialWindow, int clientWindowSize, int ackBatchSize, TokenBucketLimiter rateLimiter, Executor executor, Executor flowControlExecutor, SessionContext sessionContext, ClientSession.QueueQuery queueInfo, ClassLoader contextClassLoader, int onMessageCloseTimeout) 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, int producerID) 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 groupRebalance, Boolean groupRebalancePauseDispatch, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, Integer defaultConsumerWindowSize, Long ringSize, Boolean enabled, Boolean configurationManaged) 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, Integer defaultConsumerWindowSize) 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 groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, Integer defaultConsumerWindowSize) Constructor parameters in org.apache.activemq.artemis.core.client.impl with type arguments of type SimpleStringModifierConstructorDescriptionAddressQueryImpl(boolean exists, List<SimpleString> queueNames, boolean autoCreateQueues, boolean autoCreateAddresses, boolean defaultPurgeOnNoConsumers, int defaultMaxConsumers, Boolean defaultExclusive, Boolean defaultLastValue, SimpleString defaultLastValueKey, Boolean defaultNonDestructive, Integer defaultConsumersBeforeDispatch, Long defaultDelayBeforeDispatch, boolean supportsMulticast, boolean supportsAnycast) -
Uses of SimpleString in org.apache.activemq.artemis.core.config
Methods in org.apache.activemq.artemis.core.config that return SimpleStringModifier and TypeMethodDescriptionConfiguration.getManagementAddress()Returns the management address of this server; Clients can send management messages to this address to manage this server; default isActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_ADDRESS.Configuration.getManagementNotificationAddress()Returns the management notification address of this server; Clients can bind queues to this address to receive management notifications emitted by this server; default isActiveMQDefaultConfiguration.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS.Methods in org.apache.activemq.artemis.core.config with parameters of type SimpleStringModifier 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
Methods in org.apache.activemq.artemis.core.config.amqpBrokerConnectivity that return SimpleStringModifier and TypeMethodDescriptionAMQPBrokerConnectionElement.getMatchAddress()AMQPMirrorBrokerConnectionElement.getMirrorSNF()AMQPBrokerConnectionElement.getQueueName()Methods in org.apache.activemq.artemis.core.config.amqpBrokerConnectivity with parameters of type SimpleStringModifier and TypeMethodDescriptionstatic booleanAMQPBrokerConnectionElement.match(SimpleString matchAddressString, SimpleString checkAddressString, WildcardConfiguration wildcardConfig) booleanAMQPBrokerConnectionElement.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.config.impl
Methods in org.apache.activemq.artemis.core.config.impl that return SimpleStringModifier and TypeMethodDescriptionConfigurationImpl.getManagementAddress()ConfigurationImpl.getManagementNotificationAddress()Methods in org.apache.activemq.artemis.core.config.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionConfigurationImpl.setManagementAddress(SimpleString address) ConfigurationImpl.setManagementNotificationAddress(SimpleString address) -
Uses of SimpleString in org.apache.activemq.artemis.core.filter
Methods in org.apache.activemq.artemis.core.filter that return SimpleStringModifier and TypeMethodDescriptionFilter.getFilterString()static SimpleStringFilter.toFilterString(Filter filter) -
Uses of SimpleString in org.apache.activemq.artemis.core.filter.impl
Methods in org.apache.activemq.artemis.core.filter.impl that return SimpleStringMethods in org.apache.activemq.artemis.core.filter.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionstatic FilterFilterImpl.createFilter(SimpleString filterStr) Returns null iffilterStris null or an empty String and a valid filter else. -
Uses of SimpleString in org.apache.activemq.artemis.core.management.impl
Methods in org.apache.activemq.artemis.core.management.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidManagementRemotingConnection.killMessage(SimpleString nodeID) protected StringAbstractControl.sendMessage(SimpleString address, ActiveMQServer server, Map<String, String> headers, int type, String body, boolean durable, String user, String password, boolean createMessageId) -
Uses of SimpleString in org.apache.activemq.artemis.core.message.impl
Fields in org.apache.activemq.artemis.core.message.impl declared as SimpleStringMethods in org.apache.activemq.artemis.core.message.impl that return SimpleStringModifier and TypeMethodDescriptionCoreMessage.getAddressSimpleString()MessageInternalImpl.getAddressSimpleString()Deprecated.CoreMessage.getGroupID()CoreMessage.getLastValueProperty()CoreMessage.getReplyTo()MessageInternalImpl.getReplyTo()Deprecated.CoreMessage.getSimpleStringProperty(String key) CoreMessage.getSimpleStringProperty(SimpleString key) MessageInternalImpl.getSimpleStringProperty(String key) Deprecated.MessageInternalImpl.getSimpleStringProperty(SimpleString key) Deprecated.Methods in org.apache.activemq.artemis.core.message.impl that return types with arguments of type SimpleStringModifier and TypeMethodDescriptionCoreMessage.getPropertyNames()MessageInternalImpl.getPropertyNames()Deprecated.Methods in org.apache.activemq.artemis.core.message.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionbooleanCoreMessage.containsProperty(SimpleString key) booleanMessageInternalImpl.containsProperty(SimpleString key) Deprecated.CoreMessage.getAnnotation(SimpleString key) On core there's no delivery annotationMessageInternalImpl.getAnnotation(SimpleString key) Deprecated.CoreMessage.getBooleanProperty(SimpleString key) MessageInternalImpl.getBooleanProperty(SimpleString key) Deprecated.CoreMessage.getByteProperty(SimpleString key) MessageInternalImpl.getByteProperty(SimpleString key) Deprecated.byte[]CoreMessage.getBytesProperty(SimpleString key) byte[]MessageInternalImpl.getBytesProperty(SimpleString key) Deprecated.CoreMessage.getDoubleProperty(SimpleString key) MessageInternalImpl.getDoubleProperty(SimpleString key) Deprecated.CoreMessage.getFloatProperty(SimpleString key) MessageInternalImpl.getFloatProperty(SimpleString key) Deprecated.CoreMessage.getIntProperty(SimpleString key) MessageInternalImpl.getIntProperty(SimpleString key) Deprecated.CoreMessage.getLongProperty(SimpleString key) MessageInternalImpl.getLongProperty(SimpleString key) Deprecated.CoreMessage.getObjectProperty(SimpleString key) MessageInternalImpl.getObjectProperty(SimpleString key) Deprecated.CoreMessage.getShortProperty(SimpleString key) MessageInternalImpl.getShortProperty(SimpleString key) Deprecated.CoreMessage.getSimpleStringProperty(SimpleString key) MessageInternalImpl.getSimpleStringProperty(SimpleString key) Deprecated.CoreMessage.getStringProperty(SimpleString key) MessageInternalImpl.getStringProperty(SimpleString key) Deprecated.CoreMessage.putBooleanProperty(SimpleString key, boolean value) MessageInternalImpl.putBooleanProperty(SimpleString key, boolean value) Deprecated.CoreMessage.putByteProperty(SimpleString key, byte value) MessageInternalImpl.putByteProperty(SimpleString key, byte value) Deprecated.CoreMessage.putBytesProperty(SimpleString key, byte[] value) MessageInternalImpl.putBytesProperty(SimpleString key, byte[] value) Deprecated.CoreMessage.putCharProperty(SimpleString key, char value) MessageInternalImpl.putCharProperty(SimpleString key, char value) Deprecated.CoreMessage.putDoubleProperty(SimpleString key, double value) MessageInternalImpl.putDoubleProperty(SimpleString key, double value) Deprecated.CoreMessage.putFloatProperty(SimpleString key, float value) MessageInternalImpl.putFloatProperty(SimpleString key, float value) Deprecated.CoreMessage.putIntProperty(SimpleString key, int value) MessageInternalImpl.putIntProperty(SimpleString key, int value) Deprecated.CoreMessage.putLongProperty(SimpleString key, long value) MessageInternalImpl.putLongProperty(SimpleString key, long value) Deprecated.CoreMessage.putObjectProperty(SimpleString key, Object value) MessageInternalImpl.putObjectProperty(SimpleString key, Object value) Deprecated.CoreMessage.putShortProperty(SimpleString key, short value) MessageInternalImpl.putShortProperty(SimpleString key, short value) Deprecated.CoreMessage.putStringProperty(SimpleString key, String value) CoreMessage.putStringProperty(SimpleString key, SimpleString value) MessageInternalImpl.putStringProperty(SimpleString key, String value) Deprecated.MessageInternalImpl.putStringProperty(SimpleString key, SimpleString value) Deprecated.CoreMessage.removeAnnotation(SimpleString key) On core there's no delivery annotationCoreMessage.removeProperty(SimpleString key) MessageInternalImpl.removeProperty(SimpleString key) Deprecated.booleanCoreMessage.searchProperty(SimpleString key) Differently fromCoreMessage.containsProperty(SimpleString), this method can save decoding the message, performing a search of thekeyproperty and falling back toCoreMessage.containsProperty(SimpleString)if not possible or if already decoded.CoreMessage.setAddress(SimpleString address) MessageInternalImpl.setAddress(SimpleString address) Deprecated.voidMessageInternal.setAddressTransient(SimpleString address) Deprecated.voidMessageInternalImpl.setAddressTransient(SimpleString address) Deprecated.CoreMessage.setGroupID(SimpleString groupId) CoreMessage.setLastValueProperty(SimpleString lastValueName) CoreMessage.setReplyTo(SimpleString address) MessageInternalImpl.setReplyTo(SimpleString address) Deprecated. -
Uses of SimpleString in org.apache.activemq.artemis.core.paging
Methods in org.apache.activemq.artemis.core.paging that return SimpleStringModifier and TypeMethodDescriptionPagingStore.getAddress()PagingStore.getStoreName()PagingManager.getStoreNames()Methods in org.apache.activemq.artemis.core.paging with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidPagingManager.deletePageStore(SimpleString storeName) PagingManager.getPageStore(SimpleString address) Returns the PageStore associated with the address; a new page store is created if necessary.PagingStoreFactory.newFileFactory(SimpleString address) PagingStoreFactory.newStore(SimpleString address, AddressSettings addressSettings) -
Uses of SimpleString in org.apache.activemq.artemis.core.paging.cursor
Methods in org.apache.activemq.artemis.core.paging.cursor that return SimpleString -
Uses of SimpleString in org.apache.activemq.artemis.core.paging.impl
Methods in org.apache.activemq.artemis.core.paging.impl that return SimpleStringModifier and TypeMethodDescriptionPagingStoreImpl.getAddress()PagingStoreImpl.getStoreName()PagingManagerImpl.getStoreNames()Methods in org.apache.activemq.artemis.core.paging.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidPagingManagerImpl.deletePageStore(SimpleString storeName) PagingManagerImpl.getPageStore(SimpleString rawStoreName) This method creates a new store if not exist.PagingStoreFactoryDatabase.newFileFactory(SimpleString address) PagingStoreFactoryNIO.newFileFactory(SimpleString address) PagingStoreFactoryDatabase.newStore(SimpleString address, AddressSettings settings) PagingStoreFactoryNIO.newStore(SimpleString address, AddressSettings settings) static intPageReadWriter.readFromSequentialFile(StorageManager storage, SimpleString storeName, SequentialFileFactory fileFactory, SequentialFile file, long pageId, Consumer<PagedMessage> messages, PageReadWriter.PageRecordFilter skipRecord, PageReadWriter.SuspectFileCallback suspectFileCallback, PageReadWriter.ReadCallback readCallback) Constructors in org.apache.activemq.artemis.core.paging.impl with parameters of type SimpleStringModifierConstructorDescriptionPage(SimpleString storeName, StorageManager storageManager, SequentialFileFactory factory, SequentialFile file, long pageId) PagingManagerImpl(PagingStoreFactory pagingSPI, HierarchicalRepository<AddressSettings> addressSettingsRepository, long maxSize, long maxMessages, SimpleString managementAddress, ActiveMQServer server) PagingManagerImpl(PagingStoreFactory pagingSPI, HierarchicalRepository<AddressSettings> addressSettingsRepository, SimpleString managementAddress) PagingStoreImpl(SimpleString address, ScheduledExecutorService scheduledExecutor, long syncTimeout, PagingManager pagingManager, StorageManager storageManager, SequentialFileFactory fileFactory, PagingStoreFactory storeFactory, SimpleString storeName, AddressSettings addressSettings, ArtemisExecutor executor, boolean syncNonTransactional) -
Uses of SimpleString in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence that return SimpleStringModifier and TypeMethodDescriptionstatic SimpleStringCoreMessageObjectPools.cachedAddressSimpleString(String address, CoreMessageObjectPools coreMessageObjectPools) GroupingInfo.getClusterName()GroupingInfo.getGroupId()AddressBindingInfo.getName()Methods in org.apache.activemq.artemis.core.persistence with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidStorageManager.deleteAddressSetting(SimpleString addressMatch) voidStorageManager.deleteSecuritySetting(SimpleString addressMatch) voidStorageManager.pageClosed(SimpleString address, long pageNumber) voidStorageManager.pageDeleted(SimpleString address, long pageNumber) voidStorageManager.pageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean storageUp, boolean originallyReplicated) StorageManager.recoverAddressSettings(SimpleString address) voidStorageManager.storeDuplicateID(SimpleString address, byte[] duplID, long recordID) voidStorageManager.storeDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID) voidStorageManager.updateDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID) -
Uses of SimpleString in org.apache.activemq.artemis.core.persistence.config
Fields in org.apache.activemq.artemis.core.persistence.config declared as SimpleStringModifier and TypeFieldDescriptionprotected SimpleStringAbstractPersistedAddressSetting.addressMatchMethods in org.apache.activemq.artemis.core.persistence.config that return SimpleStringModifier and TypeMethodDescriptionAbstractPersistedAddressSetting.getAddressMatch()PersistedSecuritySetting.getAddressMatch()Methods in org.apache.activemq.artemis.core.persistence.config with parameters of type SimpleStringModifier and TypeMethodDescriptionAbstractPersistedAddressSetting.setAddressMatch(SimpleString addressMatch) Constructors in org.apache.activemq.artemis.core.persistence.config with parameters of type SimpleStringModifierConstructorDescriptionAbstractPersistedAddressSetting(SimpleString addressMatch, AddressSettings setting) PersistedAddressSettingJSON(SimpleString addressMatch, AddressSettings setting, String jsonSetting) PersistedAddressSettingJSON(SimpleString addressMatch, AddressSettings setting, SimpleString jsonSetting) -
Uses of SimpleString in org.apache.activemq.artemis.core.persistence.impl.journal
Fields in org.apache.activemq.artemis.core.persistence.impl.journal with type parameters of type SimpleStringModifier and TypeFieldDescriptionprotected final Map<SimpleString,AbstractPersistedAddressSetting> AbstractJournalStorageManager.mapPersistedAddressSettingsprotected final Map<SimpleString,PersistedSecuritySetting> AbstractJournalStorageManager.mapPersistedSecuritySettingsMethods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidAbstractJournalStorageManager.deleteAddressSetting(SimpleString addressMatch) voidAbstractJournalStorageManager.deleteSecuritySetting(SimpleString addressMatch) voidJournalStorageManager.pageClosed(SimpleString storeName, long pageNumber) voidJournalStorageManager.pageDeleted(SimpleString storeName, long pageNumber) voidJournalStorageManager.pageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean storageUp, boolean originallyReplicated) AbstractJournalStorageManager.recoverAddressSettings(SimpleString address) voidLargeServerMessageImpl.referenceOriginalMessage(Message original, SimpleString originalQueue) voidAbstractJournalStorageManager.storeDuplicateID(SimpleString address, byte[] duplID, long recordID) voidAbstractJournalStorageManager.storeDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID) voidAbstractJournalStorageManager.updateDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID) -
Uses of SimpleString in org.apache.activemq.artemis.core.persistence.impl.journal.codec
Fields in org.apache.activemq.artemis.core.persistence.impl.journal.codec declared as SimpleStringModifier and TypeFieldDescriptionDuplicateIDEncoding.addressGroupingEncoding.clusterNameGroupingEncoding.groupIdMethods in org.apache.activemq.artemis.core.persistence.impl.journal.codec that return SimpleStringModifier and TypeMethodDescriptionGroupingEncoding.getClusterName()GroupingEncoding.getGroupId()PersistentAddressBindingEncoding.getName()Constructors in org.apache.activemq.artemis.core.persistence.impl.journal.codec with parameters of type SimpleStringModifierConstructorDescriptionDuplicateIDEncoding(SimpleString address, byte[] duplID) GroupingEncoding(long id, SimpleString groupId, SimpleString clusterName) PersistentAddressBindingEncoding(SimpleString name, EnumSet<RoutingType> routingTypes, boolean autoCreated, boolean internal) -
Uses of SimpleString in org.apache.activemq.artemis.core.persistence.impl.nullpm
Methods in org.apache.activemq.artemis.core.persistence.impl.nullpm with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidNullStorageManager.deleteAddressSetting(SimpleString addressMatch) voidNullStorageManager.deleteSecuritySetting(SimpleString addressMatch) voidNullStorageManager.pageClosed(SimpleString storeName, long pageNumber) voidNullStorageManager.pageDeleted(SimpleString storeName, long pageNumber) voidNullStorageManager.pageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean lineup, boolean originallyReplicated) NullStorageManager.recoverAddressSettings(SimpleString address) voidNullStorageManager.storeDuplicateID(SimpleString address, byte[] duplID, long recordID) voidNullStorageManager.storeDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID) voidNullStorageManager.updateDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID) -
Uses of SimpleString in org.apache.activemq.artemis.core.postoffice
Methods in org.apache.activemq.artemis.core.postoffice that return SimpleStringModifier and TypeMethodDescriptionAddress.getAddress()Binding.getAddress()QueueInfo.getAddress()Address.getAddressParts()Binding.getClusterName()QueueInfo.getClusterName()QueueInfo.getFilterString()AddressManager.getMatchingQueue(SimpleString address, RoutingType routingType) AddressManager.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) PostOffice.getMatchingQueue(SimpleString address, RoutingType routingType) PostOffice.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) Bindings.getName()Binding.getRoutingName()QueueInfo.getRoutingName()Binding.getUniqueName()Methods in org.apache.activemq.artemis.core.postoffice that return types with arguments of type SimpleStringModifier and TypeMethodDescriptionAddressManager.getAddresses()PostOffice.getAddresses()QueueInfo.getFilterStrings()Methods in org.apache.activemq.artemis.core.postoffice with parameters of type SimpleStringModifier and TypeMethodDescriptionBindingsFactory.createBindings(SimpleString address) AddressManager.getAddressInfo(SimpleString address) PostOffice.getAddressInfo(SimpleString address) AddressManager.getBinding(SimpleString queueName) PostOffice.getBinding(SimpleString uniqueName) PostOffice.getBindingsForAddress(SimpleString address) Differently to lookupBindings, this will always create a new element on the Queue if non-existentAddressManager.getBindingsForRoutingAddress(SimpleString address) AddressManager.getDirectBindings(SimpleString address) PostOffice.getDirectBindings(SimpleString address) PostOffice.getDuplicateIDCache(SimpleString address) PostOffice.getDuplicateIDCache(SimpleString address, int idCacheSize) AddressManager.getExistingBindingsForRoutingAddress(SimpleString address) AddressManager.getMatchingBindings(SimpleString address) PostOffice.getMatchingBindings(SimpleString address) AddressManager.getMatchingQueue(SimpleString address, RoutingType routingType) AddressManager.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) PostOffice.getMatchingQueue(SimpleString address, RoutingType routingType) PostOffice.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) default booleanBindingsFactory.isAddressBound(SimpleString address) booleanPostOffice.isAddressBound(SimpleString address) PostOffice.listQueuesForAddress(SimpleString address) PostOffice.lookupBindingsForAddress(SimpleString address) It will lookup the Binding without creating an item on the Queue if non-existentbooleanQueueInfo.matchesAddress(SimpleString address) AddressManager.removeAddressInfo(SimpleString address) PostOffice.removeAddressInfo(SimpleString address) PostOffice.removeAddressInfo(SimpleString address, boolean force) AddressManager.removeBinding(SimpleString uniqueName, Transaction tx) This will use a Transaction as we need to confirm the queue was removedPostOffice.removeBinding(SimpleString uniqueName, Transaction tx, boolean deleteData) Bindings.removeBindingByUniqueName(SimpleString uniqueName) voidPostOffice.sendQueueInfoToQueue(SimpleString queueName, SimpleString address) AddressManager.updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes) Update the specifiedAddressInfoPostOffice.updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes) PostOffice.updateQueue(SimpleString name, RoutingType routingType, Filter filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, SimpleString user, Boolean configurationManaged) Deprecated.PostOffice.updateQueue(SimpleString name, RoutingType routingType, Filter filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, SimpleString user, Boolean configurationManaged, Long ringSize) Deprecated.Method parameters in org.apache.activemq.artemis.core.postoffice with type arguments of type SimpleStringModifier and TypeMethodDescriptionvoidQueueInfo.setFilterStrings(List<SimpleString> filterStrings) Constructors in org.apache.activemq.artemis.core.postoffice with parameters of type SimpleStringModifierConstructorDescriptionQueueInfo(SimpleString routingName, SimpleString clusterName, SimpleString address, SimpleString filterString, long id, int distance) -
Uses of SimpleString in org.apache.activemq.artemis.core.postoffice.impl
Fields in org.apache.activemq.artemis.core.postoffice.impl declared as SimpleStringModifier and TypeFieldDescriptionstatic final SimpleStringPostOfficeImpl.BRIDGE_CACHE_STRstatic final SimpleStringPostOfficeImpl.HDR_RESET_QUEUE_DATAstatic final SimpleStringPostOfficeImpl.HDR_RESET_QUEUE_DATA_COMPLETEFields in org.apache.activemq.artemis.core.postoffice.impl with type parameters of type SimpleStringModifier and TypeFieldDescriptionprotected final ConcurrentMap<SimpleString,Bindings> SimpleAddressManager.mappingsMethods in org.apache.activemq.artemis.core.postoffice.impl that return SimpleStringModifier and TypeMethodDescriptionAddressImpl.getAddress()DivertBinding.getAddress()LocalQueueBinding.getAddress()AddressImpl.getAddressParts()DivertBinding.getClusterName()LocalQueueBinding.getClusterName()PostOfficeImpl.getMatchingQueue(SimpleString address, RoutingType routingType) PostOfficeImpl.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) SimpleAddressManager.getMatchingQueue(SimpleString address, RoutingType routingType) SimpleAddressManager.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) BindingsImpl.getName()DivertBinding.getRoutingName()LocalQueueBinding.getRoutingName()DivertBinding.getUniqueName()LocalQueueBinding.getUniqueName()Methods in org.apache.activemq.artemis.core.postoffice.impl that return types with arguments of type SimpleStringModifier and TypeMethodDescriptionPostOfficeImpl.getAddresses()SimpleAddressManager.getAddresses()PostOfficeImpl.getDuplicateIDCaches()BindingsImpl.getRoutingNameBindingMap()debug method: used just for tests!!Methods in org.apache.activemq.artemis.core.postoffice.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionprotected booleanSimpleAddressManager.addMappingInternal(SimpleString address, Binding binding) protected BindingsSimpleAddressManager.addMappingsInternal(SimpleString address, Collection<Binding> newBindings) protected voidSimpleAddressManager.bindingsEmpty(SimpleString realAddress, Bindings bindings) protected voidWildcardAddressManager.bindingsEmpty(SimpleString realAddress, Bindings bindings) PostOfficeImpl.createBindings(SimpleString address) PostOfficeImpl.getAddressInfo(SimpleString addressName) SimpleAddressManager.getAddressInfo(SimpleString addressName) PostOfficeImpl.getBinding(SimpleString name) SimpleAddressManager.getBinding(SimpleString bindableName) PostOfficeImpl.getBindingsForAddress(SimpleString address) SimpleAddressManager.getBindingsForRoutingAddress(SimpleString address) WildcardAddressManager.getBindingsForRoutingAddress(SimpleString address) PostOfficeImpl.getDirectBindings(SimpleString address) SimpleAddressManager.getDirectBindings(SimpleString address) PostOfficeImpl.getDuplicateIDCache(SimpleString address) PostOfficeImpl.getDuplicateIDCache(SimpleString address, int cacheSizeToUse) SimpleAddressManager.getExistingBindingsForRoutingAddress(SimpleString address) PostOfficeImpl.getMatchingBindings(SimpleString address) SimpleAddressManager.getMatchingBindings(SimpleString address) PostOfficeImpl.getMatchingQueue(SimpleString address, RoutingType routingType) PostOfficeImpl.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) SimpleAddressManager.getMatchingQueue(SimpleString address, RoutingType routingType) SimpleAddressManager.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) String[]AddressMap.getPaths(SimpleString address) static DuplicateIDCacheDuplicateIDCaches.inMemory(SimpleString address, int size) booleanPostOfficeImpl.isAddressBound(SimpleString address) PostOfficeImpl.listQueuesForAddress(SimpleString address) PostOfficeImpl.lookupBindingsForAddress(SimpleString address) static DuplicateIDCacheDuplicateIDCaches.persistent(SimpleString address, int size, StorageManager storageManager) voidAddressMap.put(SimpleString key, T value) voidAddressMap.remove(SimpleString key, T value) PostOfficeImpl.removeAddressInfo(SimpleString address) PostOfficeImpl.removeAddressInfo(SimpleString address, boolean force) SimpleAddressManager.removeAddressInfo(SimpleString address) PostOfficeImpl.removeBinding(SimpleString uniqueName, Transaction tx, boolean deleteData) SimpleAddressManager.removeBinding(SimpleString uniqueName, Transaction tx) WildcardAddressManager.removeBinding(SimpleString uniqueName, Transaction tx) BindingsImpl.removeBindingByUniqueName(SimpleString bindingUniqueName) protected voidSimpleAddressManager.removeBindingInternal(SimpleString address, SimpleString bindableName) voidPostOfficeImpl.sendQueueInfoToQueue(SimpleString queueName, SimpleString address) voidBindingsImpl.unproposed(SimpleString groupID) voidDivertBinding.unproposed(SimpleString groupID) voidLocalQueueBinding.unproposed(SimpleString groupID) PostOfficeImpl.updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes) SimpleAddressManager.updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes) PostOfficeImpl.updateQueue(SimpleString name, RoutingType routingType, Filter filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, SimpleString user, Boolean configurationManaged) Deprecated.PostOfficeImpl.updateQueue(SimpleString name, RoutingType routingType, Filter filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, SimpleString user, Boolean configurationManaged, Long ringSize) Deprecated.voidAddressMap.visitMatching(SimpleString wildcardAddress, AddressMapVisitor<T> collector) voidAddressMap.visitMatchingWildcards(SimpleString address, AddressMapVisitor<T> collector) Constructors in org.apache.activemq.artemis.core.postoffice.impl with parameters of type SimpleStringModifierConstructorDescriptionAddressImpl(SimpleString address) AddressImpl(SimpleString address, WildcardConfiguration wildcardConfiguration) BindingsImpl(SimpleString name, GroupingHandler groupingHandler, StorageManager storageManager) DivertBinding(long id, SimpleString address, Divert divert) LocalQueueBinding(SimpleString address, Queue queue, SimpleString nodeID) -
Uses of SimpleString in org.apache.activemq.artemis.core.protocol.core.impl
Fields in org.apache.activemq.artemis.core.protocol.core.impl declared as SimpleStringModifier and TypeFieldDescriptionstatic final SimpleStringPacketImpl.OLD_QUEUE_PREFIXstatic final SimpleStringPacketImpl.OLD_TEMP_QUEUE_PREFIXstatic final SimpleStringPacketImpl.OLD_TEMP_TOPIC_PREFIXstatic final SimpleStringPacketImpl.OLD_TOPIC_PREFIXMethods in org.apache.activemq.artemis.core.protocol.core.impl that return SimpleStringMethods in org.apache.activemq.artemis.core.protocol.core.impl that return types with arguments of type SimpleStringMethods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionActiveMQSessionContext.addressQuery(SimpleString address) PacketImpl.convertName(SimpleString name) voidActiveMQSessionContext.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) voidActiveMQSessionContext.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated) ActiveMQSessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout) voidActiveMQSessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated) Deprecated.voidActiveMQSessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated, Boolean exclusive, Boolean lastValue) Deprecated.voidActiveMQSessionContext.createQueue(SimpleString address, SimpleString queueName, boolean temp, boolean autoCreated, QueueAttributes queueAttributes) Deprecated.voidActiveMQSessionContext.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, boolean autoCreated) Deprecated.voidActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.voidActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable) Deprecated.voidActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable) Deprecated.voidActiveMQSessionContext.deleteQueue(SimpleString queueName) voidRemotingConnectionImpl.killMessage(SimpleString nodeID) voidActiveMQSessionContext.linkFlowControl(SimpleString address, ClientProducerCredits clientProducerCredits) ActiveMQSessionContext.queueQuery(SimpleString queueName) voidActiveMQSessionContext.sendFullMessage(ICoreMessage msgI, boolean sendBlocking, SendAcknowledgementHandler handler, SimpleString defaultAddress, int senderID) voidCoreSessionCallback.sendProducerCreditsFailMessage(int credits, SimpleString address) voidActiveMQSessionContext.sendProducerCreditsMessage(int credits, SimpleString address) voidCoreSessionCallback.sendProducerCreditsMessage(int credits, SimpleString address) Constructors in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type SimpleStringModifierConstructorDescriptionRemotingConnectionImpl(PacketDecoder packetDecoder, Connection transportConnection, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, SimpleString nodeID, Executor connectionExecutor) Create a server side connection -
Uses of SimpleString in org.apache.activemq.artemis.core.protocol.core.impl.wireformat
Fields in org.apache.activemq.artemis.core.protocol.core.impl.wireformat declared as SimpleStringModifier and TypeFieldDescriptionprotected SimpleStringCreateProducerMessage.addressprotected SimpleStringCreateQueueMessage.addressprotected SimpleStringCreateSharedQueueMessage.addressprotected SimpleStringQueueAbstractPacket.addressprotected SimpleStringReplicationPageWriteMessage.addressprotected SimpleStringSessionQueueQueryResponseMessage.addressprotected SimpleStringSessionBindingQueryResponseMessage_V4.defaultLastValueKeyprotected SimpleStringCreateQueueMessage.filterStringprotected SimpleStringCreateSharedQueueMessage.filterStringprotected SimpleStringSessionQueueQueryResponseMessage.filterStringprotected SimpleStringSessionQueueQueryResponseMessage_V3.groupFirstKeyprotected SimpleStringSessionQueueQueryResponseMessage_V3.lastValueKeyprotected SimpleStringSessionQueueQueryResponseMessage.nameprotected SimpleStringDisconnectMessage.nodeIDprotected SimpleStringCreateQueueMessage.queueNameprotected SimpleStringCreateSharedQueueMessage.queueNameprotected SimpleStringQueueAbstractPacket.queueNameFields in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with type parameters of type SimpleStringModifier and TypeFieldDescriptionprotected List<SimpleString>SessionBindingQueryResponseMessage.queueNamesMethods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return SimpleStringModifier and TypeMethodDescriptionCreateAddressMessage.getAddress()CreateProducerMessage.getAddress()CreateQueueMessage.getAddress()CreateSharedQueueMessage.getAddress()QueueAbstractPacket.getAddress()ReplicationPageWriteMessage.getAddress()SessionProducerCreditsFailMessage.getAddress()SessionProducerCreditsMessage.getAddress()SessionQueueQueryResponseMessage.getAddress()SessionRequestProducerCreditsMessage.getAddress()SessionBindingQueryResponseMessage_V4.getDefaultLastValueKey()CreateQueueMessage.getFilterString()CreateSharedQueueMessage.getFilterString()SessionCreateConsumerMessage.getFilterString()SessionQueueQueryResponseMessage.getFilterString()CreateQueueMessage_V2.getGroupFirstKey()CreateSharedQueueMessage_V2.getGroupFirstKey()SessionQueueQueryResponseMessage_V3.getGroupFirstKey()QuorumVoteMessage.getHandler()QuorumVoteReplyMessage.getHandler()CreateQueueMessage_V2.getLastValueKey()CreateSharedQueueMessage_V2.getLastValueKey()SessionQueueQueryResponseMessage_V3.getLastValueKey()SessionQueueQueryResponseMessage.getName()BackupRequestMessage.getNodeID()DisconnectConsumerWithKillMessage.getNodeID()DisconnectMessage.getNodeID()static SimpleStringQueueAbstractPacket.getOldPrefixedAddress(SimpleString address, RoutingType routingType) ReplicationSyncFileMessage.getPageStore()CreateQueueMessage.getQueueName()CreateSharedQueueMessage.getQueueName()QueueAbstractPacket.getQueueName()SessionDeleteQueueMessage.getQueueName()ScaleDownAnnounceMessage.getScaledDownNodeId()DisconnectMessage_V2.getScaleDownNodeID()ReplicationPageEventMessage.getStoreName()ScaleDownAnnounceMessage.getTargetNodeId()DisconnectMessage_V3.getTargetNodeID()Methods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return types with arguments of type SimpleStringModifier and TypeMethodDescriptionfinal List<SimpleString>QueueAbstractPacket.convertQueueNames(int clientVersion, List<SimpleString> queueNames) It converts the givenqueueNamesusing the JMS prefix found onQueueAbstractPacket.addresswhenclientVersion <PacketImpl.ADDRESSING_CHANGE_VERSION.SessionBindingQueryResponseMessage.getQueueNames()Methods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type SimpleStringModifier and TypeMethodDescriptionstatic SimpleStringQueueAbstractPacket.getOldPrefixedAddress(SimpleString address, RoutingType routingType) voidCreateAddressMessage.setAddress(SimpleString address) voidCreateProducerMessage.setAddress(SimpleString address) voidCreateQueueMessage.setAddress(SimpleString address) voidCreateSharedQueueMessage.setAddress(SimpleString address) voidCreateQueueMessage.setFilterString(SimpleString filterString) voidCreateSharedQueueMessage.setFilterString(SimpleString filterString) voidSessionCreateConsumerMessage.setFilterString(SimpleString filterString) voidCreateSharedQueueMessage_V2.setGroupBuckets(SimpleString groupFirstKey) voidCreateQueueMessage_V2.setGroupFirstKey(SimpleString groupFirstKey) voidSessionQueueQueryResponseMessage_V3.setGroupFirstKey(SimpleString groupFirstKey) voidQuorumVoteMessage.setHandler(SimpleString handler) voidCreateQueueMessage_V2.setLastValueKey(SimpleString lastValueKey) voidCreateSharedQueueMessage_V2.setLastValueKey(SimpleString lastValueKey) voidSessionQueueQueryResponseMessage_V3.setLastValueKey(SimpleString lastValueKey) voidCreateQueueMessage.setQueueName(SimpleString queueName) voidCreateSharedQueueMessage.setQueueName(SimpleString queueName) voidSessionCreateConsumerMessage.setQueueName(SimpleString queueName) Method parameters in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with type arguments of type SimpleStringModifier and TypeMethodDescriptionfinal List<SimpleString>QueueAbstractPacket.convertQueueNames(int clientVersion, List<SimpleString> queueNames) It converts the givenqueueNamesusing the JMS prefix found onQueueAbstractPacket.addresswhenclientVersion <PacketImpl.ADDRESSING_CHANGE_VERSION.Constructors in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type SimpleStringModifierConstructorDescriptionBackupRequestMessage(int backupSize, SimpleString nodeID) CreateAddressMessage(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated, boolean requiresResponse) CreateProducerMessage(int id, SimpleString address) CreateQueueMessage(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary, boolean requiresResponse) CreateQueueMessage_V2(SimpleString address, SimpleString queueName, boolean temporary, boolean autoCreated, boolean requiresResponse, QueueAttributes queueAttributes) Deprecated.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 groupRebalance, Boolean groupRebalancePauseDispatch, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, Long ringSize, Boolean enabled) CreateSharedQueueMessage(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean requiresResponse) CreateSharedQueueMessage_V2(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Boolean groupRebalancePauseDispatch, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, Long ringSize, Boolean enabled, boolean requiresResponse) DisconnectMessage(SimpleString nodeID) DisconnectMessage_V2(SimpleString nodeID, String scaleDownNodeID) DisconnectMessage_V3(SimpleString nodeID, DisconnectReason reason, SimpleString targetNodeID, TransportConfiguration targetConnector) QuorumVoteMessage(SimpleString handler, Vote vote) QuorumVoteReplyMessage(SimpleString handler, Vote vote) ReplicationPageEventMessage(SimpleString storeName, long pageNumber, boolean isDelete, boolean useLong) ReplicationPageWriteMessage(PagedMessage pagedMessage, long pageNumber, boolean useLong, SimpleString address) ReplicationSyncFileMessage(AbstractJournalStorageManager.JournalContent content, SimpleString storeName, long id, int size, io.netty.buffer.ByteBuf buffer) ScaleDownAnnounceMessage(SimpleString targetNodeId, SimpleString scaledDownNodeId) SessionBindingQueryMessage(SimpleString address) SessionBindingQueryResponseMessage_V4(boolean exists, List<SimpleString> queueNames, boolean autoCreateQueues, boolean autoCreateAddresses, boolean defaultPurgeOnNoConsumers, int defaultMaxConsumers, Boolean defaultExclusive, Boolean defaultLastValue, SimpleString defaultLastValueKey, Boolean defaultNonDestructive, Integer defaultConsumersBeforeDispatch, Long defaultDelayBeforeDispatch) SessionBindingQueryResponseMessage_V5(boolean exists, List<SimpleString> queueNames, boolean autoCreateQueues, boolean autoCreateAddresses, boolean defaultPurgeOnNoConsumers, int defaultMaxConsumers, Boolean defaultExclusive, Boolean defaultLastValue, SimpleString defaultLastValueKey, Boolean defaultNonDestructive, Integer defaultConsumersBeforeDispatch, Long defaultDelayBeforeDispatch, boolean supportsMulticast, boolean supportsAnycast) SessionCreateConsumerMessage(long id, SimpleString queueName, SimpleString filterString, int priority, 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 parameters in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with type arguments of type SimpleStringModifierConstructorDescriptionSessionBindingQueryResponseMessage(boolean exists, List<SimpleString> queueNames) 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, SimpleString defaultLastValueKey, Boolean defaultNonDestructive, Integer defaultConsumersBeforeDispatch, Long defaultDelayBeforeDispatch) SessionBindingQueryResponseMessage_V5(boolean exists, List<SimpleString> queueNames, boolean autoCreateQueues, boolean autoCreateAddresses, boolean defaultPurgeOnNoConsumers, int defaultMaxConsumers, Boolean defaultExclusive, Boolean defaultLastValue, SimpleString defaultLastValueKey, Boolean defaultNonDestructive, Integer defaultConsumersBeforeDispatch, Long defaultDelayBeforeDispatch, boolean supportsMulticast, boolean supportsAnycast) -
Uses of SimpleString in org.apache.activemq.artemis.core.protocol.hornetq.client
Methods in org.apache.activemq.artemis.core.protocol.hornetq.client with parameters of type SimpleStringModifier and TypeMethodDescriptionHornetQClientSessionContext.addressQuery(SimpleString address) HornetQClientSessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout) HornetQClientSessionContext.queueQuery(SimpleString queueName) -
Uses of SimpleString in org.apache.activemq.artemis.core.replication
Methods in org.apache.activemq.artemis.core.replication that return types with arguments of type SimpleStringMethods in org.apache.activemq.artemis.core.replication with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidReplicationManager.pageClosed(SimpleString storeName, long pageNumber) voidReplicationManager.pageDeleted(SimpleString storeName, long pageNumber) voidReplicationManager.pageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean lineup) voidReplicationManager.syncPages(SequentialFile file, long id, SimpleString queueName) -
Uses of SimpleString in org.apache.activemq.artemis.core.security
Methods in org.apache.activemq.artemis.core.security with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidSecurityStore.check(SimpleString address, SimpleString queue, CheckType checkType, SecurityAuth session) voidSecurityStore.check(SimpleString address, CheckType checkType, SecurityAuth session) -
Uses of SimpleString in org.apache.activemq.artemis.core.security.impl
Methods in org.apache.activemq.artemis.core.security.impl that return types with arguments of type SimpleStringModifier and TypeMethodDescriptioncom.github.benmanes.caffeine.cache.Cache<String,ConcurrentHashSet<SimpleString>> SecurityStoreImpl.getAuthorizationCache()Methods in org.apache.activemq.artemis.core.security.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidSecurityStoreImpl.check(SimpleString address, SimpleString queue, CheckType checkType, SecurityAuth session) voidSecurityStoreImpl.check(SimpleString address, CheckType checkType, SecurityAuth session) -
Uses of SimpleString in org.apache.activemq.artemis.core.server
Methods in org.apache.activemq.artemis.core.server that return SimpleStringModifier and TypeMethodDescriptionQueueConfig.address()Deprecated.Divert.getAddress()Queue.getAddress()QueueQueryResult.getAddress()RoutingContext.getAddress()RoutingContext.getAddress(Message message) Queue.getDeadLetterAddress()BindingQueryResult.getDefaultLastValueKey()Queue.getExpiryAddress()ConsumerInfo.getFilterString()QueueQueryResult.getFilterString()Divert.getForwardAddress()Queue.getGroupFirstKey()QueueConfig.getGroupFirstKey()Deprecated.QueueQueryResult.getGroupFirstKey()Queue.getLastValueKey()QueueQueryResult.getLastValueKey()MessageReference.getLastValueProperty()ServerSession.getMatchingQueue(SimpleString address, RoutingType routingType) ServerSession.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) AddressQueryResult.getName()Queue.getName()QueueQueryResult.getName()NodeManager.getNodeId()ActiveMQServer.getNodeID()ServerSession.getPrefix(SimpleString address) Get the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.RoutingContext.getPreviousAddress()ConsumerInfo.getQueueAddress()Returns address of the queue that is being consumed.ConsumerInfo.getQueueName()Returns name of the queue that is being consumed.QueueManager.getQueueName()TransientQueueManager.getQueueName()Divert.getRoutingName()Divert.getUniqueName()Queue.getUser()QueueConfig.lastValueKey()Deprecated.QueueConfig.name()Deprecated.abstract SimpleStringNodeManager.readNodeId()ServerSession.removePrefix(SimpleString address) Strip the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.QueueConfig.user()Deprecated.Methods in org.apache.activemq.artemis.core.server that return types with arguments of type SimpleStringModifier and TypeMethodDescriptionServerSession.getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes) Get the canonical (i.e. non-prefixed) address and the corresponding routing-type.RoutingContext.getContexListing()Queue.getGroups()BindingQueryResult.getQueueNames()Methods in org.apache.activemq.artemis.core.server with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidActiveMQServerLogger_impl.activatingReplica(SimpleString nodeID) voidActiveMQServerLogger.activatingReplica(SimpleString nodeID) voidRoutingContext.addQueue(SimpleString address, Queue queue) voidRoutingContext.addQueueWithAck(SimpleString address, Queue queue) ActiveMQMessageBundle_impl.addressAlreadyExists(SimpleString address) ActiveMQMessageBundle.addressAlreadyExists(SimpleString address) ActiveMQMessageBundle_impl.addressDoesNotExist(SimpleString address) ActiveMQMessageBundle.addressDoesNotExist(SimpleString address) ActiveMQMessageBundle_impl.addressHasBindings(SimpleString address) ActiveMQMessageBundle.addressHasBindings(SimpleString address) ActiveMQServer.addressQuery(SimpleString name) voidActiveMQServerLogger_impl.AddressSettingsNoDLA(SimpleString name) voidActiveMQServerLogger.AddressSettingsNoDLA(SimpleString name) voidActiveMQServerLogger_impl.AddressSettingsNoExpiryAddress(SimpleString name) voidActiveMQServerLogger.AddressSettingsNoExpiryAddress(SimpleString name) voidActiveMQServer.addScaledDownNode(SimpleString scaledDownNodeId) voidActiveMQServer.autoRemoveAddressInfo(SimpleString address, SecurityAuth auth) Remove anAddressInfofrom the broker.voidActiveMQServerLogger_impl.backupServerStarted(String version, SimpleString nodeID) voidActiveMQServerLogger.backupServerStarted(String version, SimpleString nodeID) ActiveMQMessageBundle_impl.bindingNotDivert(SimpleString name) ActiveMQMessageBundle.bindingNotDivert(SimpleString name) default BindingQueryResultActiveMQServer.bindingQuery(SimpleString address) ActiveMQServer.bindingQuery(SimpleString address, boolean newFQQN) voidActiveMQServerLogger_impl.blockingDiskFull(SimpleString addressName) voidActiveMQServerLogger.blockingDiskFull(SimpleString addressName) voidActiveMQServerLogger_impl.blockingMessageProduction(SimpleString addressName, String pageInfo) voidActiveMQServerLogger.blockingMessageProduction(SimpleString addressName, String pageInfo) voidActiveMQServerLogger_impl.blockingViaControl(SimpleString addressName) voidActiveMQServerLogger.blockingViaControl(SimpleString addressName) static QueueConfig.BuilderQueueConfig.builderWith(long id, SimpleString name) Deprecated.Returns a newQueueConfig.Builderof a durable, not temporary and autoCreatedQueueConfigwith the givenidandname.static QueueConfig.BuilderQueueConfig.builderWith(long id, SimpleString name, SimpleString address) Deprecated.Returns a newQueueConfig.Builderof a durable, not temporary and autoCreatedQueueConfigwith the givenid,nameandaddress.voidPostQueueCreationCallback.callback(SimpleString queueName) voidPostQueueDeletionCallback.callback(SimpleString address, SimpleString queueName) voidActiveMQServer.callPostQueueCreationCallbacks(SimpleString queueName) voidActiveMQServer.callPostQueueDeletionCallbacks(SimpleString address, SimpleString queueName) ActiveMQMessageBundle_impl.cannotCreateConsumerOnClosedSession(SimpleString queueName) ActiveMQMessageBundle.cannotCreateConsumerOnClosedSession(SimpleString queueName) ActiveMQMessageBundle_impl.cannotDeleteQueueWithConsumers(SimpleString name, SimpleString queueName, String s) ActiveMQMessageBundle.cannotDeleteQueueWithConsumers(SimpleString name, SimpleString queueName, String s) ActiveMQMessageBundle_impl.cannotDeleteQueueWithMessages(SimpleString name, SimpleString queueName, long messageCount) ActiveMQMessageBundle.cannotDeleteQueueWithMessages(SimpleString name, SimpleString queueName, long messageCount) ActiveMQMessageBundle_impl.consumerNoReference(Long id, Long messageID, SimpleString name) ActiveMQMessageBundle.consumerNoReference(Long id, Long messageID, SimpleString name) booleanQueue.copyReference(long messageID, SimpleString queue, Binding binding) ServerSession.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) ServerSession.createAddress(SimpleString address, RoutingType routingType, boolean autoCreated) ServerSession.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly) ServerSession.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage, Integer credits) ServerSession.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly, boolean supportLargeMessage, Integer credits) ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary) Deprecated.ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress) Deprecated.ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize) Deprecated.ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString user, SimpleString filterString, boolean durable, boolean temporary) Deprecated.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) Deprecated.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) Deprecated.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 groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.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 groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.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 groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize) Deprecated.ActiveMQServer.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress) Deprecated.ActiveMQServer.createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary) Deprecated.ActiveMQServer.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress) Deprecated.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) Deprecated.ActiveMQServer.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.ActiveMQServer.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.ActiveMQServer.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress, Long ringSize) Deprecated.ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable) Deprecated.ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated) Deprecated.ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated) Deprecated.ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreated) Deprecated.ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated) Deprecated.ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated) Deprecated.ServerSession.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated, Long ringSize) Deprecated.ServerSession.createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable) Deprecated.ServerSession.createQueue(AddressInfo address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable) Deprecated.ServerSession.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated) Deprecated.ServerSession.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, Boolean exclusive, Boolean lastValue, boolean autoCreated) Deprecated.voidActiveMQServer.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable) Deprecated.voidActiveMQServer.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean lastValue) Deprecated.voidActiveMQServer.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteTimeout, long autoDeleteMessageCount) Deprecated.voidActiveMQServer.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount) Deprecated.voidServerSession.createSharedQueue(SimpleString address, SimpleString name, boolean durable, SimpleString filterString) Deprecated.voidServerSession.createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, boolean durable, SimpleString filterString) Deprecated.voidServerSession.createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidServerSession.createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount) Deprecated.voidServerSession.createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount) Deprecated.voidServerSession.deleteQueue(SimpleString name) voidServerSession.deleteQueue(SimpleString name, boolean enforceSecurity) ActiveMQServer.deployQueue(SimpleString address, SimpleString queue, SimpleString filter, boolean durable, boolean temporary) Deprecated.voidActiveMQServer.destroyDivert(SimpleString name) voidActiveMQServer.destroyDivert(SimpleString name, boolean deleteFromStorage) voidActiveMQServer.destroyQueue(SimpleString queueName) voidActiveMQServer.destroyQueue(SimpleString queueName, SecurityAuth session) voidActiveMQServer.destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount) voidActiveMQServer.destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers) voidActiveMQServer.destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean forceAutoDeleteAddress) voidActiveMQServer.destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean forceAutoDeleteAddress, boolean checkMessageCount) voidActiveMQServerLogger_impl.divertBindingAlreadyExists(SimpleString bindingName) voidActiveMQServerLogger.divertBindingAlreadyExists(SimpleString bindingName) ServerSession.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, String senderName, boolean noAutoCreateQueue) ServerSession.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, String senderName, boolean noAutoCreateQueue, RoutingContext routingContext) voidActiveMQServerLogger_impl.errorExpiringReferencesNoAddress(SimpleString name) voidActiveMQServerLogger.errorExpiringReferencesNoAddress(SimpleString name) voidActiveMQServerLogger_impl.errorExpiringReferencesNoBindings(SimpleString expiryAddress) voidActiveMQServerLogger.errorExpiringReferencesNoBindings(SimpleString expiryAddress) voidActiveMQServerLogger_impl.errorRemovingAutoCreatedDestination(String destinationType, SimpleString bindingName, Exception e) voidActiveMQServerLogger.errorRemovingAutoCreatedDestination(String destinationType, SimpleString bindingName, Exception e) voidActiveMQServerLogger_impl.errorRemovingTempQueue(SimpleString bindingName, Exception e) voidActiveMQServerLogger.errorRemovingTempQueue(SimpleString bindingName, Exception e) ServerSession.executeAddressQuery(SimpleString name) ServerSession.executeBindingQuery(SimpleString address) ServerSession.executeQueueQuery(SimpleString name) voidActiveMQServerLogger_impl.failedToDealWithObjectProperty(SimpleString property, String exceptionMessage) voidActiveMQServerLogger.failedToDealWithObjectProperty(SimpleString property, String exceptionMessage) voidActiveMQServerLogger_impl.failedToPurgeQueue(SimpleString bindingName, Exception e) voidActiveMQServerLogger.failedToPurgeQueue(SimpleString bindingName, Exception e) voidActiveMQServerLogger_impl.federationBindingsLookupError(SimpleString address, Throwable e) voidActiveMQServerLogger.federationBindingsLookupError(SimpleString address, Throwable e) voidServerMessage.forceAddress(SimpleString address) Deprecated.This will force encoding of the address, and will re-check the buffer.ServerSession.getAddress(SimpleString address) ServerSession.getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes) Get the canonical (i.e. non-prefixed) address and the corresponding routing-type.ActiveMQServer.getAddressInfo(SimpleString address) RoutingContext.getContextListing(SimpleString address) intServerSession.getDefaultConsumerWindowSize(SimpleString address) RoutingContext.getDurableQueues(SimpleString address) ServerSession.getMatchingQueue(SimpleString address, RoutingType routingType) ServerSession.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) RoutingContext.getNonDurableQueues(SimpleString address) ServerSession.getPrefix(SimpleString address) Get the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.ServerSession.getRoutingTypeFromPrefix(SimpleString address, RoutingType defaultRoutingType) QueueConfig.Builder.groupFirstKey(SimpleString groupFirstKey) Deprecated.booleanActiveMQServer.hasScaledDown(SimpleString scaledDownNodeId) voidActiveMQServerLogger_impl.initiatingQuorumVote(SimpleString vote) voidActiveMQServerLogger.initiatingQuorumVote(SimpleString vote) ActiveMQMessageBundle_impl.invalidFilter(SimpleString filter, Throwable e) ActiveMQMessageBundle.invalidFilter(SimpleString filter, Throwable e) voidActiveMQServerLogger_impl.invalidFilter(SimpleString filter) voidActiveMQServerLogger.invalidFilter(SimpleString filter) ActiveMQMessageBundle_impl.invalidQueueName(SimpleString queueName) ActiveMQMessageBundle.invalidQueueName(SimpleString queueName) QueueConfig.Builder.lastValueKey(SimpleString lastValueKey) Deprecated.ActiveMQServer.locateQueue(SimpleString queueName) ActiveMQMessageBundle_impl.maxConsumerLimitReachedForQueue(SimpleString address, SimpleString queueName) ActiveMQMessageBundle.maxConsumerLimitReachedForQueue(SimpleString address, SimpleString queueName) voidActiveMQServerLogger_impl.messageWithDuplicateID(Object duplicateProperty, SimpleString toAddress, SimpleString address, SimpleString simpleString) voidActiveMQServerLogger.messageWithDuplicateID(Object duplicateProperty, SimpleString toAddress, SimpleString address, SimpleString simpleString) booleanQueue.moveReference(long messageID, SimpleString toAddress, Binding binding, boolean rejectDuplicates) intQueue.moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates, int messageCount, Binding binding) intQueue.moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates, Binding binding) intQueue.moveReferences(Filter filter, SimpleString toAddress, Binding binding) ActiveMQMessageBundle_impl.noBindingForDivert(SimpleString name) ActiveMQMessageBundle.noBindingForDivert(SimpleString name) voidActiveMQServerLogger_impl.noBindingsOnDLA(MessageReference ref, SimpleString name) voidActiveMQServerLogger.noBindingsOnDLA(MessageReference ref, SimpleString name) voidActiveMQServerLogger_impl.noDLA(SimpleString address) voidActiveMQServerLogger.noDLA(SimpleString address) voidActiveMQServerLogger_impl.noMatchingBindingsOnDLAWithAutoCreateDLAResources(SimpleString address, String message) voidActiveMQServerLogger.noMatchingBindingsOnDLAWithAutoCreateDLAResources(SimpleString address, String message) voidActiveMQServerLogger_impl.noQueueIdDefined(Message message, Message messageCopy, SimpleString idsHeaderName) voidActiveMQServerLogger.noQueueIdDefined(Message message, Message messageCopy, SimpleString idsHeaderName) ActiveMQMessageBundle_impl.noSuchQueue(SimpleString queueName) ActiveMQMessageBundle.noSuchQueue(SimpleString queueName) voidActiveMQServerLogger_impl.noVoteHandlerConfigured(SimpleString handlerReceived) voidActiveMQServerLogger.noVoteHandlerConfigured(SimpleString handlerReceived) voidActiveMQServerLogger_impl.pageFree(SimpleString address) voidActiveMQServerLogger.pageFree(SimpleString address) voidActiveMQServerLogger_impl.pageFull(SimpleString queue, SimpleString address, Object pageLImitMessage, Object currentValue) voidActiveMQServerLogger.pageFull(SimpleString queue, SimpleString address, Object pageLImitMessage, Object currentValue) voidActiveMQServerLogger_impl.pageFullMaxBytes(SimpleString address, long pages, Long maxPages, Long limitBytes, int bytes) voidActiveMQServerLogger.pageFullMaxBytes(SimpleString address, long pages, Long maxPages, Long limitBytes, int bytes) voidActiveMQServerLogger_impl.pageStoreDropMessages(SimpleString storeName, String sizeInfo) voidActiveMQServerLogger.pageStoreDropMessages(SimpleString storeName, String sizeInfo) voidActiveMQServerLogger_impl.pageStoreStart(SimpleString storeName, String sizeInfo) voidActiveMQServerLogger.pageStoreStart(SimpleString storeName, String sizeInfo) voidActiveMQServerLogger_impl.pageStoreStop(SimpleString storeName, String pageInfo) voidActiveMQServerLogger.pageStoreStop(SimpleString storeName, String pageInfo) voidActiveMQServerLogger_impl.pageStoreTimeout(SimpleString address) voidActiveMQServerLogger.pageStoreTimeout(SimpleString address) voidActiveMQServerLogger_impl.problemCleaningPageAddress(SimpleString address, Throwable e) voidActiveMQServerLogger.problemCleaningPageAddress(SimpleString address, Throwable e) ActiveMQMessageBundle_impl.queueAlreadyExists(SimpleString queueName, SimpleString addressName) ActiveMQMessageBundle.queueAlreadyExists(SimpleString queueName, SimpleString addressName) ActiveMQServer.queueQuery(SimpleString name) ActiveMQMessageBundle_impl.queueSubscriptionBelongsToDifferentAddress(SimpleString queueName) ActiveMQMessageBundle.queueSubscriptionBelongsToDifferentAddress(SimpleString queueName) ActiveMQMessageBundle_impl.queueSubscriptionBelongsToDifferentFilter(SimpleString queueName) ActiveMQMessageBundle.queueSubscriptionBelongsToDifferentFilter(SimpleString queueName) voidActiveMQServerLogger_impl.remoteQueueAlreadyBoundOnClusterConnection(Object messageFlowRecord, SimpleString clusterName) voidActiveMQServerLogger.remoteQueueAlreadyBoundOnClusterConnection(Object messageFlowRecord, SimpleString clusterName) voidActiveMQServer.removeAddressInfo(SimpleString address, SecurityAuth auth) Remove anAddressInfofrom the broker.voidActiveMQServer.removeAddressInfo(SimpleString address, SecurityAuth auth, boolean force) Remove anAddressInfofrom the broker.ServerSession.removePrefix(SimpleString address) Strip the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.voidServerSession.requestProducerCredits(SimpleString address, int credits) voidQueue.resetGroup(SimpleString groupID) voidActiveMQServerLogger_impl.sendingMessageToDLA(MessageReference ref, SimpleString name, SimpleString simpleString) voidActiveMQServerLogger.sendingMessageToDLA(MessageReference ref, SimpleString name, SimpleString simpleString) voidActiveMQServerLogger_impl.sendingMessageToDLAnoDLA(MessageReference ref, SimpleString name) voidActiveMQServerLogger.sendingMessageToDLAnoDLA(MessageReference ref, SimpleString name) voidActiveMQServerLogger_impl.serverStarted(String fullVersion, String name, SimpleString nodeId, String identity) voidActiveMQServerLogger.serverStarted(String fullVersion, String name, SimpleString nodeId, String identity) voidActiveMQServerLogger_impl.serverStopped(String version, SimpleString nodeId, String uptime) voidActiveMQServerLogger.serverStopped(String version, SimpleString nodeId, String uptime) voidQueueQueryResult.setAddress(SimpleString address) voidRoutingContext.setAddress(SimpleString address) voidDivert.setForwardAddress(SimpleString forwardAddress) voidQueue.setGroupFirstKey(SimpleString groupFirstKey) voidQueue.setUser(SimpleString user) voidTempQueueObserver.tempQueueDeleted(SimpleString bindingName) voidActiveMQServerLogger_impl.unableToCreateManagementNotificationAddress(SimpleString addressName, Exception e) voidActiveMQServerLogger.unableToCreateManagementNotificationAddress(SimpleString addressName, Exception e) voidActiveMQServerLogger_impl.unableToDeleteGroupBindings(SimpleString groupId, Exception e) voidActiveMQServerLogger.unableToDeleteGroupBindings(SimpleString groupId, Exception e) voidActiveMQServerLogger_impl.unableToStartBridge(SimpleString name, Exception e) voidActiveMQServerLogger.unableToStartBridge(SimpleString name, Exception e) voidActiveMQServerLogger_impl.unableToStartClusterConnection(SimpleString name, Exception e) voidActiveMQServerLogger.unableToStartClusterConnection(SimpleString name, Exception e) voidActiveMQServerLogger_impl.unableToUndeployAddress(SimpleString addressName, String reason) voidActiveMQServerLogger.unableToUndeployAddress(SimpleString addressName, String reason) voidActiveMQServerLogger_impl.unableToUndeployQueue(SimpleString queueName, String reason) voidActiveMQServerLogger.unableToUndeployQueue(SimpleString queueName, String reason) voidActiveMQServerLogger_impl.unblockingMessageProduction(SimpleString addressName, String sizeInfo) voidActiveMQServerLogger.unblockingMessageProduction(SimpleString addressName, String sizeInfo) voidActiveMQServerLogger_impl.unblockingViaControl(SimpleString addressName) voidActiveMQServerLogger.unblockingViaControl(SimpleString addressName) voidActiveMQServerLogger_impl.undeployAddress(SimpleString addressName) voidActiveMQServerLogger.undeployAddress(SimpleString addressName) voidActiveMQServerLogger_impl.undeployQueue(SimpleString queueName) voidActiveMQServerLogger.undeployQueue(SimpleString queueName) voidQueue.unproposed(SimpleString groupID) booleanActiveMQServer.updateAddressInfo(SimpleString address, Collection<RoutingType> routingTypes) Deprecated.booleanActiveMQServer.updateAddressInfo(SimpleString address, EnumSet<RoutingType> routingTypes) Updates anAddressInfoon the broker with the specified routing types.QueueConfig.Builder.user(SimpleString user) Deprecated.ActiveMQMessageBundle_impl.userNoPermissions(String username, CheckType checkType, SimpleString address) ActiveMQMessageBundle.userNoPermissions(String username, CheckType checkType, SimpleString address) ActiveMQMessageBundle_impl.userNoPermissionsQueue(String username, CheckType checkType, SimpleString queue, SimpleString address) ActiveMQMessageBundle.userNoPermissionsQueue(String username, CheckType checkType, SimpleString queue, SimpleString address) Method parameters in org.apache.activemq.artemis.core.server with type arguments of type SimpleStringModifier and TypeMethodDescriptionActiveMQServer.createInternalSession(String name, int minLargeMessageSize, RemotingConnection remotingConnection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString, RoutingType> prefixes, String securityDomain, boolean isLegacyProducer) This is to be used in places where security is bypassed, like internal sessions, broker connections, etc...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, String securityDomain, String validatedUser, boolean isLegacyProducer) Constructors in org.apache.activemq.artemis.core.server with parameters of type SimpleStringModifierConstructorDescriptionAddressQueryResult(SimpleString name, Set<RoutingType> routingTypes, long id, boolean autoCreated, boolean exists, boolean autoCreateAddresses, boolean defaultPurgeOnNoConsumers, int defaultMaxConsumers) BindingQueryResult(boolean exists, AddressInfo addressInfo, List<SimpleString> queueNames, boolean autoCreateQueues, boolean autoCreateAddresses, boolean defaultPurgeOnNoConsumers, int defaultMaxConsumers, boolean defaultExclusive, boolean defaultLastValue, SimpleString defaultLastValueKey, Boolean defaultNonDestructive, Integer defaultConsumersBeforeDispatch, Long defaultDelayBeforeDispatch) Constructor parameters in org.apache.activemq.artemis.core.server with type arguments of type SimpleStringModifierConstructorDescriptionBindingQueryResult(boolean exists, AddressInfo addressInfo, List<SimpleString> queueNames, boolean autoCreateQueues, boolean autoCreateAddresses, boolean defaultPurgeOnNoConsumers, int defaultMaxConsumers, boolean defaultExclusive, boolean defaultLastValue, SimpleString defaultLastValueKey, Boolean defaultNonDestructive, Integer defaultConsumersBeforeDispatch, Long defaultDelayBeforeDispatch) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.cluster
Methods in org.apache.activemq.artemis.core.server.cluster that return SimpleStringModifier and TypeMethodDescriptionBridge.getForwardingAddress()Bridge.getName()ClusterConnection.getName()ClusterController.getNodeID()Methods in org.apache.activemq.artemis.core.server.cluster that return types with arguments of type SimpleStringMethods in org.apache.activemq.artemis.core.server.cluster with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidClusterController.addClusterConnection(SimpleString name, DiscoveryGroupConfiguration dg, ClusterConnectionConfiguration config, TransportConfiguration connector) add a locator for a cluster connection.voidClusterController.addClusterConnection(SimpleString name, TransportConfiguration[] tcConfigs, ClusterConnectionConfiguration config, TransportConfiguration connector) add a locator for a cluster connection.voidRemoteQueueBinding.addConsumer(SimpleString filterString) voidClusterControl.announceScaleDown(SimpleString targetNodeId, SimpleString scaledDownNodeId) ClusterController.getServerLocator(SimpleString name) voidRemoteQueueBinding.removeConsumer(SimpleString filterString) booleanClusterControl.requestReplicatedBackup(int backupSize, SimpleString nodeID) voidClusterController.setDefaultClusterConnectionName(SimpleString defaultClusterConnection) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.cluster.ha
Methods in org.apache.activemq.artemis.core.server.cluster.ha with parameters of type SimpleStringModifier and TypeMethodDescriptionbooleanColocatedHAManager.activateBackup(int backupSize, String journalDirectory, String bindingsDirectory, String largeMessagesDirectory, String pagingDirectory, SimpleString nodeID) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.cluster.impl
Methods in org.apache.activemq.artemis.core.server.cluster.impl that return SimpleStringModifier and TypeMethodDescriptionRemoteQueueBindingImpl.getAddress()RemoteQueueBindingImpl.getClusterName()BridgeImpl.getForwardingAddress()BridgeImpl.getName()ClusterConnectionImpl.getName()RemoteQueueBindingImpl.getRoutingName()ClusterConnectionImpl.getSfQueueName(String nodeID) RemoteQueueBindingImpl.getUniqueName()Methods in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidRemoteQueueBindingImpl.addConsumer(SimpleString filterString) protected MessageBridgeImpl.beforeForward(Message message, SimpleString forwardingAddress) Hook for processing message before forwardingprotected MessageClusterConnectionBridge.beforeForward(Message message, SimpleString forwardingAddress) protected MessageBridgeImpl.beforeForwardingNoCopy(Message message, SimpleString forwardingAddress) ClusterConnectionBridge already makes a copy of the message.voidRemoteQueueBindingImpl.removeConsumer(SimpleString filterString) voidRemoteQueueBindingImpl.unproposed(SimpleString groupID) Constructors in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type SimpleStringModifierConstructorDescriptionClusterConnectionBridge(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, TransformerConfiguration transformer, boolean useDuplicateDetection, String user, String password, ActiveMQServer server, SimpleString managementAddress, SimpleString managementNotificationAddress, MessageFlowRecord flowRecord, TransportConfiguration connector, String storeAndForwardPrefix, StorageManager storageManager, String clientId) 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, String clientId, int topologyScannerAttempts) 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, String clientId, int topologyScannerAttempts) RemoteQueueBindingImpl(long id, SimpleString address, SimpleString uniqueName, SimpleString routingName, Long remoteQueueID, SimpleString filterString, Queue storeAndForwardQueue, SimpleString bridgeName, int distance, MessageLoadBalancingType messageLoadBalancingType) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.cluster.quorum
Fields in org.apache.activemq.artemis.core.server.cluster.quorum declared as SimpleStringModifier and TypeFieldDescriptionstatic final SimpleStringQuorumVoteServerConnect.OLD_PRIMARY_FAILOVER_VOTEstatic final SimpleStringQuorumVoteServerConnect.PRIMARY_FAILOVER_VOTENOTE: The following String is used to identify the targetNode implementation at other servers.Methods in org.apache.activemq.artemis.core.server.cluster.quorum that return SimpleStringModifier and TypeMethodDescriptionQuorumVote.getName()the name of this quorum vote, used for identifying the correctQuorumVoteHandlerQuorumVote.getOldName()QuorumVoteHandler.getQuorumName()Constructors in org.apache.activemq.artemis.core.server.cluster.quorum with parameters of type SimpleString -
Uses of SimpleString in org.apache.activemq.artemis.core.server.federation
Fields in org.apache.activemq.artemis.core.server.federation declared as SimpleStringMethods in org.apache.activemq.artemis.core.server.federation that return SimpleStringModifier and TypeMethodDescriptionFederatedConsumerKey.getAddress()FederatedConsumerKey.getFilterString()FederatedConsumerKey.getFqqn()AbstractFederationStream.getName()Federation.getName()FederationStream.getName()FederatedConsumerKey.getQueueFilterString()FederatedConsumerKey.getQueueName() -
Uses of SimpleString in org.apache.activemq.artemis.core.server.federation.address
Fields in org.apache.activemq.artemis.core.server.federation.address declared as SimpleStringMethods in org.apache.activemq.artemis.core.server.federation.address that return SimpleStringModifier and TypeMethodDescriptionFederatedAddressConsumerKey.getAddress()FederatedAddressConsumerKey.getFilterString()FederatedAddressConsumerKey.getFqqn()FederatedAddressConsumerKey.getQueueFilterString()FederatedAddressConsumerKey.getQueueName()Methods in org.apache.activemq.artemis.core.server.federation.address with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidFederatedAddress.beforeRemoveBinding(SimpleString uniqueName, Transaction tx, boolean deleteData) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.federation.queue
Methods in org.apache.activemq.artemis.core.server.federation.queue that return SimpleStringModifier and TypeMethodDescriptionFederatedQueueConsumerKey.getAddress()FederatedQueueConsumerKey.getFilterString()FederatedQueueConsumerKey.getFqqn()FederatedQueueConsumerKey.getQueueFilterString()FederatedQueueConsumerKey.getQueueName() -
Uses of SimpleString in org.apache.activemq.artemis.core.server.group
Methods in org.apache.activemq.artemis.core.server.group that return SimpleStringMethods in org.apache.activemq.artemis.core.server.group with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidGroupingHandler.forceRemove(SimpleString groupid, SimpleString clusterName) this will force a removal of the group everywhere with an unproposal (dinstance=0).GroupingHandler.getProposal(SimpleString fullID, boolean touchTime) voidGroupingHandler.remove(SimpleString groupid, SimpleString clusterName) voidGroupingHandler.remove(SimpleString groupid, SimpleString clusterName, int distance) voidUnproposalListener.unproposed(SimpleString groupID) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.group.impl
Fields in org.apache.activemq.artemis.core.server.group.impl declared as SimpleStringMethods in org.apache.activemq.artemis.core.server.group.impl that return SimpleStringModifier and TypeMethodDescriptionGroupingHandlerConfiguration.getAddress()Response.getAlternativeClusterName()Response.getChosenClusterName()GroupBinding.getClusterName()Proposal.getClusterName()Response.getClusterName()GroupBinding.getGroupId()Proposal.getGroupId()Response.getGroupId()GroupingHandlerConfiguration.getName()LocalGroupingHandler.getName()RemoteGroupingHandler.getName()Methods in org.apache.activemq.artemis.core.server.group.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionprotected voidGroupHandlingAbstract.fireUnproposed(SimpleString groupID) voidGroupHandlingAbstract.forceRemove(SimpleString groupid, SimpleString clusterName) LocalGroupingHandler.getProposal(SimpleString fullID, boolean touchTime) RemoteGroupingHandler.getProposal(SimpleString fullID, boolean touchTime) voidLocalGroupingHandler.remove(SimpleString groupid, SimpleString clusterName) voidLocalGroupingHandler.remove(SimpleString groupid, SimpleString clusterName, int distance) voidRemoteGroupingHandler.remove(SimpleString groupid, SimpleString clusterName) voidRemoteGroupingHandler.remove(SimpleString groupid, SimpleString clusterName, int distance) protected voidGroupHandlingAbstract.sendUnproposal(SimpleString groupid, SimpleString clusterName, int distance) GroupingHandlerConfiguration.setAddress(SimpleString address) GroupingHandlerConfiguration.setName(SimpleString name) Constructors in org.apache.activemq.artemis.core.server.group.impl with parameters of type SimpleStringModifierConstructorDescriptionGroupBinding(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(ManagementService managementService, SimpleString name, SimpleString address, long timeout, long groupTimeout) RemoteGroupingHandler(ExecutorFactory executorFactory, ManagementService managementService, SimpleString name, SimpleString address, long timeout, long groupTimeout) Response(SimpleString groupId, SimpleString clusterName) Response(SimpleString groupId, SimpleString clusterName, SimpleString alternativeClusterName) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.impl
Fields in org.apache.activemq.artemis.core.server.impl with type parameters of type SimpleStringModifier and TypeFieldDescriptionprotected final Map<SimpleString,ServerSessionImpl.TempQueueCleanerUpper> ServerSessionImpl.tempQueueCleannerUppersMethods in org.apache.activemq.artemis.core.server.impl that return SimpleStringModifier and TypeMethodDescriptionDivertImpl.getAddress()QueueImpl.getAddress()RoutingContextImpl.getAddress()RoutingContextImpl.getAddress(Message message) QueueImpl.getDeadLetterAddress()QueueImpl.getExpiryAddress()ServerConsumerImpl.getFilterString()DivertImpl.getForwardAddress()QueueImpl.getGroupFirstKey()QueueImpl.getLastValueKey()GroupFirstMessageReference.getLastValueProperty()MessageReferenceImpl.getLastValueProperty()ServerSessionImpl.getMatchingQueue(SimpleString address, RoutingType routingType) ServerSessionImpl.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) AddressInfo.getName()QueueImpl.getName()ActiveMQServerImpl.getNodeID()ServerSessionImpl.getPrefix(SimpleString address) RoutingContextImpl.getPreviousAddress()ServerConsumerImpl.getQueueAddress()QueueManagerImpl.getQueueName()ServerConsumerImpl.getQueueName()TransientQueueManagerImpl.getQueueName()ServerConnectVoteHandler.getQuorumName()DivertImpl.getRoutingName()QueueImpl.getRoutingName()DivertImpl.getUniqueName()QueueImpl.getUniqueName()QueueImpl.getUser()final SimpleStringFileLockNodeManager.readNodeId()InVMNodeManager.readNodeId()ServerSessionImpl.removePrefix(SimpleString address) Methods in org.apache.activemq.artemis.core.server.impl that return types with arguments of type SimpleStringModifier and TypeMethodDescriptionServerSessionImpl.getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes) RoutingContextImpl.getContexListing()QueueImpl.getGroups()LastValueQueue.getLastValueKeys()ServerSessionImpl.getTempQueueCleanUppers()BucketMessageGroups.toMap()MessageGroups.toMap()Methods in org.apache.activemq.artemis.core.server.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidRoutingContextImpl.addQueue(SimpleString address, Queue queue) voidRoutingContextImpl.addQueueWithAck(SimpleString address, Queue queue) ActiveMQServerImpl.addressQuery(SimpleString name) voidActiveMQServerImpl.addScaledDownNode(SimpleString scaledDownNodeId) voidActiveMQServerImpl.autoRemoveAddressInfo(SimpleString address, SecurityAuth auth) ActiveMQServerImpl.bindingQuery(SimpleString address, boolean newFQQN) voidActiveMQServerImpl.callPostQueueCreationCallbacks(SimpleString queueName) voidActiveMQServerImpl.callPostQueueDeletionCallbacks(SimpleString address, SimpleString queueName) booleanQueueImpl.copyReference(long messageID, SimpleString toQueue, Binding binding) AddressInfo.create(SimpleString name, RoutingType routingType) ServerSessionImpl.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) ServerSessionImpl.createAddress(SimpleString address, RoutingType routingType, boolean autoCreated) ServerSessionImpl.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly) ServerSessionImpl.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage, Integer credits) ServerSessionImpl.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly, boolean supportLargeMessage, Integer credits) ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary) Deprecated.ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress) Deprecated.ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize) Deprecated.ActiveMQServerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString user, SimpleString filterString, boolean durable, boolean temporary) Deprecated.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) Deprecated.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 exclusive, boolean lastValue, boolean autoCreateAddress) Deprecated.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 groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.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 groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.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 groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize) Deprecated.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.ActiveMQServerImpl.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary) Deprecated.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 groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, boolean configurationManaged, long ringSize) Deprecated.ActiveMQServerImpl.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress) Deprecated.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) Deprecated.ActiveMQServerImpl.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.ActiveMQServerImpl.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress) Deprecated.ActiveMQServerImpl.createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress, Long ringSize) Deprecated.ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable) Deprecated.ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated) Deprecated.ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated) Deprecated.ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreated) Deprecated.ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated) Deprecated.ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated) Deprecated.ServerSessionImpl.createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated, Long ringSize) Deprecated.ServerSessionImpl.createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable) Deprecated.ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable) Deprecated.ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated) Deprecated.ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreated, long ringSize) Deprecated.ServerSessionImpl.createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, Boolean exclusive, Boolean lastValue, boolean autoCreated) Deprecated.voidActiveMQServerImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable) Deprecated.voidActiveMQServerImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean lastValue) Deprecated.voidActiveMQServerImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount) Deprecated.voidActiveMQServerImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount) Deprecated.voidServerSessionImpl.createSharedQueue(SimpleString address, SimpleString name, boolean durable, SimpleString filterString) Deprecated.voidServerSessionImpl.createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, boolean durable, SimpleString filterString) Deprecated.voidServerSessionImpl.createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidServerSessionImpl.createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount) Deprecated.voidServerSessionImpl.createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount) Deprecated.voidServerSessionImpl.deleteQueue(SimpleString queueToDelete) voidServerSessionImpl.deleteQueue(SimpleString queueToDelete, boolean enforceSecurity) ActiveMQServerImpl.deployQueue(SimpleString address, SimpleString resourceName, SimpleString filterString, boolean durable, boolean temporary) Deprecated.voidActiveMQServerImpl.destroyDivert(SimpleString name) voidActiveMQServerImpl.destroyDivert(SimpleString name, boolean deleteFromStorage) voidActiveMQServerImpl.destroyQueue(SimpleString queueName) voidActiveMQServerImpl.destroyQueue(SimpleString queueName, SecurityAuth session) voidActiveMQServerImpl.destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount) voidActiveMQServerImpl.destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers) voidActiveMQServerImpl.destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean forceAutoDeleteAddress) voidActiveMQServerImpl.destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean forceAutoDeleteAddress, boolean checkMessageCount) ServerSessionImpl.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, String senderName, boolean noAutoCreateQueue) ServerSessionImpl.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, String senderName, boolean noAutoCreateQueue, RoutingContext routingContext) ServerSessionImpl.executeAddressQuery(SimpleString name) ServerSessionImpl.executeBindingQuery(SimpleString address) ServerSessionImpl.executeQueueQuery(SimpleString name) BucketMessageGroups.get(SimpleString key) MessageGroups.get(SimpleString key) ServerSessionImpl.getAddress(SimpleString address) ServerSessionImpl.getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes) ActiveMQServerImpl.getAddressInfo(SimpleString address) RoutingContextImpl.getContextListing(SimpleString address) intServerSessionImpl.getDefaultConsumerWindowSize(SimpleString address) RoutingContextImpl.getDurableQueues(SimpleString address) ServerSessionImpl.getMatchingQueue(SimpleString address, RoutingType routingType) ServerSessionImpl.getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) RoutingContextImpl.getNonDurableQueues(SimpleString address) ServerSessionImpl.getPrefix(SimpleString address) ServerSessionImpl.getRoutingTypeFromPrefix(SimpleString address, RoutingType defaultRoutingType) booleanActiveMQServerImpl.hasScaledDown(SimpleString scaledDownNodeId) ActiveMQServerImpl.locateQueue(SimpleString queueName) booleanQueueImpl.moveReference(long messageID, SimpleString toAddress, Binding binding, boolean rejectDuplicate) intQueueImpl.moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates, int messageCount, Binding binding) intQueueImpl.moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates, Binding binding) intQueueImpl.moveReferences(Filter filter, SimpleString toAddress, Binding binding) intQueueImpl.moveReferencesBetweenSnFQueues(SimpleString queueSuffix) voidBucketMessageGroups.put(SimpleString key, C consumer) voidMessageGroups.put(SimpleString key, C consumer) ActiveMQServerImpl.queueQuery(SimpleString name) BucketMessageGroups.remove(SimpleString key) MessageGroups.remove(SimpleString key) voidActiveMQServerImpl.removeAddressInfo(SimpleString address, SecurityAuth auth) voidActiveMQServerImpl.removeAddressInfo(SimpleString address, SecurityAuth auth, boolean force) ServerSessionImpl.removePrefix(SimpleString address) voidServerSessionImpl.requestProducerCredits(SimpleString address, int credits) intQueueImpl.rerouteMessages(SimpleString queueName, Filter filter) voidQueueImpl.resetGroup(SimpleString groupId) longScaleDownHandler.scaleDown(ClientSessionFactory sessionFactory, ResourceManager resourceManager, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, SimpleString managementAddress, SimpleString targetNodeId) voidScaleDownHandler.scaleDownDuplicateIDs(Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, ClientSessionFactory sessionFactory, SimpleString managementAddress, String user, String password) longScaleDownHandler.scaleDownMessages(ClientSessionFactory sessionFactory, SimpleString nodeId, String user, String password) longScaleDownHandler.scaleDownRegularMessages(SimpleString address, Set<Queue> queues, ClientSession clientSession, ClientProducer producer) voidRoutingContextImpl.setAddress(SimpleString address) voidDivertImpl.setForwardAddress(SimpleString forwardAddress) voidQueueImpl.setGroupFirstKey(SimpleString groupFirstKey) voidQueueImpl.setUser(SimpleString user) voidQueueImpl.unproposed(SimpleString groupID) booleanActiveMQServerImpl.updateAddressInfo(SimpleString address, Collection<RoutingType> routingTypes) booleanActiveMQServerImpl.updateAddressInfo(SimpleString address, EnumSet<RoutingType> routingTypes) Method parameters in org.apache.activemq.artemis.core.server.impl with type arguments of type SimpleStringModifier and TypeMethodDescriptionActiveMQServerImpl.createInternalSession(String name, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString, RoutingType> prefixes, String securityDomain, boolean isLegacyProducer) 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, String securityDomain, String validatedUser, boolean isLegacyProducer) AddressInfo.getAddressAndRoutingType(Map<SimpleString, RoutingType> prefixes) voidBackupRecoveryJournalLoader.handleDuplicateIds(Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) voidJournalLoader.handleDuplicateIds(Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) voidPostOfficeJournalLoader.handleDuplicateIds(Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) protected ServerSessionImplActiveMQServerImpl.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 autoCreateQueues, Map<SimpleString, RoutingType> prefixes, String securityDomain, boolean isLegacyProducer) voidBackupRecoveryJournalLoader.postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) voidJournalLoader.postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) voidPostOfficeJournalLoader.postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap) longScaleDownHandler.scaleDown(ClientSessionFactory sessionFactory, ResourceManager resourceManager, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, SimpleString managementAddress, SimpleString targetNodeId) voidScaleDownHandler.scaleDownDuplicateIDs(Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, ClientSessionFactory sessionFactory, SimpleString managementAddress, String user, String password) Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type SimpleStringModifierConstructorDescriptionAddressInfo(SimpleString name) AddressInfo(SimpleString name, EnumSet<RoutingType> routingTypes) AddressInfo(SimpleString name, RoutingType routingType) DivertImpl(SimpleString uniqueName, SimpleString address, SimpleString forwardAddress, SimpleString routingName, boolean exclusive, Filter filter, Transformer transformer, PostOffice postOffice, StorageManager storageManager, ComponentConfigurationRoutingType routingType) GroupFirstMessageReference(SimpleString key, MessageReference messageReference) 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, String securityDomain, boolean isLegacyProducer) TempQueueCleanerUpper(ActiveMQServer server, SimpleString bindingName) TransientQueueManagerImpl(ActiveMQServer server, SimpleString queueName) Constructor parameters in org.apache.activemq.artemis.core.server.impl with type arguments of type SimpleStringModifierConstructorDescriptionServerSessionImpl(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, String securityDomain, boolean isLegacyProducer) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.impl.jdbc
Methods in org.apache.activemq.artemis.core.server.impl.jdbc that return SimpleString -
Uses of SimpleString in org.apache.activemq.artemis.core.server.management
Methods in org.apache.activemq.artemis.core.server.management that return SimpleStringModifier and TypeMethodDescriptionManagementService.getManagementAddress()ManagementService.getManagementNotificationAddress()Methods in org.apache.activemq.artemis.core.server.management with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidManagementService.registerQueue(Queue queue, SimpleString address, StorageManager storageManager) voidManagementService.unregisterAddress(SimpleString address) voidManagementService.unregisterDivert(SimpleString name, SimpleString address) voidManagementService.unregisterQueue(SimpleString name, SimpleString address, RoutingType routingType) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.management.impl
Methods in org.apache.activemq.artemis.core.server.management.impl that return SimpleStringModifier and TypeMethodDescriptionManagementServiceImpl.getManagementAddress()ManagementServiceImpl.getManagementNotificationAddress()Methods in org.apache.activemq.artemis.core.server.management.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidManagementServiceImpl.registerQueue(Queue queue, SimpleString address, StorageManager storageManager) voidManagementServiceImpl.unregisterAddress(SimpleString address) voidManagementServiceImpl.unregisterDivert(SimpleString name, SimpleString address) voidManagementServiceImpl.unregisterQueue(SimpleString name, SimpleString address, RoutingType routingType) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.mirror
Methods in org.apache.activemq.artemis.core.server.mirror with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidMirrorController.deleteQueue(SimpleString addressName, SimpleString queueName) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.plugin
Methods in org.apache.activemq.artemis.core.server.plugin with parameters of type SimpleStringModifier and TypeMethodDescriptiondefault voidActiveMQServerQueuePlugin.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) After a queue has been destroyeddefault voidActiveMQServerAddressPlugin.afterRemoveAddress(SimpleString address, AddressInfo addressInfo) After an address has been removeddefault voidActiveMQServerConsumerPlugin.beforeCreateConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) default voidActiveMQServerConsumerPlugin.beforeCreateConsumer(long consumerID, QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) Before a consumer is createddefault voidActiveMQServerQueuePlugin.beforeDestroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) default voidActiveMQServerAddressPlugin.beforeRemoveAddress(SimpleString address) Before an address is removeddefault voidActiveMQServerBindingPlugin.beforeRemoveBinding(SimpleString uniqueName, Transaction tx, boolean deleteData) Before a binding is removeddefault voidActiveMQServerAddressPlugin.beforeUpdateAddress(SimpleString address, EnumSet<RoutingType> routingTypes) Before an address is updateddefault voidActiveMQServerMessagePlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress) default voidActiveMQServerMessagePlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer) A message has been expireddefault voidActiveMQServerMessagePlugin.messageMoved(Transaction tx, MessageReference ref, AckReason reason, SimpleString destAddress, Long destQueueID, ServerConsumer consumer, Message newMessage, RoutingStatus result) A message has been movedMethod parameters in org.apache.activemq.artemis.core.server.plugin with type arguments of type SimpleStringModifier and TypeMethodDescriptiondefault voidActiveMQServerSessionPlugin.beforeCreateSession(String name, String username, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString, RoutingType> prefixes) Before a session is created. -
Uses of SimpleString in org.apache.activemq.artemis.core.server.plugin.impl
Methods in org.apache.activemq.artemis.core.server.plugin.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidLoggingActiveMQServerPluginLogger_impl.afterDeliver(String messageID, SimpleString queueAddress, SimpleString queueName, String consumerSessionID, long consumerID) voidLoggingActiveMQServerPluginLogger.afterDeliver(String messageID, SimpleString queueAddress, SimpleString queueName, String consumerSessionID, long consumerID) voidLoggingActiveMQServerPluginLogger_impl.afterDeliverDetails(String messageID, SimpleString queueAddress, SimpleString queueName, String consumerSessionID, long consumerID, MessageReference reference, ServerConsumer consumer) voidLoggingActiveMQServerPluginLogger.afterDeliverDetails(String messageID, SimpleString queueAddress, SimpleString queueName, String consumerSessionID, long consumerID, MessageReference reference, ServerConsumer consumer) voidLoggingActiveMQServerPlugin.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) After a queue has been destroyedvoidLoggingActiveMQServerPluginLogger_impl.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) voidLoggingActiveMQServerPluginLogger.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) voidNotificationActiveMQServerPlugin.afterRemoveAddress(SimpleString address, AddressInfo addressInfo) voidLoggingActiveMQServerPlugin.beforeCreateConsumer(long consumerID, QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) Before a consumer is createdvoidLoggingActiveMQServerPluginLogger_impl.beforeCreateConsumer(String consumerID, QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) voidLoggingActiveMQServerPluginLogger.beforeCreateConsumer(String consumerID, QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) voidLoggingActiveMQServerPlugin.beforeDestroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) Before a queue is destroyedvoidLoggingActiveMQServerPluginLogger_impl.beforeDestroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) voidLoggingActiveMQServerPluginLogger.beforeDestroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) voidLoggingActiveMQServerPlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer) voidLoggingActiveMQServerPluginLogger_impl.messageExpired(MessageReference message, SimpleString messageExpiryAddress) voidLoggingActiveMQServerPluginLogger.messageExpired(MessageReference message, SimpleString messageExpiryAddress) voidNotificationActiveMQServerPlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer) Method parameters in org.apache.activemq.artemis.core.server.plugin.impl with type arguments of type SimpleStringModifier and TypeMethodDescriptionvoidLoggingActiveMQServerPlugin.beforeCreateSession(String name, String username, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String publicAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString, RoutingType> prefixes) Before a session is created. -
Uses of SimpleString in org.apache.activemq.artemis.core.server.transformer
Methods in org.apache.activemq.artemis.core.server.transformer with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidServerMessageImpl.forceAddress(SimpleString address) Deprecated.This will force encoding of the address, and will re-check the buffer. -
Uses of SimpleString in org.apache.activemq.artemis.core.settings.impl
Fields in org.apache.activemq.artemis.core.settings.impl declared as SimpleStringModifier and TypeFieldDescriptionstatic final SimpleStringAddressSettings.DEFAULT_DEAD_LETTER_QUEUE_PREFIXstatic final SimpleStringAddressSettings.DEFAULT_DEAD_LETTER_QUEUE_SUFFIXstatic final SimpleStringAddressSettings.DEFAULT_EXPIRY_QUEUE_PREFIXstatic final SimpleStringAddressSettings.DEFAULT_EXPIRY_QUEUE_SUFFIXstatic final SimpleStringResourceLimitSettings.DEFAULT_MATCHMethods in org.apache.activemq.artemis.core.settings.impl that return SimpleStringModifier and TypeMethodDescriptionAddressSettings.getDeadLetterAddress()AddressSettings.getDeadLetterQueuePrefix()AddressSettings.getDeadLetterQueueSuffix()AddressSettings.getDefaultGroupFirstKey()AddressSettings.getDefaultLastValueKey()AddressSettings.getExpiryAddress()AddressSettings.getExpiryQueuePrefix()AddressSettings.getExpiryQueueSuffix()ResourceLimitSettings.getMatch()Methods in org.apache.activemq.artemis.core.settings.impl with parameters of type SimpleStringModifier and TypeMethodDescriptionAddressSettings.setDeadLetterAddress(SimpleString deadLetterAddress) AddressSettings.setDeadLetterQueuePrefix(SimpleString value) AddressSettings.setDeadLetterQueueSuffix(SimpleString value) AddressSettings.setDefaultGroupFirstKey(SimpleString defaultGroupFirstKey) AddressSettings.setDefaultLastValueKey(SimpleString defaultLastValueKey) AddressSettings.setExpiryAddress(SimpleString expiryAddress) AddressSettings.setExpiryQueuePrefix(SimpleString value) AddressSettings.setExpiryQueueSuffix(SimpleString value) voidResourceLimitSettings.setMatch(SimpleString match) Constructors in org.apache.activemq.artemis.core.settings.impl with parameters of type SimpleString -
Uses of SimpleString in org.apache.activemq.artemis.jms.client
Fields in org.apache.activemq.artemis.jms.client declared as SimpleStringModifier and TypeFieldDescriptionstatic final SimpleStringActiveMQConnection.CONNECTION_ID_PROPERTY_NAMEstatic final SimpleStringActiveMQMessage.OLD_QUEUE_QUALIFIED_PREFIXstatic final SimpleStringActiveMQMessage.OLD_TEMP_QUEUE_QUALIFED_PREFIXstatic final SimpleStringActiveMQMessage.OLD_TEMP_TOPIC_QUALIFED_PREFIXstatic final SimpleStringActiveMQMessage.OLD_TOPIC_QUALIFIED_PREFIXMethods in org.apache.activemq.artemis.jms.client that return SimpleStringModifier and TypeMethodDescriptionprotected SimpleStringActiveMQMessage.checkPrefix(SimpleString address) protected SimpleStringActiveMQMessage.checkPrefixStr(SimpleString address) static SimpleStringActiveMQDestination.createQueueAddressFromName(String name) static SimpleStringActiveMQDestination.createQueueNameForSubscription(boolean isDurable, String clientID, String subscriptionName) static SimpleStringActiveMQDestination.createTopicAddressFromName(String name) ActiveMQMessageConsumer.getAutoDeleteQueueName()ActiveMQDestination.getSimpleAddress()ActiveMQConnection.getUID()Methods in org.apache.activemq.artemis.jms.client with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidActiveMQConnection.addTemporaryQueue(SimpleString queueAddress) protected SimpleStringActiveMQMessage.checkPrefix(SimpleString address) protected SimpleStringActiveMQMessage.checkPrefixStr(SimpleString address) booleanActiveMQConnection.containsTemporaryQueue(SimpleString queueAddress) static ActiveMQDestinationActiveMQDestination.createDestination(RoutingType routingType, SimpleString address) static ActiveMQQueueActiveMQDestination.createQueue(SimpleString address) static ActiveMQTopicActiveMQDestination.createTopic(SimpleString address) ActiveMQJMSClientBundle_impl.destinationDoesNotExist(SimpleString destination) ActiveMQJMSClientBundle.destinationDoesNotExist(SimpleString destination) ActiveMQJMSClientBundle_impl.invalidFilter(SimpleString filter, Throwable e) ActiveMQJMSClientBundle.invalidFilter(SimpleString filter, Throwable e) voidActiveMQConnection.removeTemporaryQueue(SimpleString queueAddress) voidActiveMQDestination.setSimpleAddress(SimpleString address) Constructors in org.apache.activemq.artemis.jms.client with parameters of type SimpleStringModifierConstructorDescriptionprotectedActiveMQDestination(SimpleString address, String name, ActiveMQDestination.TYPE type, ActiveMQSession session) Deprecated.protectedActiveMQDestination(SimpleString address, ActiveMQDestination.TYPE type, ActiveMQSession session) protectedActiveMQMessageConsumer(ConnectionFactoryOptions options, ActiveMQConnection connection, ActiveMQSession session, ClientConsumer consumer, boolean noLocal, ActiveMQDestination destination, String selector, SimpleString autoDeleteQueueName) ActiveMQQueue(SimpleString address) ActiveMQTopic(SimpleString address) -
Uses of SimpleString in org.apache.activemq.artemis.jms.client.compatible1X
Methods in org.apache.activemq.artemis.jms.client.compatible1X that return SimpleStringModifier and TypeMethodDescriptionprotected SimpleStringActiveMQBytesCompatibleMessage.checkPrefix(SimpleString address) ActiveMQCompatibleMessage.checkPrefix(SimpleString address) protected SimpleStringActiveMQMapCompatibleMessage.checkPrefix(SimpleString address) protected SimpleStringActiveMQObjectCompatibleMessage.checkPrefix(SimpleString address) protected SimpleStringActiveMQStreamCompatibleMessage.checkPrefix(SimpleString address) protected SimpleStringActiveMQTextCompatibleMessage.checkPrefix(SimpleString address) protected static SimpleStringActiveMQCompatibleMessage.checkPrefix1X(SimpleString address) Methods in org.apache.activemq.artemis.jms.client.compatible1X with parameters of type SimpleStringModifier and TypeMethodDescriptionprotected SimpleStringActiveMQBytesCompatibleMessage.checkPrefix(SimpleString address) ActiveMQCompatibleMessage.checkPrefix(SimpleString address) protected SimpleStringActiveMQMapCompatibleMessage.checkPrefix(SimpleString address) protected SimpleStringActiveMQObjectCompatibleMessage.checkPrefix(SimpleString address) protected SimpleStringActiveMQStreamCompatibleMessage.checkPrefix(SimpleString address) protected SimpleStringActiveMQTextCompatibleMessage.checkPrefix(SimpleString address) protected static SimpleStringActiveMQCompatibleMessage.checkPrefix1X(SimpleString address) -
Uses of SimpleString in org.apache.activemq.artemis.jms.server.management
Fields in org.apache.activemq.artemis.jms.server.management declared as SimpleString -
Uses of SimpleString in org.apache.activemq.artemis.ra.inflow
Methods in org.apache.activemq.artemis.ra.inflow that return SimpleStringModifier and TypeMethodDescriptionActiveMQActivation.getAddress()ActiveMQActivation.getTopicTemporaryQueue()Methods in org.apache.activemq.artemis.ra.inflow with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidActiveMQActivation.setTopicTemporaryQueue(SimpleString topicTemporaryQueue) -
Uses of SimpleString in org.apache.activemq.artemis.reader
Fields in org.apache.activemq.artemis.reader declared as SimpleStringModifier and TypeFieldDescriptionstatic final SimpleStringMessageUtil.CONNECTION_ID_PROPERTY_NAMEstatic final SimpleStringMessageUtil.CORRELATIONID_HEADER_NAMEstatic final SimpleStringMessageUtil.JMSstatic final SimpleStringMessageUtil.JMS_static final SimpleStringMessageUtil.JMSXstatic final SimpleStringMessageUtil.REPLYTO_HEADER_NAMEstatic final SimpleStringMessageUtil.TYPE_HEADER_NAMEMethods in org.apache.activemq.artemis.reader that return SimpleStringModifier and TypeMethodDescriptionstatic SimpleStringMessageUtil.getJMSReplyTo(Message message) static SimpleStringTextMessageUtil.readBodyText(ActiveMQBuffer buff) Utility method to set the Text message on a message bodyMethods in org.apache.activemq.artemis.reader with parameters of type SimpleStringModifier and TypeMethodDescriptionstatic voidMessageUtil.setJMSReplyTo(Message message, SimpleString dest) static voidTextMessageUtil.writeBodyText(ActiveMQBuffer buff, SimpleString text) Utility method to set the Text message on a message body -
Uses of SimpleString in org.apache.activemq.artemis.selector.filter
Methods in org.apache.activemq.artemis.selector.filter with parameters of type SimpleStringModifier and TypeMethodDescriptionFilterable.getProperty(SimpleString name) Extracts the named message propertyConstructors in org.apache.activemq.artemis.selector.filter with parameters of type SimpleString -
Uses of SimpleString in org.apache.activemq.artemis.spi.core.protocol
Methods in org.apache.activemq.artemis.spi.core.protocol that return types with arguments of type SimpleStringModifier and TypeMethodDescriptionAbstractProtocolManager.getPrefixes()ProtocolManager.getPrefixes()Methods in org.apache.activemq.artemis.spi.core.protocol with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidAbstractRemotingConnection.killMessage(SimpleString nodeID) voidRemotingConnection.killMessage(SimpleString nodeID) if slow consumer is killed,send the msessage to client.voidSessionCallback.sendProducerCreditsFailMessage(int credits, SimpleString address) voidSessionCallback.sendProducerCreditsMessage(int credits, SimpleString address) -
Uses of SimpleString in org.apache.activemq.artemis.spi.core.remoting
Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type SimpleStringModifier and TypeMethodDescriptionabstract ClientSession.AddressQuerySessionContext.addressQuery(SimpleString address) abstract voidSessionContext.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) abstract voidSessionContext.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated) Deprecated.abstract ClientConsumerInternalSessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout) abstract voidSessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated) Deprecated.abstract voidSessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated, Boolean exclusive, Boolean lastVale) abstract voidSessionContext.createQueue(SimpleString address, SimpleString queueName, boolean temp, boolean autoCreated, QueueAttributes queueAttributes) abstract voidSessionContext.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, boolean autoCreated) Deprecated.abstract voidSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.abstract voidSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable) Deprecated.abstract voidSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.abstract voidSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable) Deprecated.abstract voidSessionContext.deleteQueue(SimpleString queueName) protected voidSessionContext.handleReceiveProducerCredits(SimpleString address, int credits) protected voidSessionContext.handleReceiveProducerFailCredits(SimpleString address, int credits) abstract voidSessionContext.linkFlowControl(SimpleString address, ClientProducerCredits clientProducerCredits) abstract ClientSession.QueueQuerySessionContext.queueQuery(SimpleString queueName) abstract voidSessionContext.sendFullMessage(ICoreMessage msgI, boolean sendBlocking, SendAcknowledgementHandler handler, SimpleString defaultAddress, int senderID) abstract voidSessionContext.sendProducerCreditsMessage(int credits, SimpleString address) -
Uses of SimpleString in org.apache.activemq.artemis.utils
Methods in org.apache.activemq.artemis.utils that return SimpleStringModifier and TypeMethodDescriptionstatic SimpleStringDestinationUtil.createQueueNameForSubscription(boolean isDurable, String clientID, String subscriptionName) static SimpleStringCompositeAddress.extractAddressName(SimpleString address) static SimpleStringCompositeAddress.extractQueueName(SimpleString name) UUIDGenerator.generateSimpleStringUUID()static SimpleStringPrefixUtil.getAddress(SimpleString address, Map<SimpleString, RoutingType> prefixes) static SimpleStringAutoCreateUtil.getCoreQueueName(ClientSession session, SimpleString destAddress) static SimpleStringPrefixUtil.getPrefix(SimpleString address, Map<SimpleString, RoutingType> prefixes) static SimpleStringRandomUtil.randomUUIDSimpleString()Returns A randomly generatedUUIDconverted to aSimpleString.static SimpleStringPrefixUtil.removeAddress(SimpleString string, SimpleString prefix) static SimpleStringPrefixUtil.removePrefix(SimpleString string, SimpleString prefix) static SimpleStringCompositeAddress.toFullyQualified(SimpleString address, SimpleString qName) Methods in org.apache.activemq.artemis.utils that return types with arguments of type SimpleStringModifier and TypeMethodDescriptionstatic Pair<SimpleString,EnumSet<RoutingType>> PrefixUtil.getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes, Map<SimpleString, RoutingType> prefixes) Methods in org.apache.activemq.artemis.utils with parameters of type SimpleStringModifier and TypeMethodDescriptionstatic voidAutoCreateUtil.autoCreateQueue(ClientSession session, SimpleString destAddress, SimpleString selectorString) static SimpleStringCompositeAddress.extractAddressName(SimpleString address) static SimpleStringCompositeAddress.extractQueueName(SimpleString name) static SimpleStringPrefixUtil.getAddress(SimpleString address, Map<SimpleString, RoutingType> prefixes) static Pair<SimpleString,EnumSet<RoutingType>> PrefixUtil.getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes, Map<SimpleString, RoutingType> prefixes) static SimpleStringAutoCreateUtil.getCoreQueueName(ClientSession session, SimpleString destAddress) static SimpleStringPrefixUtil.getPrefix(SimpleString address, Map<SimpleString, RoutingType> prefixes) static booleanCompositeAddress.isFullyQualified(SimpleString address) static SimpleStringPrefixUtil.removeAddress(SimpleString string, SimpleString prefix) static SimpleStringPrefixUtil.removePrefix(SimpleString string, SimpleString prefix) static voidAutoCreateUtil.setRequiredQueueConfigurationIfNotSet(QueueConfiguration queueConfiguration, ClientSession.AddressQuery addressQuery, RoutingType routingType, SimpleString filter, boolean durable) Set the non nullable (CreateQueueMessage_V2) queue attributes (all others have static defaults or get defaulted if null by address settings server side).static SimpleStringCompositeAddress.toFullyQualified(SimpleString address, SimpleString qName) Method parameters in org.apache.activemq.artemis.utils with type arguments of type SimpleStringModifier and TypeMethodDescriptionstatic SimpleStringPrefixUtil.getAddress(SimpleString address, Map<SimpleString, RoutingType> prefixes) static Pair<SimpleString,EnumSet<RoutingType>> PrefixUtil.getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes, Map<SimpleString, RoutingType> prefixes) static SimpleStringPrefixUtil.getPrefix(SimpleString address, Map<SimpleString, RoutingType> prefixes) -
Uses of SimpleString in org.apache.activemq.artemis.utils.collections
Methods in org.apache.activemq.artemis.utils.collections that return SimpleStringMethods in org.apache.activemq.artemis.utils.collections that return types with arguments of type SimpleStringMethods in org.apache.activemq.artemis.utils.collections with parameters of type SimpleStringModifier and TypeMethodDescriptionbooleanTypedProperties.containsProperty(SimpleString key) TypedProperties.getBooleanProperty(SimpleString key) TypedProperties.getByteProperty(SimpleString key) TypedProperties.getByteProperty(SimpleString key, Supplier<Byte> defaultValue) byte[]TypedProperties.getBytesProperty(SimpleString key) TypedProperties.getCharProperty(SimpleString key) TypedProperties.getDoubleProperty(SimpleString key) TypedProperties.getFloatProperty(SimpleString key) TypedProperties.getIntProperty(SimpleString key) TypedProperties.getLongProperty(SimpleString key) TypedProperties.getProperty(SimpleString key) TypedProperties.getShortProperty(SimpleString key) TypedProperties.getSimpleStringProperty(SimpleString key) voidTypedProperties.putBooleanProperty(SimpleString key, boolean value) voidTypedProperties.putByteProperty(SimpleString key, byte value) voidTypedProperties.putBytesProperty(SimpleString key, byte[] value) voidTypedProperties.putCharProperty(SimpleString key, char value) voidTypedProperties.putDoubleProperty(SimpleString key, double value) voidTypedProperties.putFloatProperty(SimpleString key, float value) voidTypedProperties.putIntProperty(SimpleString key, int value) voidTypedProperties.putLongProperty(SimpleString key, long value) voidTypedProperties.putNullValue(SimpleString key) TypedProperties.putProperty(SimpleString key, Object value) voidTypedProperties.putShortProperty(SimpleString key, short value) voidTypedProperties.putSimpleStringProperty(SimpleString key, SimpleString value) TypedProperties.removeProperty(SimpleString key) static booleanTypedProperties.searchProperty(SimpleString key, io.netty.buffer.ByteBuf buffer, int startIndex) Performs a search among the valid key properties contained inbuffer, starting fromfromassuming it to be a valid encodedTypedPropertiescontent.static voidTypedProperties.setObjectProperty(SimpleString key, Object value, TypedProperties properties) Helper for MapMessage#setObjectProperty(String, Object)Method parameters in org.apache.activemq.artemis.utils.collections with type arguments of type SimpleStringModifier and TypeMethodDescriptionvoidTypedProperties.forEach(BiConsumer<SimpleString, Object> action) This method is read-only.voidTypedProperties.forEachKey(Consumer<SimpleString> action) This method is read-only.Constructor parameters in org.apache.activemq.artemis.utils.collections with type arguments of type SimpleStringModifierConstructorDescriptionTypedProperties(Predicate<SimpleString> internalPropertyPredicate) TypedProperties(Predicate<SimpleString> internalPropertyPredicate, Predicate<SimpleString> amqpPropertyPredicate) -
Uses of SimpleString in org.apache.activemq.artemis.utils.uri
Methods in org.apache.activemq.artemis.utils.uri with parameters of type SimpleString -
Uses of SimpleString in org.wildfly.extension.messaging.activemq
Methods in org.wildfly.extension.messaging.activemq that return SimpleStringMethods in org.wildfly.extension.messaging.activemq with parameters of type SimpleStringModifier and TypeMethodDescriptionvoidActiveMQBroker.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary) Creates a Queue on the underlyingActiveMQServer.voidActiveMQBrokerImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary) voidActiveMQBroker.destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount) Destroys a queue from the underlyingActiveMQServer.voidActiveMQBrokerImpl.destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount)
of(String)instead.