Uses of Class
org.apache.activemq.artemis.api.core.SimpleString
-
-
Uses of SimpleString in org.apache.activemq.artemis.api.config
Fields in org.apache.activemq.artemis.api.config declared as SimpleString Modifier and Type Field Description static SimpleStringActiveMQDefaultConfiguration. DEFAULT_GROUP_FIRST_KEYstatic SimpleStringActiveMQDefaultConfiguration. DEFAULT_LAST_VALUE_KEYMethods in org.apache.activemq.artemis.api.config that return SimpleString Modifier and Type Method Description static 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 SimpleString Modifier and Type Field Description static SimpleStringFilterConstants. ACTIVEMQ_ADDRESSName of the ActiveMQ Artemis Address headerstatic SimpleStringFilterConstants. ACTIVEMQ_DURABLEName of the ActiveMQ Artemis Message durable header.static SimpleStringFilterConstants. ACTIVEMQ_EXPIRATIONName of the ActiveMQ Artemis Message expiration header.static SimpleStringFilterConstants. ACTIVEMQ_GROUP_IDName of the ActiveMQ Artemis Message group id header.static SimpleStringFilterConstants. ACTIVEMQ_PREFIXAll ActiveMQ Artemis headers are prepended by this prefix.static SimpleStringFilterConstants. ACTIVEMQ_PRIORITYName of the ActiveMQ Artemis Message priority header.static SimpleStringFilterConstants. ACTIVEMQ_SIZEName of the ActiveMQ Artemis Message size header.static SimpleStringFilterConstants. ACTIVEMQ_TIMESTAMPName of the ActiveMQ Artemis Message timestamp header.static SimpleStringFilterConstants. ACTIVEMQ_USERIDName of the ActiveMQ Artemis UserID header.static SimpleStringFilterConstants. DURABLEValue for the Durable header when the message is durable.static SimpleStringMessage. HDR_ACTUAL_EXPIRY_TIMEthe actual time the message was expired.static SimpleStringMessage. HDR_BRIDGE_DUPLICATE_IDstatic SimpleStringMessage. HDR_CONTENT_TYPETo define the mime-type of body messages.static SimpleStringMessage. HDR_DUPLICATE_DETECTION_IDTo be used with duplicate detection.static SimpleStringMessage. HDR_GROUP_IDFor the Message Grouping feature.static SimpleStringMessage. HDR_GROUP_SEQUENCEstatic SimpleStringMessage. HDR_INGRESS_TIMESTAMPThe time at which the message arrived at the broker.static SimpleStringMessage. HDR_LARGE_BODY_SIZEThe body size of a large message before it was compressed.static SimpleStringMessage. HDR_LARGE_COMPRESSEDto determine if the Large Message was compressed.static SimpleStringMessage. HDR_LAST_VALUE_NAMETo be used with Last value queues.static SimpleStringMessage. HDR_ORIG_MESSAGE_IDThe original message ID before the message was transferred.static SimpleStringMessage. HDR_ORIG_ROUTING_TYPEThe original routing type of a message before getting transferred through DLQ or expirystatic SimpleStringMessage. HDR_ORIGINAL_ADDRESSThe original address of a message when a message is diverted or transferred through DLQ or expirystatic SimpleStringMessage. HDR_ORIGINAL_QUEUEThe original address of a message when a message is transferred through DLQ or expirystatic SimpleStringMessage. HDR_PREFIXThe prefix used (if any) when sending this message.static SimpleStringMessage. HDR_ROUTE_TO_ACK_IDSstatic SimpleStringMessage. HDR_ROUTE_TO_IDSstatic SimpleStringMessage. HDR_ROUTING_TYPEThe Routing Type for this message.static SimpleStringMessage. HDR_SCALEDOWN_TO_IDSstatic SimpleStringMessage. HDR_SCHEDULED_DELIVERY_TIMETo be used with Scheduled Delivery.static SimpleStringMessage. HDR_VALIDATED_USERThe name of the validated user who sent the message.static SimpleStringFilterConstants. NON_DURABLEValue for the Durable header when the message is non-durable.Fields in org.apache.activemq.artemis.api.core with type parameters of type SimpleString Modifier and Type Field Description static Predicate<SimpleString>Message. INTERNAL_PROPERTY_NAMES_PREDICATEMethods in org.apache.activemq.artemis.api.core that return SimpleString Modifier and Type Method Description SimpleStringSimpleString. concat(char c)Concatenates a SimpleString and a charSimpleStringSimpleString. concat(String toAdd)Concatenates a SimpleString and a StringSimpleStringSimpleString. concat(SimpleString toAdd)Concatenates 2 SimpleString'sprotected SimpleStringSimpleString.ByteBufSimpleStringPool. create(io.netty.buffer.ByteBuf byteBuf, int length)protected SimpleStringSimpleString.StringSimpleStringPool. create(String value)SimpleStringParameterisedAddress. getAddress()SimpleStringQueueConfiguration. getAddress()SimpleStringMessage. getAddressSimpleString()SimpleStringQueueAttributes. getFilterString()Deprecated.SimpleStringQueueConfiguration. getFilterString()SimpleStringQueueAttributes. getGroupFirstKey()Deprecated.SimpleStringQueueConfiguration. getGroupFirstKey()default SimpleStringMessage. getGroupID()SimpleStringQueueAttributes. getLastValueKey()Deprecated.SimpleStringQueueConfiguration. getLastValueKey()default SimpleStringMessage. getLastValueProperty()SimpleStringQueueConfiguration. getName()SimpleStringMessage. getReplyTo()SimpleStringMessage. getSimpleStringProperty(String key)SimpleStringMessage. getSimpleStringProperty(SimpleString key)SimpleStringQueueConfiguration. getUser()SimpleStringActiveMQBuffer. 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)SimpleStringActiveMQBuffer. 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[]SimpleString. split(char delim)Splits this SimpleString into an array of SimpleString using the char param as the delimiter.SimpleStringSimpleString. subSeq(int start, int end)static SimpleStringParameterisedAddress. toParameterisedAddress(SimpleString address, Map<String,String> parameters)static SimpleStringSimpleString. toSimpleString(String string)Returns a SimpleString constructed from thestringparameter.static SimpleStringSimpleString. toSimpleString(String string, SimpleString.StringSimpleStringPool pool)Methods in org.apache.activemq.artemis.api.core that return types with arguments of type SimpleString Modifier and Type Method Description Set<SimpleString>Message. getPropertyNames()Returns all the names of the properties for this message.Methods in org.apache.activemq.artemis.api.core with parameters of type SimpleString Modifier and Type Method Description intSimpleString. compareTo(SimpleString o)SimpleStringSimpleString. concat(SimpleString toAdd)Concatenates 2 SimpleString'sbooleanMessage. containsProperty(SimpleString key)ObjectMessage. getAnnotation(SimpleString key)default StringMessage. getAnnotationString(SimpleString key)BooleanMessage. getBooleanProperty(SimpleString key)default ObjectMessage. getBrokerProperty(SimpleString key)ByteMessage. getByteProperty(SimpleString key)byte[]Message. getBytesProperty(SimpleString key)DoubleMessage. getDoubleProperty(SimpleString key)default byte[]Message. getExtraBytesProperty(SimpleString key)FloatMessage. getFloatProperty(SimpleString key)IntegerMessage. getIntProperty(SimpleString key)LongMessage. getLongProperty(SimpleString key)ObjectMessage. getObjectProperty(SimpleString key)default ObjectMessage. getObjectPropertyForFilter(SimpleString key)ShortMessage. getShortProperty(SimpleString key)SimpleStringMessage. getSimpleStringProperty(SimpleString key)StringMessage. 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)MessageMessage. putBooleanProperty(SimpleString key, boolean value)MessageMessage. putByteProperty(SimpleString key, byte value)MessageMessage. putBytesProperty(SimpleString key, byte[] value)MessageMessage. putCharProperty(SimpleString key, char value)MessageMessage. putDoubleProperty(SimpleString key, double value)default MessageMessage. putExtraBytesProperty(SimpleString key, byte[] value)MessageMessage. putFloatProperty(SimpleString key, float value)MessageMessage. putIntProperty(SimpleString key, int value)MessageMessage. putLongProperty(SimpleString key, long value)MessageMessage. putObjectProperty(SimpleString key, Object value)MessageMessage. putShortProperty(SimpleString key, short value)MessageMessage. putStringProperty(SimpleString key, String value)MessageMessage. putStringProperty(SimpleString key, SimpleString value)default voidMessage. referenceOriginalMessage(Message original, SimpleString originalQueue)default ObjectMessage. removeAnnotation(SimpleString key)default byte[]Message. removeExtraBytesProperty(SimpleString key)ObjectMessage. removeProperty(SimpleString key)MessageMessage. setAddress(SimpleString address)This will set the address on CoreMessage.QueueConfigurationQueueConfiguration. setAddress(SimpleString address)Set the name.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.QueueAttributesQueueAttributes. setFilterString(SimpleString filterString)Deprecated.QueueConfigurationQueueConfiguration. setFilterString(SimpleString filterString)QueueAttributesQueueAttributes. setGroupFirstKey(SimpleString groupFirstKey)Deprecated.QueueConfigurationQueueConfiguration. setGroupFirstKey(SimpleString groupFirstKey)default MessageMessage. setGroupID(SimpleString groupID)QueueAttributesQueueAttributes. setLastValueKey(SimpleString lastValueKey)Deprecated.QueueConfigurationQueueConfiguration. setLastValueKey(SimpleString lastValueKey)default MessageMessage. setLastValueProperty(SimpleString lastValueName)QueueConfigurationQueueConfiguration. setName(SimpleString name)Set the name.MessageMessage. setReplyTo(SimpleString address)QueueConfigurationQueueConfiguration. setUser(SimpleString user)static intSimpleString. sizeofNullableString(SimpleString str)returns the size of a SimpleString which could be nullstatic intSimpleString. sizeofString(SimpleString str)returns the size of a SimpleStringbooleanSimpleString. startsWith(SimpleString other)returns true if the SimpleString parameter starts with the same data as this one.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 SimpleString Constructor Description ParameterisedAddress(SimpleString address)ParameterisedAddress(SimpleString address, QueueAttributes queueAttributes)Deprecated.ParameterisedAddress(SimpleString address, QueueConfiguration queueConfiguration)QueueConfiguration(SimpleString name)Instantiate this object and invokeQueueConfiguration.setName(SimpleString) -
Uses of SimpleString in org.apache.activemq.artemis.api.core.client
Methods in org.apache.activemq.artemis.api.core.client that return SimpleString Modifier and Type Method Description SimpleStringClientProducer. getAddress()Returns the address where messages will be sent.SimpleStringClientSession.QueueQuery. getAddress()Returns the address that the queue is bound to.SimpleStringClientSession.AddressQuery. getDefaultLastValueKey()SimpleStringClientSession.QueueQuery. getFilterString()Returns the queue's filter string (ornullif the queue has no filter).SimpleStringClientSession.QueueQuery. getGroupFirstKey()SimpleStringClientSession.QueueQuery. getLastValueKey()SimpleStringClientSession.QueueQuery. getName()Return the name of the queueMethods in org.apache.activemq.artemis.api.core.client that return types with arguments of type SimpleString Modifier and Type Method Description List<SimpleString>ClientSession.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 SimpleString Modifier and Type Method Description ClientSession.AddressQueryClientSession. 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 typeClientConsumerClientSession. createConsumer(SimpleString queueName)Creates a ClientConsumer to consume message from the queue with the given name.ClientConsumerClientSession. createConsumer(SimpleString queueName, boolean browseOnly)Creates a ClientConsumer to consume or browse messages from the queue with the given name.ClientConsumerClientSession. createConsumer(SimpleString queueName, SimpleString filter)Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.ClientConsumerClientSession. 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.ClientConsumerClientSession. 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.ClientConsumerClientSession. 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.ClientConsumerClientSession. 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.ClientProducerClientSession. createProducer(SimpleString address)Creates a producer which sends messages to the given addressClientProducerClientSession. createProducer(SimpleString address, int rate)Creates a producer which sends messages to the given addressvoidClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName)Deprecated.voidClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable)Deprecated.voidClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable)Deprecated.voidClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated)Deprecated.voidClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers)Deprecated.voidClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)Deprecated.voidClientSession. createQueue(SimpleString address, SimpleString queueName)Deprecated.voidClientSession. createQueue(SimpleString address, SimpleString queueName, boolean durable)Deprecated.voidClientSession. createQueue(SimpleString address, SimpleString queueName, boolean autoCreated, QueueAttributes queueAttributes)Deprecated.voidClientSession. createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable)Deprecated.voidClientSession. createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated)Deprecated.voidClientSession. 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.voidClientSession. createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter)Deprecated.voidClientSession. createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)Deprecated.voidClientSession. createTemporaryQueue(SimpleString address, SimpleString queueName)Deprecated.voidClientSession. createTemporaryQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes)Deprecated.voidClientSession. createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter)Deprecated.voidClientSession. deleteQueue(SimpleString queueName)Deletes the queue.ClientMessageClientMessage. putBooleanProperty(SimpleString key, boolean value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putByteProperty(SimpleString key, byte value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putBytesProperty(SimpleString key, byte[] value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putCharProperty(SimpleString key, char value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putDoubleProperty(SimpleString key, double value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putFloatProperty(SimpleString key, float value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putIntProperty(SimpleString key, int value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putLongProperty(SimpleString key, long value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putShortProperty(SimpleString key, short value)Overridden fromMessageto enable fluent APIClientSession.QueueQueryClientSession. 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 SimpleString Constructor Description ClientRequestor(ClientSession session, SimpleString requestAddress)Constructor for the ClientRequestor. -
Uses of SimpleString in org.apache.activemq.artemis.api.core.management
Methods in org.apache.activemq.artemis.api.core.management that return SimpleString Modifier and Type Method Description 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)Methods in org.apache.activemq.artemis.api.core.management with parameters of type SimpleString Modifier and Type Method Description ObjectNameObjectNameBuilder. getAddressObjectName(SimpleString address)Returns the ObjectName used by AddressControl.ObjectNameObjectNameBuilder. 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 SimpleString Modifier and Type Method Description SimpleStringChannelBufferWrapper. readNullableSimpleString()SimpleStringChannelBufferWrapper. readSimpleString()Methods in org.apache.activemq.artemis.core.buffers.impl with parameters of type SimpleString Modifier and Type Method Description voidChannelBufferWrapper. 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 SimpleString Modifier and Type Field Description protected SimpleStringAbstractProducerCreditsImpl. addressstatic SimpleStringClientConsumerImpl. FORCED_DELIVERY_MESSAGEstatic SimpleStringClientMessageImpl. REPLYTO_HEADER_NAMEMethods in org.apache.activemq.artemis.core.client.impl that return SimpleString Modifier and Type Method Description SimpleStringAbstractProducerCreditsImpl. getAddress()SimpleStringClientProducerCredits. getAddress()SimpleStringClientProducerImpl. getAddress()SimpleStringQueueQueryImpl. getAddress()SimpleStringAddressQueryImpl. getDefaultLastValueKey()SimpleStringClientConsumerImpl. getFilterString()SimpleStringClientConsumerInternal. getFilterString()SimpleStringQueueQueryImpl. getFilterString()SimpleStringQueueQueryImpl. getGroupFirstKey()SimpleStringQueueQueryImpl. getLastValueKey()SimpleStringQueueQueryImpl. getName()SimpleStringClientConsumerImpl. getQueueName()SimpleStringClientConsumerInternal. getQueueName()SimpleStringLargeMessageControllerImpl. readNullableSimpleString()SimpleStringLargeMessageControllerImpl. readSimpleString()Methods in org.apache.activemq.artemis.core.client.impl that return types with arguments of type SimpleString Modifier and Type Method Description List<SimpleString>AddressQueryImpl. getQueueNames()Methods in org.apache.activemq.artemis.core.client.impl with parameters of type SimpleString Modifier and Type Method Description ClientSession.AddressQueryClientSessionImpl. 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)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, SimpleString filterString)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, SimpleString filterString, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, SimpleString filterString, int windowSize, int maxRate, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, boolean browseOnly)Note, we DO NOT currently support direct consumers (i.e.ClientProducerClientSessionImpl. createProducer(SimpleString address)ClientProducerClientSessionImpl. 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)Creates a transient queue.voidClientSessionImpl. createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable)Creates a transient queue.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)ClientProducerCreditsClientProducerCreditManager. getCredits(SimpleString address, boolean anon, SessionContext context)ClientProducerCreditsClientProducerCreditManagerImpl. getCredits(SimpleString address, boolean anon, SessionContext context)ClientProducerCreditsClientSessionImpl. getCredits(SimpleString address, boolean anon)ClientProducerCreditsClientSessionInternal. 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)ClientMessageImplClientMessageImpl. putBooleanProperty(SimpleString key, boolean value)ClientMessageImplClientMessageImpl. putByteProperty(SimpleString key, byte value)ClientMessageImplClientMessageImpl. putBytesProperty(SimpleString key, byte[] value)ClientMessageImplClientMessageImpl. putCharProperty(SimpleString key, char value)ClientMessageImplClientMessageImpl. putDoubleProperty(SimpleString key, double value)ClientMessageImplClientMessageImpl. putFloatProperty(SimpleString key, float value)ClientMessageImplClientMessageImpl. putIntProperty(SimpleString key, int value)ClientMessageImplClientMessageImpl. putLongProperty(SimpleString key, long value)ClientMessageImplClientMessageImpl. putObjectProperty(SimpleString key, Object value)ClientMessageImplClientMessageImpl. putShortProperty(SimpleString key, short value)ClientMessageImplClientMessageImpl. putStringProperty(SimpleString key, String value)ClientMessageImplClientMessageImpl. putStringProperty(SimpleString key, SimpleString value)ClientSession.QueueQueryClientSessionImpl. 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 SimpleString Constructor Description AbstractProducerCreditsImpl(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)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)ClientProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize)ClientProducerImpl(ClientSessionInternal session, SimpleString address, TokenBucketLimiter rateLimiter, boolean blockOnNonDurableSend, boolean blockOnDurableSend, boolean autoGroup, SimpleString groupID, int minLargeMessageSize, SessionContext sessionContext)QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists)QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues)QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues, int maxConsumers, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType)QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues, int maxConsumers, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType, Boolean exclusive, Boolean 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 SimpleString Constructor Description 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) -
Uses of SimpleString in org.apache.activemq.artemis.core.config
Methods in org.apache.activemq.artemis.core.config that return SimpleString Modifier and Type Method Description SimpleStringConfiguration. getManagementAddress()Returns the management address of this server.SimpleStringConfiguration. getManagementNotificationAddress()Returns the management notification address of this server.Methods in org.apache.activemq.artemis.core.config with parameters of type SimpleString Modifier and Type Method Description ConfigurationConfiguration. setManagementAddress(SimpleString address)Sets the management address of this server.ConfigurationConfiguration. 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 SimpleString Modifier and Type Method Description SimpleStringAMQPBrokerConnectionElement. getMatchAddress()SimpleStringAMQPMirrorBrokerConnectionElement. getMirrorSNF()SimpleStringAMQPBrokerConnectionElement. getQueueName()Methods in org.apache.activemq.artemis.core.config.amqpBrokerConnectivity with parameters of type SimpleString Modifier and Type Method Description static booleanAMQPBrokerConnectionElement. match(SimpleString matchAddressString, SimpleString checkAddressString, WildcardConfiguration wildcardConfig)booleanAMQPBrokerConnectionElement. match(SimpleString checkAddress, WildcardConfiguration wildcardConfig)AMQPBrokerConnectionElementAMQPBrokerConnectionElement. setMatchAddress(SimpleString matchAddress)AMQPMirrorBrokerConnectionElementAMQPMirrorBrokerConnectionElement. setMirrorSNF(SimpleString mirrorSNF)AMQPBrokerConnectionElementAMQPBrokerConnectionElement. 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 SimpleString Modifier and Type Method Description SimpleStringConfigurationImpl. getManagementAddress()SimpleStringConfigurationImpl. getManagementNotificationAddress()Methods in org.apache.activemq.artemis.core.config.impl with parameters of type SimpleString Modifier and Type Method Description ConfigurationImplConfigurationImpl. setManagementAddress(SimpleString address)ConfigurationImplConfigurationImpl. setManagementNotificationAddress(SimpleString address) -
Uses of SimpleString in org.apache.activemq.artemis.core.filter
Methods in org.apache.activemq.artemis.core.filter that return SimpleString Modifier and Type Method Description SimpleStringFilter. 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 SimpleString Modifier and Type Method Description SimpleStringFilterImpl. getFilterString()Methods in org.apache.activemq.artemis.core.filter.impl with parameters of type SimpleString Modifier and Type Method Description static FilterFilterImpl. createFilter(SimpleString filterStr) -
Uses of SimpleString in org.apache.activemq.artemis.core.management.impl
Methods in org.apache.activemq.artemis.core.management.impl with parameters of type SimpleString Modifier and Type Method Description voidManagementRemotingConnection. 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, Long... queueID) -
Uses of SimpleString in org.apache.activemq.artemis.core.message.impl
Fields in org.apache.activemq.artemis.core.message.impl declared as SimpleString Modifier and Type Field Description protected SimpleStringCoreMessage. addressMethods in org.apache.activemq.artemis.core.message.impl that return SimpleString Modifier and Type Method Description SimpleStringCoreMessage. getAddressSimpleString()SimpleStringMessageInternalImpl. getAddressSimpleString()Deprecated.SimpleStringCoreMessage. getGroupID()SimpleStringCoreMessage. getLastValueProperty()SimpleStringCoreMessage. getReplyTo()SimpleStringMessageInternalImpl. getReplyTo()Deprecated.SimpleStringCoreMessage. getSimpleStringProperty(String key)SimpleStringCoreMessage. getSimpleStringProperty(SimpleString key)SimpleStringMessageInternalImpl. getSimpleStringProperty(String key)Deprecated.SimpleStringMessageInternalImpl. getSimpleStringProperty(SimpleString key)Deprecated.Methods in org.apache.activemq.artemis.core.message.impl that return types with arguments of type SimpleString Modifier and Type Method Description Set<SimpleString>CoreMessage. getPropertyNames()Set<SimpleString>MessageInternalImpl. getPropertyNames()Deprecated.Returns all the names of the properties for this message.Methods in org.apache.activemq.artemis.core.message.impl with parameters of type SimpleString Modifier and Type Method Description booleanCoreMessage. containsProperty(SimpleString key)booleanMessageInternalImpl. containsProperty(SimpleString key)Deprecated.ObjectCoreMessage. getAnnotation(SimpleString key)On core there's no delivery annotationObjectMessageInternalImpl. getAnnotation(SimpleString key)Deprecated.BooleanCoreMessage. getBooleanProperty(SimpleString key)BooleanMessageInternalImpl. getBooleanProperty(SimpleString key)Deprecated.ByteCoreMessage. getByteProperty(SimpleString key)ByteMessageInternalImpl. getByteProperty(SimpleString key)Deprecated.byte[]CoreMessage. getBytesProperty(SimpleString key)byte[]MessageInternalImpl. getBytesProperty(SimpleString key)Deprecated.DoubleCoreMessage. getDoubleProperty(SimpleString key)DoubleMessageInternalImpl. getDoubleProperty(SimpleString key)Deprecated.FloatCoreMessage. getFloatProperty(SimpleString key)FloatMessageInternalImpl. getFloatProperty(SimpleString key)Deprecated.IntegerCoreMessage. getIntProperty(SimpleString key)IntegerMessageInternalImpl. getIntProperty(SimpleString key)Deprecated.LongCoreMessage. getLongProperty(SimpleString key)LongMessageInternalImpl. getLongProperty(SimpleString key)Deprecated.ObjectCoreMessage. getObjectProperty(SimpleString key)ObjectMessageInternalImpl. getObjectProperty(SimpleString key)Deprecated.ShortCoreMessage. getShortProperty(SimpleString key)ShortMessageInternalImpl. getShortProperty(SimpleString key)Deprecated.SimpleStringCoreMessage. getSimpleStringProperty(SimpleString key)SimpleStringMessageInternalImpl. getSimpleStringProperty(SimpleString key)Deprecated.StringCoreMessage. getStringProperty(SimpleString key)StringMessageInternalImpl. getStringProperty(SimpleString key)Deprecated.CoreMessageCoreMessage. putBooleanProperty(SimpleString key, boolean value)MessageMessageInternalImpl. putBooleanProperty(SimpleString key, boolean value)Deprecated.CoreMessageCoreMessage. putByteProperty(SimpleString key, byte value)MessageMessageInternalImpl. putByteProperty(SimpleString key, byte value)Deprecated.CoreMessageCoreMessage. putBytesProperty(SimpleString key, byte[] value)MessageMessageInternalImpl. putBytesProperty(SimpleString key, byte[] value)Deprecated.CoreMessageCoreMessage. putCharProperty(SimpleString key, char value)MessageMessageInternalImpl. putCharProperty(SimpleString key, char value)Deprecated.CoreMessageCoreMessage. putDoubleProperty(SimpleString key, double value)MessageMessageInternalImpl. putDoubleProperty(SimpleString key, double value)Deprecated.CoreMessageCoreMessage. putFloatProperty(SimpleString key, float value)MessageMessageInternalImpl. putFloatProperty(SimpleString key, float value)Deprecated.CoreMessageCoreMessage. putIntProperty(SimpleString key, int value)MessageMessageInternalImpl. putIntProperty(SimpleString key, int value)Deprecated.CoreMessageCoreMessage. putLongProperty(SimpleString key, long value)MessageMessageInternalImpl. putLongProperty(SimpleString key, long value)Deprecated.CoreMessageCoreMessage. putObjectProperty(SimpleString key, Object value)MessageMessageInternalImpl. putObjectProperty(SimpleString key, Object value)Deprecated.CoreMessageCoreMessage. putShortProperty(SimpleString key, short value)MessageMessageInternalImpl. putShortProperty(SimpleString key, short value)Deprecated.CoreMessageCoreMessage. putStringProperty(SimpleString key, String value)CoreMessageCoreMessage. putStringProperty(SimpleString key, SimpleString value)MessageMessageInternalImpl. putStringProperty(SimpleString key, String value)Deprecated.MessageMessageInternalImpl. putStringProperty(SimpleString key, SimpleString value)Deprecated.ObjectCoreMessage. removeAnnotation(SimpleString key)On core there's no delivery annotationObjectCoreMessage. removeProperty(SimpleString key)ObjectMessageInternalImpl. 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.CoreMessageCoreMessage. setAddress(SimpleString address)MessageMessageInternalImpl. setAddress(SimpleString address)Deprecated.voidMessageInternal. setAddressTransient(SimpleString address)Deprecated.voidMessageInternalImpl. setAddressTransient(SimpleString address)Deprecated.CoreMessageCoreMessage. setGroupID(SimpleString groupId)MessageCoreMessage. setLastValueProperty(SimpleString lastValueName)CoreMessageCoreMessage. setReplyTo(SimpleString address)MessageMessageInternalImpl. setReplyTo(SimpleString address)Deprecated. -
Uses of SimpleString in org.apache.activemq.artemis.core.paging
Methods in org.apache.activemq.artemis.core.paging that return SimpleString Modifier and Type Method Description SimpleStringPagingStore. getAddress()SimpleStringPagingStore. getStoreName()SimpleString[]PagingManager. getStoreNames()Methods in org.apache.activemq.artemis.core.paging with parameters of type SimpleString Modifier and Type Method Description voidPagingManager. deletePageStore(SimpleString storeName)PagingStorePagingManager. getPageStore(SimpleString address)Returns the PageStore associated with the address.SequentialFileFactoryPagingStoreFactory. newFileFactory(SimpleString address)PagingStorePagingStoreFactory. 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 Modifier and Type Method Description SimpleStringPagedReferenceImpl. getLastValueProperty() -
Uses of SimpleString in org.apache.activemq.artemis.core.paging.impl
Methods in org.apache.activemq.artemis.core.paging.impl that return SimpleString Modifier and Type Method Description SimpleStringPagingStoreImpl. getAddress()SimpleStringPagingStoreImpl. getStoreName()SimpleString[]PagingManagerImpl. getStoreNames()Methods in org.apache.activemq.artemis.core.paging.impl with parameters of type SimpleString Modifier and Type Method Description voidPagingManagerImpl. deletePageStore(SimpleString storeName)PagingStorePagingManagerImpl. getPageStore(SimpleString rawStoreName)This method creates a new store if not exist.SequentialFileFactoryPagingStoreFactoryDatabase. newFileFactory(SimpleString address)SequentialFileFactoryPagingStoreFactoryNIO. newFileFactory(SimpleString address)PagingStorePagingStoreFactoryDatabase. newStore(SimpleString address, AddressSettings settings)PagingStorePagingStoreFactoryNIO. newStore(SimpleString address, AddressSettings settings)Constructors in org.apache.activemq.artemis.core.paging.impl with parameters of type SimpleString Constructor Description Page(SimpleString storeName, StorageManager storageManager, SequentialFileFactory factory, SequentialFile file, int pageId)PagingManagerImpl(PagingStoreFactory pagingSPI, HierarchicalRepository<AddressSettings> addressSettingsRepository, long maxSize, long maxMessages, SimpleString managementAddress)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)PagingStoreImpl(SimpleString address, ScheduledExecutorService scheduledExecutor, long syncTimeout, PagingManager pagingManager, StorageManager storageManager, SequentialFileFactory fileFactory, PagingStoreFactory storeFactory, SimpleString storeName, AddressSettings addressSettings, ArtemisExecutor executor, ArtemisExecutor ioExecutor, boolean syncNonTransactional) -
Uses of SimpleString in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence that return SimpleString Modifier and Type Method Description static SimpleStringCoreMessageObjectPools. cachedAddressSimpleString(String address, CoreMessageObjectPools coreMessageObjectPools)SimpleStringQueueBindingInfo. getAddress()SimpleStringGroupingInfo. getClusterName()SimpleStringQueueBindingInfo. getFilterString()SimpleStringQueueBindingInfo. getGroupFirstKey()SimpleStringGroupingInfo. getGroupId()SimpleStringQueueBindingInfo. getLastValueKey()SimpleStringAddressBindingInfo. getName()SimpleStringQueueBindingInfo. getQueueName()SimpleStringQueueBindingInfo. getUser()Methods in org.apache.activemq.artemis.core.persistence with parameters of type SimpleString Modifier and Type Method Description voidStorageManager. deleteAddressSetting(SimpleString addressMatch)voidStorageManager. deleteSecuritySetting(SimpleString addressMatch)voidStorageManager. pageClosed(SimpleString storeName, int pageNumber)voidStorageManager. pageDeleted(SimpleString storeName, int pageNumber)voidQueueBindingInfo. replaceQueueName(SimpleString newName)used to rename the queue in case of a duplication during load timevoidQueueBindingInfo. setLastValueKey(SimpleString lastValue)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
Methods in org.apache.activemq.artemis.core.persistence.config that return SimpleString Modifier and Type Method Description SimpleStringPersistedAddressSetting. getAddressMatch()SimpleStringPersistedSecuritySetting. getAddressMatch()Constructors in org.apache.activemq.artemis.core.persistence.config with parameters of type SimpleString Constructor Description PersistedAddressSetting(SimpleString addressMatch, AddressSettings setting) -
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 SimpleString Modifier and Type Field Description protected Map<SimpleString,PersistedAddressSetting>AbstractJournalStorageManager. mapPersistedAddressSettingsprotected Map<SimpleString,PersistedSecuritySetting>AbstractJournalStorageManager. mapPersistedSecuritySettingsMethods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type SimpleString Modifier and Type Method Description voidAbstractJournalStorageManager. deleteAddressSetting(SimpleString addressMatch)voidAbstractJournalStorageManager. deleteSecuritySetting(SimpleString addressMatch)voidJournalStorageManager. pageClosed(SimpleString storeName, int pageNumber)voidJournalStorageManager. pageDeleted(SimpleString storeName, int pageNumber)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 SimpleString Modifier and Type Field Description SimpleStringDuplicateIDEncoding. addressSimpleStringPersistentQueueBindingEncoding. addressSimpleStringGroupingEncoding. clusterNameSimpleStringPersistentQueueBindingEncoding. filterStringSimpleStringPersistentQueueBindingEncoding. groupFirstKeySimpleStringGroupingEncoding. groupIdSimpleStringPersistentQueueBindingEncoding. lastValueKeySimpleStringPersistentAddressBindingEncoding. nameSimpleStringPersistentQueueBindingEncoding. nameSimpleStringPersistentQueueBindingEncoding. userMethods in org.apache.activemq.artemis.core.persistence.impl.journal.codec that return SimpleString Modifier and Type Method Description SimpleStringPersistentQueueBindingEncoding. getAddress()SimpleStringGroupingEncoding. getClusterName()SimpleStringPersistentQueueBindingEncoding. getFilterString()SimpleStringPersistentQueueBindingEncoding. getGroupFirstKey()SimpleStringGroupingEncoding. getGroupId()SimpleStringPersistentQueueBindingEncoding. getLastValueKey()SimpleStringPersistentAddressBindingEncoding. getName()SimpleStringPersistentQueueBindingEncoding. getQueueName()SimpleStringPersistentQueueBindingEncoding. getUser()Methods in org.apache.activemq.artemis.core.persistence.impl.journal.codec with parameters of type SimpleString Modifier and Type Method Description voidPersistentQueueBindingEncoding. replaceQueueName(SimpleString newName)voidPersistentQueueBindingEncoding. setLastValueKey(SimpleString lastValueKey)Constructors in org.apache.activemq.artemis.core.persistence.impl.journal.codec with parameters of type SimpleString Constructor Description DuplicateIDEncoding(SimpleString address, byte[] duplID)GroupingEncoding(long id, SimpleString groupId, SimpleString clusterName)PersistentAddressBindingEncoding(SimpleString name, EnumSet<RoutingType> routingTypes, boolean autoCreated)PersistentQueueBindingEncoding(SimpleString name, SimpleString address, SimpleString filterString, SimpleString user, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean enabled, boolean exclusive, boolean groupRebalance, boolean groupRebalancePauseDispatch, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, byte routingType, boolean configurationManaged, long ringSize) -
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 SimpleString Modifier and Type Method Description voidNullStorageManager. deleteAddressSetting(SimpleString addressMatch)voidNullStorageManager. deleteSecuritySetting(SimpleString addressMatch)voidNullStorageManager. pageClosed(SimpleString storeName, int pageNumber)voidNullStorageManager. pageDeleted(SimpleString storeName, int pageNumber)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 SimpleString Modifier and Type Method Description SimpleStringAddress. getAddress()SimpleStringBinding. getAddress()SimpleStringQueueInfo. getAddress()SimpleString[]Address. getAddressParts()SimpleStringBinding. getClusterName()SimpleStringQueueInfo. getClusterName()SimpleStringQueueInfo. getFilterString()SimpleStringAddressManager. getMatchingQueue(SimpleString address, RoutingType routingType)SimpleStringAddressManager. getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType)SimpleStringPostOffice. getMatchingQueue(SimpleString address, RoutingType routingType)SimpleStringPostOffice. getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType)SimpleStringBindings. getName()SimpleStringBinding. getRoutingName()SimpleStringQueueInfo. getRoutingName()SimpleStringBinding. getUniqueName()Methods in org.apache.activemq.artemis.core.postoffice that return types with arguments of type SimpleString Modifier and Type Method Description Set<SimpleString>AddressManager. getAddresses()Set<SimpleString>PostOffice. getAddresses()List<SimpleString>QueueInfo. getFilterStrings()Methods in org.apache.activemq.artemis.core.postoffice with parameters of type SimpleString Modifier and Type Method Description BindingsBindingsFactory. createBindings(SimpleString address)AddressInfoAddressManager. getAddressInfo(SimpleString address)AddressInfoPostOffice. getAddressInfo(SimpleString address)BindingAddressManager. getBinding(SimpleString queueName)BindingPostOffice. getBinding(SimpleString uniqueName)BindingsPostOffice. getBindingsForAddress(SimpleString address)Differently to lookupBindings, this will always create a new element on the Queue if non-existentBindingsAddressManager. getBindingsForRoutingAddress(SimpleString address)Collection<Binding>AddressManager. getDirectBindings(SimpleString address)Collection<Binding>PostOffice. getDirectBindings(SimpleString address)DuplicateIDCachePostOffice. getDuplicateIDCache(SimpleString address)DuplicateIDCachePostOffice. getDuplicateIDCache(SimpleString address, int idCacheSize)BindingsAddressManager. getExistingBindingsForRoutingAddress(SimpleString address)Collection<Binding>AddressManager. getMatchingBindings(SimpleString address)Collection<Binding>PostOffice. getMatchingBindings(SimpleString address)SimpleStringAddressManager. getMatchingQueue(SimpleString address, RoutingType routingType)SimpleStringAddressManager. getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType)SimpleStringPostOffice. getMatchingQueue(SimpleString address, RoutingType routingType)SimpleStringPostOffice. getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType)default booleanBindingsFactory. isAddressBound(SimpleString address)booleanPostOffice. isAddressBound(SimpleString address)List<Queue>PostOffice. listQueuesForAddress(SimpleString address)BindingsPostOffice. lookupBindingsForAddress(SimpleString address)It will lookup the Binding without creating an item on the Queue if non-existentbooleanQueueInfo. matchesAddress(SimpleString address)AddressInfoAddressManager. removeAddressInfo(SimpleString address)AddressInfoPostOffice. removeAddressInfo(SimpleString address)AddressInfoPostOffice. removeAddressInfo(SimpleString address, boolean force)BindingAddressManager. removeBinding(SimpleString uniqueName, Transaction tx)This will use a Transaction as we need to confirm the queue was removedBindingPostOffice. removeBinding(SimpleString uniqueName, Transaction tx, boolean deleteData)BindingBindings. removeBindingByUniqueName(SimpleString uniqueName)voidPostOffice. sendQueueInfoToQueue(SimpleString queueName, SimpleString address)AddressInfoAddressManager. updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes)it will return null if there are no updates.AddressInfoPostOffice. updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes)QueueBindingPostOffice. 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.QueueBindingPostOffice. 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 SimpleString Modifier and Type Method Description voidQueueInfo. setFilterStrings(List<SimpleString> filterStrings)Constructors in org.apache.activemq.artemis.core.postoffice with parameters of type SimpleString Constructor Description QueueInfo(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 SimpleString Modifier and Type Field Description static SimpleStringPostOfficeImpl. BRIDGE_CACHE_STRstatic SimpleStringPostOfficeImpl. HDR_RESET_QUEUE_DATAstatic SimpleStringPostOfficeImpl. HDR_RESET_QUEUE_DATA_COMPLETEFields in org.apache.activemq.artemis.core.postoffice.impl with type parameters of type SimpleString Modifier and Type Field Description protected ConcurrentMap<SimpleString,Bindings>SimpleAddressManager. mappingsHashMap<Address, Binding>Methods in org.apache.activemq.artemis.core.postoffice.impl that return types with arguments of type SimpleString Modifier and Type Method Description Set<SimpleString>PostOfficeImpl. getAddresses()Set<SimpleString>SimpleAddressManager. getAddresses()ConcurrentMap<SimpleString,DuplicateIDCache>PostOfficeImpl. getDuplicateIDCaches()Map<SimpleString,List<Binding>>BindingsImpl. getRoutingNameBindingMap()debug method: used just for tests!!Methods in org.apache.activemq.artemis.core.postoffice.impl with parameters of type SimpleString Modifier and Type Method Description protected 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)BindingsPostOfficeImpl. createBindings(SimpleString address)AddressInfoPostOfficeImpl. getAddressInfo(SimpleString addressName)AddressInfoSimpleAddressManager. getAddressInfo(SimpleString addressName)BindingPostOfficeImpl. getBinding(SimpleString name)BindingSimpleAddressManager. getBinding(SimpleString bindableName)BindingsPostOfficeImpl. getBindingsForAddress(SimpleString address)BindingsSimpleAddressManager. getBindingsForRoutingAddress(SimpleString address)BindingsWildcardAddressManager. getBindingsForRoutingAddress(SimpleString address)Collection<Binding>PostOfficeImpl. getDirectBindings(SimpleString address)Collection<Binding>SimpleAddressManager. getDirectBindings(SimpleString address)DuplicateIDCachePostOfficeImpl. getDuplicateIDCache(SimpleString address)DuplicateIDCachePostOfficeImpl. getDuplicateIDCache(SimpleString address, int cacheSizeToUse)BindingsSimpleAddressManager. getExistingBindingsForRoutingAddress(SimpleString address)Collection<Binding>PostOfficeImpl. getMatchingBindings(SimpleString address)Collection<Binding>SimpleAddressManager. getMatchingBindings(SimpleString address)SimpleStringPostOfficeImpl. getMatchingQueue(SimpleString address, RoutingType routingType)SimpleStringPostOfficeImpl. getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType)SimpleStringSimpleAddressManager. getMatchingQueue(SimpleString address, RoutingType routingType)SimpleStringSimpleAddressManager. getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType)String[]AddressMap. getPaths(SimpleString address)static DuplicateIDCacheDuplicateIDCaches. inMemory(SimpleString address, int size)booleanPostOfficeImpl. isAddressBound(SimpleString address)List<Queue>PostOfficeImpl. listQueuesForAddress(SimpleString address)BindingsPostOfficeImpl. lookupBindingsForAddress(SimpleString address)static DuplicateIDCacheDuplicateIDCaches. persistent(SimpleString address, int size, StorageManager storageManager)voidAddressMap. put(SimpleString key, T value)voidAddressMap. remove(SimpleString key, T value)AddressInfoPostOfficeImpl. removeAddressInfo(SimpleString address)AddressInfoPostOfficeImpl. removeAddressInfo(SimpleString address, boolean force)AddressInfoSimpleAddressManager. removeAddressInfo(SimpleString address)BindingPostOfficeImpl. removeBinding(SimpleString uniqueName, Transaction tx, boolean deleteData)BindingSimpleAddressManager. removeBinding(SimpleString uniqueName, Transaction tx)BindingWildcardAddressManager. removeBinding(SimpleString uniqueName, Transaction tx)BindingBindingsImpl. 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)AddressInfoPostOfficeImpl. updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes)AddressInfoSimpleAddressManager. updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes)QueueBindingPostOfficeImpl. 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.QueueBindingPostOfficeImpl. 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 SimpleString Constructor Description AddressImpl(SimpleString address)AddressImpl(SimpleString address, WildcardConfiguration wildcardConfiguration)BindingsImpl(SimpleString name, GroupingHandler groupingHandler)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 SimpleString Modifier and Type Field Description static SimpleStringPacketImpl. OLD_QUEUE_PREFIXstatic SimpleStringPacketImpl. OLD_TEMP_QUEUE_PREFIXstatic SimpleStringPacketImpl. OLD_TEMP_TOPIC_PREFIXstatic SimpleStringPacketImpl. OLD_TOPIC_PREFIXMethods in org.apache.activemq.artemis.core.protocol.core.impl that return SimpleString Modifier and Type Method Description SimpleStringPacketImpl. convertName(SimpleString name)Methods in org.apache.activemq.artemis.core.protocol.core.impl that return types with arguments of type SimpleString Modifier and Type Method Description Map<SimpleString,RoutingType>CoreProtocolManager. getPrefixes()Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type SimpleString Modifier and Type Method Description ClientSession.AddressQueryActiveMQSessionContext. addressQuery(SimpleString address)SimpleStringPacketImpl. convertName(SimpleString name)voidActiveMQSessionContext. createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated)voidActiveMQSessionContext. createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated)ClientConsumerInternalActiveMQSessionContext. createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor)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)voidCoreSessionCallback. disconnect(ServerConsumer consumerId, SimpleString queueName)voidRemotingConnectionImpl. killMessage(SimpleString nodeID)voidActiveMQSessionContext. linkFlowControl(SimpleString address, ClientProducerCredits clientProducerCredits)ClientSession.QueueQueryActiveMQSessionContext. queueQuery(SimpleString queueName)voidActiveMQSessionContext. sendFullMessage(ICoreMessage msgI, boolean sendBlocking, SendAcknowledgementHandler handler, SimpleString defaultAddress)voidCoreSessionCallback. sendProducerCreditsFailMessage(int credits, SimpleString address)voidActiveMQSessionContext. sendProducerCreditsMessage(int credits, SimpleString address)voidCoreSessionCallback. sendProducerCreditsMessage(int credits, SimpleString address) -
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 SimpleString Modifier and Type Field Description protected SimpleStringCreateQueueMessage. addressprotected SimpleStringCreateSharedQueueMessage. addressprotected SimpleStringQueueAbstractPacket. addressprotected SimpleStringSessionQueueQueryResponseMessage. addressprotected 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 SimpleString Modifier and Type Field Description protected List<SimpleString>SessionBindingQueryResponseMessage. queueNamesMethods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return SimpleString Modifier and Type Method Description SimpleStringCreateAddressMessage. getAddress()SimpleStringCreateQueueMessage. getAddress()SimpleStringCreateSharedQueueMessage. getAddress()SimpleStringQueueAbstractPacket. getAddress()SimpleStringSessionProducerCreditsFailMessage. getAddress()SimpleStringSessionProducerCreditsMessage. getAddress()SimpleStringSessionQueueQueryResponseMessage. getAddress()SimpleStringSessionRequestProducerCreditsMessage. getAddress()SimpleStringSessionBindingQueryResponseMessage_V4. getDefaultLastValueKey()SimpleStringCreateQueueMessage. getFilterString()SimpleStringCreateSharedQueueMessage. getFilterString()SimpleStringSessionCreateConsumerMessage. getFilterString()SimpleStringSessionQueueQueryResponseMessage. getFilterString()SimpleStringCreateQueueMessage_V2. getGroupFirstKey()SimpleStringCreateSharedQueueMessage_V2. getGroupFirstKey()SimpleStringSessionQueueQueryResponseMessage_V3. getGroupFirstKey()SimpleStringQuorumVoteMessage. getHandler()SimpleStringQuorumVoteReplyMessage. getHandler()SimpleStringCreateQueueMessage_V2. getLastValueKey()SimpleStringCreateSharedQueueMessage_V2. getLastValueKey()SimpleStringSessionQueueQueryResponseMessage_V3. getLastValueKey()SimpleStringSessionQueueQueryResponseMessage. getName()SimpleStringBackupRequestMessage. getNodeID()SimpleStringDisconnectConsumerWithKillMessage. getNodeID()SimpleStringDisconnectMessage. getNodeID()static SimpleStringQueueAbstractPacket. getOldPrefixedAddress(SimpleString address, RoutingType routingType)SimpleStringReplicationSyncFileMessage. getPageStore()SimpleStringCreateQueueMessage. getQueueName()SimpleStringCreateSharedQueueMessage. getQueueName()SimpleStringQueueAbstractPacket. getQueueName()SimpleStringSessionDeleteQueueMessage. getQueueName()SimpleStringScaleDownAnnounceMessage. getScaledDownNodeId()SimpleStringDisconnectMessage_V2. getScaleDownNodeID()SimpleStringReplicationPageEventMessage. getStoreName()SimpleStringScaleDownAnnounceMessage. getTargetNodeId()SimpleStringDisconnectMessage_V3. getTargetNodeID()Methods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return types with arguments of type SimpleString Modifier and Type Method Description List<SimpleString>QueueAbstractPacket. convertQueueNames(int clientVersion, List<SimpleString> queueNames)It converts the givenqueueNamesusing the JMS prefix found onQueueAbstractPacket.addresswhenclientVersion <PacketImpl.ADDRESSING_CHANGE_VERSION.List<SimpleString>SessionBindingQueryResponseMessage. getQueueNames()Methods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type SimpleString Modifier and Type Method Description static SimpleStringQueueAbstractPacket. getOldPrefixedAddress(SimpleString address, RoutingType routingType)voidCreateAddressMessage. 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)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 SimpleString Modifier and Type Method Description 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 SimpleString Constructor Description BackupRequestMessage(int backupSize, SimpleString nodeID)CreateAddressMessage(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated, boolean requiresResponse)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)DisconnectConsumerWithKillMessage(SimpleString nodeID)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, int pageNumber, boolean isDelete)ReplicationSyncFileMessage(AbstractJournalStorageManager.JournalContent content, SimpleString storeName, long id, int size, io.netty.buffer.ByteBuf buffer)ScaleDownAnnounceMessage(SimpleString targetNodeId, SimpleString scaledDownNodeId)SessionBindingQueryMessage(SimpleString address)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)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 SimpleString Constructor Description SessionBindingQueryResponseMessage(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) -
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 SimpleString Modifier and Type Method Description ClientSession.AddressQueryHornetQClientSessionContext. addressQuery(SimpleString address)ClientConsumerInternalHornetQClientSessionContext. createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor)ClientSession.QueueQueryHornetQClientSessionContext. queueQuery(SimpleString queueName) -
Uses of SimpleString in org.apache.activemq.artemis.core.replication
Methods in org.apache.activemq.artemis.core.replication with parameters of type SimpleString Modifier and Type Method Description voidReplicationManager. pageClosed(SimpleString storeName, int pageNumber)voidReplicationManager. pageDeleted(SimpleString storeName, int pageNumber)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 SimpleString Modifier and Type Method Description voidSecurityStore. 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 with parameters of type SimpleString Modifier and Type Method Description voidSecurityStoreImpl. 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 types with arguments of type SimpleString Modifier and Type Method Description Pair<SimpleString,EnumSet<RoutingType>>ServerSession. getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes)Get the canonical (i.e.Map<SimpleString,RouteContextList>RoutingContext. getContexListing()Map<SimpleString,Consumer>Queue. getGroups()List<SimpleString>BindingQueryResult. getQueueNames()Methods in org.apache.activemq.artemis.core.server with parameters of type SimpleString Modifier and Type Method Description voidActiveMQServerLogger_$logger. activatingReplica(SimpleString nodeID)voidActiveMQServerLogger. activatingReplica(SimpleString nodeID)voidRoutingContext. addQueue(SimpleString address, Queue queue)voidRoutingContext. addQueueWithAck(SimpleString address, Queue queue)ActiveMQAddressExistsExceptionActiveMQMessageBundle_$bundle. addressAlreadyExists(SimpleString address)ActiveMQAddressExistsExceptionActiveMQMessageBundle. addressAlreadyExists(SimpleString address)ActiveMQAddressDoesNotExistExceptionActiveMQMessageBundle_$bundle. addressDoesNotExist(SimpleString address)ActiveMQAddressDoesNotExistExceptionActiveMQMessageBundle. addressDoesNotExist(SimpleString address)ActiveMQDeleteAddressExceptionActiveMQMessageBundle_$bundle. addressHasBindings(SimpleString address)ActiveMQDeleteAddressExceptionActiveMQMessageBundle. addressHasBindings(SimpleString address)AddressQueryResultActiveMQServer. addressQuery(SimpleString name)voidActiveMQServerLogger_$logger. AddressSettingsNoDLA(SimpleString name)voidActiveMQServerLogger. AddressSettingsNoDLA(SimpleString name)voidActiveMQServerLogger_$logger. AddressSettingsNoExpiryAddress(SimpleString name)voidActiveMQServerLogger. AddressSettingsNoExpiryAddress(SimpleString name)voidActiveMQServer. addScaledDownNode(SimpleString scaledDownNodeId)voidActiveMQServer. autoRemoveAddressInfo(SimpleString address, SecurityAuth auth)Remove anAddressInfofrom the broker.voidActiveMQServerLogger_$logger. backupServerStarted(String version, SimpleString nodeID)voidActiveMQServerLogger. backupServerStarted(String version, SimpleString nodeID)ActiveMQInternalErrorExceptionActiveMQMessageBundle_$bundle. bindingNotDivert(SimpleString name)ActiveMQInternalErrorExceptionActiveMQMessageBundle. bindingNotDivert(SimpleString name)default BindingQueryResultActiveMQServer. bindingQuery(SimpleString address)BindingQueryResultActiveMQServer. bindingQuery(SimpleString address, boolean newFQQN)voidActiveMQServerLogger_$logger. blockingDiskFull(SimpleString addressName)voidActiveMQServerLogger. blockingDiskFull(SimpleString addressName)voidActiveMQServerLogger_$logger. blockingMessageProduction(SimpleString addressName, String pageInfo)voidActiveMQServerLogger. blockingMessageProduction(SimpleString addressName, String pageInfo)voidActiveMQServerLogger_$logger. blockingViaControl(SimpleString addressName)voidActiveMQServerLogger. blockingViaControl(SimpleString addressName)voidActiveMQServerLogger_$logger. bridgeNoBindings(SimpleString name, SimpleString forwardingAddress, SimpleString address)voidActiveMQServerLogger. bridgeNoBindings(SimpleString name, SimpleString forwardingAddress, SimpleString address)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)ActiveMQIllegalStateExceptionActiveMQMessageBundle_$bundle. cannotCreateConsumerOnClosedSession(SimpleString queueName)ActiveMQIllegalStateExceptionActiveMQMessageBundle. cannotCreateConsumerOnClosedSession(SimpleString queueName)ActiveMQIllegalStateExceptionActiveMQMessageBundle_$bundle. cannotDeleteQueueWithConsumers(SimpleString name, SimpleString queueName, String s)ActiveMQIllegalStateExceptionActiveMQMessageBundle. cannotDeleteQueueWithConsumers(SimpleString name, SimpleString queueName, String s)ActiveMQIllegalStateExceptionActiveMQMessageBundle_$bundle. cannotDeleteQueueWithMessages(SimpleString name, SimpleString queueName, long messageCount)ActiveMQIllegalStateExceptionActiveMQMessageBundle. cannotDeleteQueueWithMessages(SimpleString name, SimpleString queueName, long messageCount)ActiveMQIllegalStateExceptionActiveMQMessageBundle_$bundle. consumerNoReference(Long id, Long messageID, SimpleString name)ActiveMQIllegalStateExceptionActiveMQMessageBundle. consumerNoReference(Long id, Long messageID, SimpleString name)AddressInfoServerSession. createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated)AddressInfoServerSession. createAddress(SimpleString address, RoutingType routingType, boolean autoCreated)ServerConsumerServerSession. createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly)ServerConsumerServerSession. createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage, Integer credits)ServerConsumerServerSession. createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly, boolean supportLargeMessage, Integer credits)QueueActiveMQServer. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary)Deprecated.QueueActiveMQServer. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress)Deprecated.QueueActiveMQServer. 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.QueueActiveMQServer. 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.QueueActiveMQServer. 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.QueueActiveMQServer. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString user, SimpleString filterString, boolean durable, boolean temporary)Deprecated.QueueActiveMQServer. 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.QueueActiveMQServer. 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.QueueActiveMQServer. 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.QueueActiveMQServer. 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.QueueActiveMQServer. 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.QueueActiveMQServer. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)Deprecated.QueueActiveMQServer. createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary)Deprecated.QueueActiveMQServer. createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)Deprecated.QueueActiveMQServer. 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.QueueActiveMQServer. 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.QueueActiveMQServer. 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.QueueActiveMQServer. 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.QueueQueueFactory. createQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated)Deprecated.QueueServerSession. createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable)Deprecated.QueueServerSession. createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)Deprecated.QueueServerSession. createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated)Deprecated.QueueServerSession. createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreated)Deprecated.QueueServerSession. 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.QueueServerSession. 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.QueueServerSession. 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.QueueServerSession. createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)Deprecated.QueueServerSession. createQueue(AddressInfo address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)Deprecated.QueueServerSession. createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)Deprecated.QueueServerSession. 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)QueueActiveMQServer. deployQueue(SimpleString address, SimpleString queue, SimpleString filter, boolean durable, boolean temporary)Deprecated.voidActiveMQServerLogger_$logger. deployTopic(SimpleString topicName)voidActiveMQServerLogger. deployTopic(SimpleString topicName)voidActiveMQServer. destroyDivert(SimpleString name)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_$logger. divertBindingAlreadyExists(SimpleString bindingName)voidActiveMQServerLogger. divertBindingAlreadyExists(SimpleString bindingName)RoutingStatusServerSession. doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue)RoutingStatusServerSession. doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue, RoutingContext routingContext)voidActiveMQServerLogger_$logger. errorExpiringReferencesNoAddress(SimpleString name)voidActiveMQServerLogger. errorExpiringReferencesNoAddress(SimpleString name)voidActiveMQServerLogger_$logger. errorExpiringReferencesNoBindings(SimpleString expiryAddress)voidActiveMQServerLogger. errorExpiringReferencesNoBindings(SimpleString expiryAddress)voidActiveMQServerLogger_$logger. errorRemovingAutoCreatedDestination(Exception e, SimpleString bindingName, String destinationType)voidActiveMQServerLogger. errorRemovingAutoCreatedDestination(Exception e, SimpleString bindingName, String destinationType)voidActiveMQServerLogger_$logger. errorRemovingTempQueue(Exception e, SimpleString bindingName)voidActiveMQServerLogger. errorRemovingTempQueue(Exception e, SimpleString bindingName)AddressQueryResultServerSession. executeAddressQuery(SimpleString name)BindingQueryResultServerSession. executeBindingQuery(SimpleString address)QueueQueryResultServerSession. executeQueueQuery(SimpleString name)voidActiveMQServerLogger_$logger. failedToDealWithObjectProperty(SimpleString property, String exceptionMessage)voidActiveMQServerLogger. failedToDealWithObjectProperty(SimpleString property, String exceptionMessage)voidActiveMQServerLogger_$logger. failedToPurgeQueue(Exception e, SimpleString bindingName)voidActiveMQServerLogger. failedToPurgeQueue(Exception e, SimpleString bindingName)voidActiveMQServerLogger_$logger. federationBindingsLookupError(Throwable e, SimpleString address)voidActiveMQServerLogger. federationBindingsLookupError(Throwable e, SimpleString address)voidServerMessage. forceAddress(SimpleString address)Deprecated.This will force encoding of the address, and will re-check the buffer This is to avoid setMessageTransient which set the address without changing the bufferAddressInfoServerSession. getAddress(SimpleString address)Pair<SimpleString,EnumSet<RoutingType>>ServerSession. getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes)Get the canonical (i.e.AddressInfoActiveMQServer. getAddressInfo(SimpleString address)RouteContextListRoutingContext. getContextListing(SimpleString address)intServerSession. getDefaultConsumerWindowSize(SimpleString address)List<Queue>RoutingContext. getDurableQueues(SimpleString address)SimpleStringServerSession. getMatchingQueue(SimpleString address, RoutingType routingType)SimpleStringServerSession. getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType)List<Queue>RoutingContext. getNonDurableQueues(SimpleString address)SimpleStringServerSession. getPrefix(SimpleString address)Get the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.RoutingTypeServerSession. getRoutingTypeFromPrefix(SimpleString address, RoutingType defaultRoutingType)QueueConfig.BuilderQueueConfig.Builder. groupFirstKey(SimpleString groupFirstKey)Deprecated.voidActiveMQServerLogger_$logger. groupingQueueRemoved(int size, SimpleString clusterName)voidActiveMQServerLogger. groupingQueueRemoved(int size, SimpleString clusterName)booleanActiveMQServer. hasScaledDown(SimpleString scaledDownNodeId)voidActiveMQServerLogger_$logger. initiatingQuorumVote(SimpleString vote)voidActiveMQServerLogger. initiatingQuorumVote(SimpleString vote)ActiveMQInvalidFilterExpressionExceptionActiveMQMessageBundle_$bundle. invalidFilter(Throwable e, SimpleString filter)ActiveMQInvalidFilterExpressionExceptionActiveMQMessageBundle. invalidFilter(Throwable e, SimpleString filter)voidActiveMQServerLogger_$logger. invalidFilter(SimpleString filter)voidActiveMQServerLogger. invalidFilter(SimpleString filter)ActiveMQInvalidQueueConfigurationActiveMQMessageBundle_$bundle. invalidQueueConfiguration(SimpleString address, SimpleString queueName, String queuePropertyName, Object expectedValue, Object actualValue)ActiveMQInvalidQueueConfigurationActiveMQMessageBundle. invalidQueueConfiguration(SimpleString address, SimpleString queueName, String queuePropertyName, Object expectedValue, Object actualValue)ActiveMQIllegalStateExceptionActiveMQMessageBundle_$bundle. invalidQueueName(SimpleString queueName)ActiveMQIllegalStateExceptionActiveMQMessageBundle. invalidQueueName(SimpleString queueName)QueueConfig.BuilderQueueConfig.Builder. lastValueKey(SimpleString lastValueKey)Deprecated.QueueActiveMQServer. locateQueue(SimpleString queueName)ActiveMQQueueMaxConsumerLimitReachedActiveMQMessageBundle_$bundle. maxConsumerLimitReachedForQueue(SimpleString address, SimpleString queueName)ActiveMQQueueMaxConsumerLimitReachedActiveMQMessageBundle. maxConsumerLimitReachedForQueue(SimpleString address, SimpleString queueName)voidActiveMQServerLogger_$logger. messageExceededMaxDelivery(MessageReference ref, SimpleString name)voidActiveMQServerLogger. messageExceededMaxDelivery(MessageReference ref, SimpleString name)voidActiveMQServerLogger_$logger. messageExceededMaxDeliveryNoDLA(MessageReference ref, SimpleString name)voidActiveMQServerLogger. messageExceededMaxDeliveryNoDLA(MessageReference ref, SimpleString name)voidActiveMQServerLogger_$logger. messageExceededMaxDeliverySendtoDLA(MessageReference ref, SimpleString name, SimpleString simpleString)voidActiveMQServerLogger. messageExceededMaxDeliverySendtoDLA(MessageReference ref, SimpleString name, SimpleString simpleString)voidActiveMQServerLogger_$logger. 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)ActiveMQInternalErrorExceptionActiveMQMessageBundle_$bundle. noBindingForDivert(SimpleString name)ActiveMQInternalErrorExceptionActiveMQMessageBundle. noBindingForDivert(SimpleString name)voidActiveMQServerLogger_$logger. noDLA(SimpleString address)voidActiveMQServerLogger. noDLA(SimpleString address)voidActiveMQServerLogger_$logger. noMatchingBindingsOnDLAWithAutoCreateDLAResources(SimpleString address, String message)voidActiveMQServerLogger. noMatchingBindingsOnDLAWithAutoCreateDLAResources(SimpleString address, String message)voidActiveMQServerLogger_$logger. noQueueIdDefined(Message message, Message messageCopy, SimpleString idsHeaderName)voidActiveMQServerLogger. noQueueIdDefined(Message message, Message messageCopy, SimpleString idsHeaderName)ActiveMQNonExistentQueueExceptionActiveMQMessageBundle_$bundle. noSuchQueue(SimpleString queueName)ActiveMQNonExistentQueueExceptionActiveMQMessageBundle. noSuchQueue(SimpleString queueName)voidActiveMQServerLogger_$logger. pageStoreDropMessages(SimpleString storeName, String sizeInfo)voidActiveMQServerLogger. pageStoreDropMessages(SimpleString storeName, String sizeInfo)voidActiveMQServerLogger_$logger. pageStoreStart(SimpleString storeName, String sizeInfo)voidActiveMQServerLogger. pageStoreStart(SimpleString storeName, String sizeInfo)voidActiveMQServerLogger_$logger. pageStoreStop(SimpleString storeName, String pageInfo)voidActiveMQServerLogger. pageStoreStop(SimpleString storeName, String pageInfo)voidActiveMQServerLogger_$logger. pageStoreTimeout(SimpleString address)voidActiveMQServerLogger. pageStoreTimeout(SimpleString address)voidActiveMQServerLogger_$logger. pageSubscriptionCouldntLoad(long transactionID, PagePosition position, SimpleString address, SimpleString name)voidActiveMQServerLogger. pageSubscriptionCouldntLoad(long transactionID, PagePosition position, SimpleString address, SimpleString name)voidActiveMQServerLogger_$logger. problemCleaningPageAddress(Exception e, SimpleString address)voidActiveMQServerLogger. problemCleaningPageAddress(Exception e, SimpleString address)ActiveMQQueueExistsExceptionActiveMQMessageBundle_$bundle. queueAlreadyExists(SimpleString queueName, SimpleString addressName)ActiveMQQueueExistsExceptionActiveMQMessageBundle. queueAlreadyExists(SimpleString queueName, SimpleString addressName)QueueQueryResultActiveMQServer. queueQuery(SimpleString name)ActiveMQInvalidTransientQueueUseExceptionActiveMQMessageBundle_$bundle. queueSubscriptionBelongsToDifferentAddress(SimpleString queueName)ActiveMQInvalidTransientQueueUseExceptionActiveMQMessageBundle. queueSubscriptionBelongsToDifferentAddress(SimpleString queueName)ActiveMQInvalidTransientQueueUseExceptionActiveMQMessageBundle_$bundle. queueSubscriptionBelongsToDifferentFilter(SimpleString queueName)ActiveMQInvalidTransientQueueUseExceptionActiveMQMessageBundle. queueSubscriptionBelongsToDifferentFilter(SimpleString queueName)voidActiveMQServerLogger_$logger. 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.SimpleStringServerSession. 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_$logger. serverStarted(String fullVersion, String name, SimpleString nodeId, String identity)voidActiveMQServerLogger. serverStarted(String fullVersion, String name, SimpleString nodeId, String identity)voidActiveMQServerLogger_$logger. 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_$logger. unableToCreateManagementNotificationAddress(SimpleString addressName, Exception e)voidActiveMQServerLogger. unableToCreateManagementNotificationAddress(SimpleString addressName, Exception e)voidActiveMQServerLogger_$logger. unableToDeleteGroupBindings(Exception e, SimpleString groupId)voidActiveMQServerLogger. unableToDeleteGroupBindings(Exception e, SimpleString groupId)voidActiveMQServerLogger_$logger. unableToStartBridge(Exception e, SimpleString name)voidActiveMQServerLogger. unableToStartBridge(Exception e, SimpleString name)voidActiveMQServerLogger_$logger. unableToStartClusterConnection(Exception e, SimpleString name)voidActiveMQServerLogger. unableToStartClusterConnection(Exception e, SimpleString name)voidActiveMQServerLogger_$logger. unableToUndeployAddress(SimpleString addressName, String reason)voidActiveMQServerLogger. unableToUndeployAddress(SimpleString addressName, String reason)voidActiveMQServerLogger_$logger. unableToUndeployQueue(SimpleString queueName, String reason)voidActiveMQServerLogger. unableToUndeployQueue(SimpleString queueName, String reason)voidActiveMQServerLogger_$logger. unblockingMessageProduction(SimpleString addressName, String sizeInfo)voidActiveMQServerLogger. unblockingMessageProduction(SimpleString addressName, String sizeInfo)voidActiveMQServerLogger_$logger. unblockingViaControl(SimpleString addressName)voidActiveMQServerLogger. unblockingViaControl(SimpleString addressName)voidActiveMQServerLogger_$logger. undeployAddress(SimpleString addressName)voidActiveMQServerLogger. undeployAddress(SimpleString addressName)voidActiveMQServerLogger_$logger. undeployQueue(SimpleString queueName)voidActiveMQServerLogger. undeployQueue(SimpleString queueName)ActiveMQUnexpectedRoutingTypeForAddressActiveMQMessageBundle_$bundle. unexpectedRoutingTypeForAddress(SimpleString address, RoutingType expectedRoutingType, Set<RoutingType> supportedRoutingTypes)ActiveMQUnexpectedRoutingTypeForAddressActiveMQMessageBundle. unexpectedRoutingTypeForAddress(SimpleString address, RoutingType expectedRoutingType, Set<RoutingType> supportedRoutingTypes)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.BuilderQueueConfig.Builder. user(SimpleString user)Deprecated.ActiveMQSecurityExceptionActiveMQMessageBundle_$bundle. userNoPermissions(String username, CheckType checkType, SimpleString address)ActiveMQSecurityExceptionActiveMQMessageBundle. userNoPermissions(String username, CheckType checkType, SimpleString address)ActiveMQSecurityExceptionActiveMQMessageBundle_$bundle. userNoPermissionsQueue(String username, CheckType checkType, SimpleString queue, SimpleString address)ActiveMQSecurityExceptionActiveMQMessageBundle. userNoPermissionsQueue(String username, CheckType checkType, SimpleString queue, SimpleString address)Method parameters in org.apache.activemq.artemis.core.server with type arguments of type SimpleString Modifier and Type Method Description ServerSessionActiveMQServer. 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)This is to be used in places where security is bypassed, like internal sessions, broker connections, etc...ServerSessionActiveMQServer. 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)Constructors in org.apache.activemq.artemis.core.server with parameters of type SimpleString Constructor Description AddressQueryResult(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)QueueQueryResult(SimpleString name, SimpleString address, boolean durable, boolean temporary, SimpleString filterString, int consumerCount, long messageCount, boolean autoCreateQueues, boolean exists, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType, int maxConsumers, Boolean exclusive, Boolean 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)Constructor parameters in org.apache.activemq.artemis.core.server with type arguments of type SimpleString Constructor Description 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) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.cluster
Methods in org.apache.activemq.artemis.core.server.cluster that return SimpleString Modifier and Type Method Description SimpleStringBridge. getForwardingAddress()SimpleStringBridge. getName()SimpleStringClusterConnection. getName()SimpleStringClusterController. getNodeID()Methods in org.apache.activemq.artemis.core.server.cluster that return types with arguments of type SimpleString Modifier and Type Method Description Map<SimpleString,ServerLocatorInternal>ClusterController. getLocators()Methods in org.apache.activemq.artemis.core.server.cluster with parameters of type SimpleString Modifier and Type Method Description voidClusterController. 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)ServerLocatorClusterController. 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 SimpleString Modifier and Type Method Description booleanColocatedHAManager. 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 SimpleString Modifier and Type Method Description SimpleStringRemoteQueueBindingImpl. getAddress()SimpleStringRemoteQueueBindingImpl. getClusterName()SimpleStringBridgeImpl. getForwardingAddress()SimpleStringBridgeImpl. getName()SimpleStringClusterConnectionImpl. getName()SimpleStringRemoteQueueBindingImpl. getRoutingName()SimpleStringClusterConnectionImpl. getSfQueueName(String nodeID)SimpleStringRemoteQueueBindingImpl. getUniqueName()Methods in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type SimpleString Modifier and Type Method Description voidRemoteQueueBindingImpl. addConsumer(SimpleString filterString)protected MessageBridgeImpl. beforeForward(Message message, SimpleString forwardingAddress)protected 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 SimpleString Constructor Description ClusterConnectionBridge(ClusterConnection clusterConnection, ClusterManager clusterManager, ServerLocatorInternal targetLocator, ServerLocatorInternal discoveryLocator, int initialConnectAttempts, int reconnectAttempts, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, long targetNodeEventUID, String targetNodeID, SimpleString name, Queue queue, Executor executor, Filter filterString, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, TransformerConfiguration transformer, boolean useDuplicateDetection, String user, String password, ActiveMQServer server, SimpleString managementAddress, SimpleString managementNotificationAddress, MessageFlowRecord flowRecord, TransportConfiguration connector, String storeAndForwardPrefix, StorageManager storageManager)ClusterConnectionImpl(ClusterManager manager, DiscoveryGroupConfiguration dg, TransportConfiguration connector, SimpleString name, SimpleString address, int minLargeMessageSize, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int initialConnectAttempts, int reconnectAttempts, long callTimeout, long callFailoverTimeout, boolean useDuplicateDetection, MessageLoadBalancingType messageLoadBalancingType, int confirmationWindowSize, int producerWindowSize, ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ManagementService managementService, ScheduledExecutorService scheduledExecutor, int maxHops, NodeManager nodeManager, String clusterUser, String clusterPassword, boolean allowDirectConnectionsOnly, long clusterNotificationInterval, int clusterNotificationAttempts)ClusterConnectionImpl(ClusterManager manager, TransportConfiguration[] staticTranspConfigs, TransportConfiguration connector, SimpleString name, SimpleString address, int minLargeMessageSize, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int initialConnectAttempts, int reconnectAttempts, long callTimeout, long callFailoverTimeout, boolean useDuplicateDetection, MessageLoadBalancingType messageLoadBalancingType, int confirmationWindowSize, int producerWindowSize, ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ManagementService managementService, ScheduledExecutorService scheduledExecutor, int maxHops, NodeManager nodeManager, String clusterUser, String clusterPassword, boolean allowDirectConnectionsOnly, long clusterNotificationInterval, int clusterNotificationAttempts)RemoteQueueBindingImpl(long id, SimpleString address, SimpleString uniqueName, SimpleString routingName, Long remoteQueueID, SimpleString filterString, Queue storeAndForwardQueue, SimpleString bridgeName, int distance, MessageLoadBalancingType messageLoadBalancingType) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.cluster.qourum
Fields in org.apache.activemq.artemis.core.server.cluster.qourum declared as SimpleString Modifier and Type Field Description static SimpleStringQuorumVoteServerConnect. LIVE_FAILOVER_VOTEMethods in org.apache.activemq.artemis.core.server.cluster.qourum that return SimpleString Modifier and Type Method Description SimpleStringQuorumVote. getName()the name of this quorum vote, used for identifying the correctQuorumVoteHandlerSimpleStringQuorumVoteHandler. getQuorumName()the name of the quorum voteConstructors in org.apache.activemq.artemis.core.server.cluster.qourum with parameters of type SimpleString Constructor Description QuorumVote(SimpleString name) -
Uses of SimpleString in org.apache.activemq.artemis.core.server.federation
Fields in org.apache.activemq.artemis.core.server.federation declared as SimpleString Modifier and Type Field Description protected SimpleStringAbstractFederationStream. nameMethods in org.apache.activemq.artemis.core.server.federation that return SimpleString Modifier and Type Method Description SimpleStringFederatedConsumerKey. getAddress()SimpleStringFederatedConsumerKey. getFilterString()SimpleStringFederatedConsumerKey. getFqqn()SimpleStringAbstractFederationStream. getName()SimpleStringFederation. getName()SimpleStringFederationStream. getName()SimpleStringFederatedConsumerKey. getQueueFilterString()SimpleStringFederatedConsumerKey. 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 SimpleString Modifier and Type Field Description static SimpleStringFederatedAddress. HDR_HOPSMethods in org.apache.activemq.artemis.core.server.federation.address that return SimpleString Modifier and Type Method Description SimpleStringFederatedAddressConsumerKey. getAddress()SimpleStringFederatedAddressConsumerKey. getFilterString()SimpleStringFederatedAddressConsumerKey. getFqqn()SimpleStringFederatedAddressConsumerKey. getQueueFilterString()SimpleStringFederatedAddressConsumerKey. getQueueName()Methods in org.apache.activemq.artemis.core.server.federation.address with parameters of type SimpleString Modifier and Type Method Description voidFederatedAddress. 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 SimpleString Modifier and Type Method Description SimpleStringFederatedQueueConsumerKey. getAddress()SimpleStringFederatedQueueConsumerKey. getFilterString()SimpleStringFederatedQueueConsumerKey. getFqqn()SimpleStringFederatedQueueConsumerKey. getQueueFilterString()SimpleStringFederatedQueueConsumerKey. getQueueName() -
Uses of SimpleString in org.apache.activemq.artemis.core.server.group
Methods in org.apache.activemq.artemis.core.server.group that return SimpleString Modifier and Type Method Description SimpleStringGroupingHandler. getName()Methods in org.apache.activemq.artemis.core.server.group with parameters of type SimpleString Modifier and Type Method Description voidGroupingHandler. forceRemove(SimpleString groupid, SimpleString clusterName)this will force a removal of the group everywhere with an unproposal (dinstance=0).ResponseGroupingHandler. 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 SimpleString Modifier and Type Field Description protected SimpleStringGroupHandlingAbstract. addressMethods in org.apache.activemq.artemis.core.server.group.impl that return SimpleString Modifier and Type Method Description SimpleStringGroupingHandlerConfiguration. getAddress()SimpleStringResponse. getAlternativeClusterName()SimpleStringResponse. getChosenClusterName()SimpleStringGroupBinding. getClusterName()SimpleStringProposal. getClusterName()SimpleStringResponse. getClusterName()SimpleStringGroupBinding. getGroupId()SimpleStringProposal. getGroupId()SimpleStringResponse. getGroupId()SimpleStringGroupingHandlerConfiguration. getName()SimpleStringLocalGroupingHandler. getName()SimpleStringRemoteGroupingHandler. getName()Methods in org.apache.activemq.artemis.core.server.group.impl with parameters of type SimpleString Modifier and Type Method Description protected voidGroupHandlingAbstract. fireUnproposed(SimpleString groupID)voidGroupHandlingAbstract. forceRemove(SimpleString groupid, SimpleString clusterName)ResponseLocalGroupingHandler. getProposal(SimpleString fullID, boolean touchTime)ResponseRemoteGroupingHandler. 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)GroupingHandlerConfigurationGroupingHandlerConfiguration. setAddress(SimpleString address)GroupingHandlerConfigurationGroupingHandlerConfiguration. setName(SimpleString name)Constructors in org.apache.activemq.artemis.core.server.group.impl with parameters of type SimpleString Constructor Description GroupBinding(long id, SimpleString groupId, SimpleString clusterName)GroupBinding(SimpleString groupId, SimpleString clusterName)GroupHandlingAbstract(Executor executor, ManagementService managementService, SimpleString address)LocalGroupingHandler(ExecutorFactory executorFactory, ScheduledExecutorService scheduledExecutor, ManagementService managementService, SimpleString name, SimpleString address, StorageManager storageManager, long timeout, long groupTimeout, long reaperPeriod)Proposal(SimpleString groupId, SimpleString clusterName)RemoteGroupingHandler(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 SimpleString Modifier and Type Field Description protected Map<SimpleString,Pair<Object,AtomicLong>>ServerSessionImpl. targetAddressInfosprotected Map<SimpleString,ServerSessionImpl.TempQueueCleanerUpper>ServerSessionImpl. tempQueueCleannerUppersMethods in org.apache.activemq.artemis.core.server.impl that return types with arguments of type SimpleString Modifier and Type Method Description Map<SimpleString,Pair<Object,AtomicLong>>ServerSessionImpl. cloneTargetAddresses()Pair<SimpleString,EnumSet<RoutingType>>ServerSessionImpl. getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes)Map<SimpleString,RouteContextList>RoutingContextImpl. getContexListing()Map<SimpleString,Consumer>QueueImpl. getGroups()Set<SimpleString>LastValueQueue. getLastValueKeys()Map<SimpleString,ServerSessionImpl.TempQueueCleanerUpper>ServerSessionImpl. getTempQueueCleanUppers()Map<SimpleString,C>BucketMessageGroups. toMap()Map<SimpleString,C>MessageGroups. toMap()Methods in org.apache.activemq.artemis.core.server.impl with parameters of type SimpleString Modifier and Type Method Description voidRoutingContextImpl. addQueue(SimpleString address, Queue queue)voidRoutingContextImpl. addQueueWithAck(SimpleString address, Queue queue)AddressQueryResultActiveMQServerImpl. addressQuery(SimpleString name)voidActiveMQServerImpl. addScaledDownNode(SimpleString scaledDownNodeId)voidActiveMQServerImpl. autoRemoveAddressInfo(SimpleString address, SecurityAuth auth)BindingQueryResultActiveMQServerImpl. bindingQuery(SimpleString address, boolean newFQQN)voidActiveMQServerImpl. callPostQueueCreationCallbacks(SimpleString queueName)voidActiveMQServerImpl. callPostQueueDeletionCallbacks(SimpleString address, SimpleString queueName)AddressInfoAddressInfo. create(SimpleString name, RoutingType routingType)AddressInfoServerSessionImpl. createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated)AddressInfoServerSessionImpl. createAddress(SimpleString address, RoutingType routingType, boolean autoCreated)ServerConsumerServerSessionImpl. createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly)ServerConsumerServerSessionImpl. createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage, Integer credits)ServerConsumerServerSessionImpl. createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly, boolean supportLargeMessage, Integer credits)QueueActiveMQServerImpl. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)Deprecated.QueueActiveMQServerImpl. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress)Deprecated.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString user, SimpleString filterString, boolean durable, boolean temporary)Deprecated.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)Deprecated.QueueActiveMQServerImpl. createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)Deprecated.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)Deprecated.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. 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.QueueActiveMQServerImpl. 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.QueueQueueFactoryImpl. createQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated)Deprecated.QueueServerSessionImpl. createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable)Deprecated.QueueServerSessionImpl. createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)Deprecated.QueueServerSessionImpl. createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated)Deprecated.QueueServerSessionImpl. createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreated)Deprecated.QueueServerSessionImpl. 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.QueueServerSessionImpl. 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.QueueServerSessionImpl. 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.QueueServerSessionImpl. createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)Deprecated.QueueServerSessionImpl. createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable)Deprecated.QueueServerSessionImpl. createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated)Deprecated.QueueServerSessionImpl. 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.QueueServerSessionImpl. 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)QueueActiveMQServerImpl. deployQueue(SimpleString address, SimpleString resourceName, SimpleString filterString, boolean durable, boolean temporary)Deprecated.voidActiveMQServerImpl. destroyDivert(SimpleString name)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)RoutingStatusServerSessionImpl. doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue)RoutingStatusServerSessionImpl. doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue, RoutingContext routingContext)AddressQueryResultServerSessionImpl. executeAddressQuery(SimpleString name)BindingQueryResultServerSessionImpl. executeBindingQuery(SimpleString address)QueueQueryResultServerSessionImpl. executeQueueQuery(SimpleString name)CBucketMessageGroups. get(SimpleString key)CMessageGroups. get(SimpleString key)AddressInfoServerSessionImpl. getAddress(SimpleString address)Pair<SimpleString,EnumSet<RoutingType>>ServerSessionImpl. getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes)AddressInfoActiveMQServerImpl. getAddressInfo(SimpleString address)RouteContextListRoutingContextImpl. getContextListing(SimpleString address)intServerSessionImpl. getDefaultConsumerWindowSize(SimpleString address)List<Queue>RoutingContextImpl. getDurableQueues(SimpleString address)SimpleStringServerSessionImpl. getMatchingQueue(SimpleString address, RoutingType routingType)SimpleStringServerSessionImpl. getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType)List<Queue>RoutingContextImpl. getNonDurableQueues(SimpleString address)SimpleStringServerSessionImpl. getPrefix(SimpleString address)RoutingTypeServerSessionImpl. getRoutingTypeFromPrefix(SimpleString address, RoutingType defaultRoutingType)booleanActiveMQServerImpl. hasScaledDown(SimpleString scaledDownNodeId)QueueActiveMQServerImpl. 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)QueueQueryResultActiveMQServerImpl. queueQuery(SimpleString name)CBucketMessageGroups. remove(SimpleString key)CMessageGroups. remove(SimpleString key)voidActiveMQServerImpl. removeAddressInfo(SimpleString address, SecurityAuth auth)voidActiveMQServerImpl. removeAddressInfo(SimpleString address, SecurityAuth auth, boolean force)SimpleStringServerSessionImpl. 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 SimpleString Modifier and Type Method Description ServerSessionActiveMQServerImpl. 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)ServerSessionActiveMQServerImpl. 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)AddressInfoAddressInfo. 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)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 SimpleString Constructor Description AddressInfo(SimpleString name)AddressInfo(SimpleString name, EnumSet<RoutingType> routingTypes)Creates an AddressInfo object with a Set of routing typesAddressInfo(SimpleString name, RoutingType routingType)Creates an AddressInfo object with a single RoutingType associated with it.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)LastValueQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean purgeOnNoConsumers, SimpleString lastValueKey, Boolean nonDestructive, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean configurationManaged, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)Deprecated.QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)Deprecated.QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)Deprecated.QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean purgeOnNoConsumers, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean configurationManaged, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)Deprecated.QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean purgeOnNoConsumers, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean configurationManaged, Long ringSize, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)Deprecated.QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean purgeOnNoConsumers, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean configurationManaged, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)Deprecated.QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean purgeOnNoConsumers, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)Deprecated.QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)Deprecated.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)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 SimpleString Constructor Description ServerSessionImpl(String name, String username, String password, String validatedUser, int minLargeMessageSize, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean strictUpdateDeliveryCount, boolean xa, RemotingConnection remotingConnection, StorageManager storageManager, PostOffice postOffice, ResourceManager resourceManager, SecurityStore securityStore, ManagementService managementService, ActiveMQServer server, SimpleString managementAddress, SimpleString defaultAddress, SessionCallback callback, OperationContext context, PagingManager pagingManager, Map<SimpleString,RoutingType> prefixes, String securityDomain) -
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 Modifier and Type Method Description SimpleStringJdbcNodeManager. readNodeId() -
Uses of SimpleString in org.apache.activemq.artemis.core.server.management
Methods in org.apache.activemq.artemis.core.server.management that return SimpleString Modifier and Type Method Description SimpleStringManagementService. getManagementAddress()SimpleStringManagementService. getManagementNotificationAddress()Methods in org.apache.activemq.artemis.core.server.management with parameters of type SimpleString Modifier and Type Method Description voidManagementService. 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 SimpleString Modifier and Type Method Description SimpleStringManagementServiceImpl. getManagementAddress()SimpleStringManagementServiceImpl. getManagementNotificationAddress()Methods in org.apache.activemq.artemis.core.server.management.impl with parameters of type SimpleString Modifier and Type Method Description voidManagementServiceImpl. 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 SimpleString Modifier and Type Method Description voidMirrorController. 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 SimpleString Modifier and Type Method Description default 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 expiredMethod parameters in org.apache.activemq.artemis.core.server.plugin with type arguments of type SimpleString Modifier and Type Method Description default 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 SimpleString Modifier and Type Method Description voidLoggingActiveMQServerPluginLogger_$logger. afterDeliver(String messageID, SimpleString queueAddress, SimpleString queueName, String consumerSessionID, long consumerID)voidLoggingActiveMQServerPluginLogger. afterDeliver(String messageID, SimpleString queueAddress, SimpleString queueName, String consumerSessionID, long consumerID)voidLoggingActiveMQServerPluginLogger_$logger. 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_$logger. 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_$logger. 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_$logger. 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_$logger. 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 SimpleString Modifier and Type Method Description voidLoggingActiveMQServerPlugin. 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 SimpleString Modifier and Type Method Description voidServerMessageImpl. forceAddress(SimpleString address)Deprecated.This will force encoding of the address, and will re-check the buffer This is to avoid setMessageTransient which set the address without changing the buffer -
Uses of SimpleString in org.apache.activemq.artemis.core.settings.impl
Fields in org.apache.activemq.artemis.core.settings.impl declared as SimpleString Modifier and Type Field Description static SimpleStringAddressSettings. DEFAULT_DEAD_LETTER_QUEUE_PREFIXstatic SimpleStringAddressSettings. DEFAULT_DEAD_LETTER_QUEUE_SUFFIXstatic SimpleStringAddressSettings. DEFAULT_EXPIRY_QUEUE_PREFIXstatic SimpleStringAddressSettings. DEFAULT_EXPIRY_QUEUE_SUFFIXstatic SimpleStringResourceLimitSettings. DEFAULT_MATCHMethods in org.apache.activemq.artemis.core.settings.impl that return SimpleString Modifier and Type Method Description SimpleStringAddressSettings. getDeadLetterAddress()SimpleStringAddressSettings. getDeadLetterQueuePrefix()SimpleStringAddressSettings. getDeadLetterQueueSuffix()SimpleStringAddressSettings. getDefaultGroupFirstKey()SimpleStringAddressSettings. getDefaultLastValueKey()SimpleStringAddressSettings. getExpiryAddress()SimpleStringAddressSettings. getExpiryQueuePrefix()SimpleStringAddressSettings. getExpiryQueueSuffix()SimpleStringResourceLimitSettings. getMatch()Methods in org.apache.activemq.artemis.core.settings.impl with parameters of type SimpleString Modifier and Type Method Description AddressSettingsAddressSettings. setDeadLetterAddress(SimpleString deadLetterAddress)AddressSettingsAddressSettings. setDeadLetterQueuePrefix(SimpleString value)AddressSettingsAddressSettings. setDeadLetterQueueSuffix(SimpleString value)AddressSettingsAddressSettings. setDefaultGroupFirstKey(SimpleString defaultGroupFirstKey)AddressSettingsAddressSettings. setDefaultLastValueKey(SimpleString defaultLastValueKey)AddressSettingsAddressSettings. setExpiryAddress(SimpleString expiryAddress)AddressSettingsAddressSettings. setExpiryQueuePrefix(SimpleString value)AddressSettingsAddressSettings. setExpiryQueueSuffix(SimpleString value)voidResourceLimitSettings. setMatch(SimpleString match) -
Uses of SimpleString in org.apache.activemq.artemis.jms.client
Fields in org.apache.activemq.artemis.jms.client declared as SimpleString Modifier and Type Field Description static SimpleStringActiveMQConnection. CONNECTION_ID_PROPERTY_NAMEstatic SimpleStringActiveMQMessage. OLD_QUEUE_QUALIFIED_PREFIXstatic SimpleStringActiveMQMessage. OLD_TEMP_QUEUE_QUALIFED_PREFIXstatic SimpleStringActiveMQMessage. OLD_TEMP_TOPIC_QUALIFED_PREFIXstatic SimpleStringActiveMQMessage. OLD_TOPIC_QUALIFIED_PREFIXMethods in org.apache.activemq.artemis.jms.client that return SimpleString Modifier and Type Method Description protected 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)SimpleStringActiveMQDestination. getSimpleAddress()SimpleStringActiveMQConnection. getUID()Constructors in org.apache.activemq.artemis.jms.client with parameters of type SimpleString Constructor Description ActiveMQDestination(SimpleString address, String name, ActiveMQDestination.TYPE type, ActiveMQSession session)Deprecated.ActiveMQDestination(SimpleString address, ActiveMQDestination.TYPE type, ActiveMQSession session)ActiveMQMessageConsumer(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 SimpleString Modifier and Type Method Description protected SimpleStringActiveMQBytesCompatibleMessage. checkPrefix(SimpleString address)SimpleStringActiveMQCompatibleMessage. 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 SimpleString Modifier and Type Method Description protected SimpleStringActiveMQBytesCompatibleMessage. checkPrefix(SimpleString address)SimpleStringActiveMQCompatibleMessage. 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 Modifier and Type Field Description static SimpleStringJMSNotificationType. MESSAGE -
Uses of SimpleString in org.apache.activemq.artemis.reader
Fields in org.apache.activemq.artemis.reader declared as SimpleString Modifier and Type Field Description static SimpleStringMessageUtil. CONNECTION_ID_PROPERTY_NAMEstatic SimpleStringMessageUtil. CORRELATIONID_HEADER_NAMEstatic SimpleStringMessageUtil. JMSstatic SimpleStringMessageUtil. JMS_static SimpleStringMessageUtil. JMSXstatic SimpleStringMessageUtil. REPLYTO_HEADER_NAMEstatic SimpleStringMessageUtil. TYPE_HEADER_NAMEMethods in org.apache.activemq.artemis.reader that return SimpleString Modifier and Type Method Description static 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 SimpleString Modifier and Type Method Description static 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 SimpleString Modifier and Type Method Description ObjectFilterable. getProperty(SimpleString name)Extracts the named message propertyConstructors in org.apache.activemq.artemis.selector.filter with parameters of type SimpleString Constructor Description PropertyExpression(SimpleString name) -
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 SimpleString Modifier and Type Method Description Map<SimpleString,RoutingType>AbstractProtocolManager. getPrefixes()Map<SimpleString,RoutingType>ProtocolManager. getPrefixes()Methods in org.apache.activemq.artemis.spi.core.protocol with parameters of type SimpleString Modifier and Type Method Description voidSessionCallback. disconnect(ServerConsumer consumerId, SimpleString queueName)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 SimpleString Modifier and Type Method Description abstract 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)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)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 types with arguments of type SimpleString Modifier and Type Method Description static 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 SimpleString Modifier and Type Method Description static 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 SimpleString Modifier and Type Method Description 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 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 SimpleString Modifier and Type Method Description SimpleStringTypedProperties. getSimpleStringProperty(SimpleString key)Methods in org.apache.activemq.artemis.utils.collections that return types with arguments of type SimpleString Modifier and Type Method Description Set<SimpleString>TypedProperties. getPropertyNames()Methods in org.apache.activemq.artemis.utils.collections with parameters of type SimpleString Modifier and Type Method Description booleanTypedProperties. containsProperty(SimpleString key)BooleanTypedProperties. getBooleanProperty(SimpleString key)ByteTypedProperties. getByteProperty(SimpleString key)ByteTypedProperties. getByteProperty(SimpleString key, Supplier<Byte> defaultValue)byte[]TypedProperties. getBytesProperty(SimpleString key)CharacterTypedProperties. getCharProperty(SimpleString key)DoubleTypedProperties. getDoubleProperty(SimpleString key)FloatTypedProperties. getFloatProperty(SimpleString key)IntegerTypedProperties. getIntProperty(SimpleString key)LongTypedProperties. getLongProperty(SimpleString key)ObjectTypedProperties. getProperty(SimpleString key)ShortTypedProperties. getShortProperty(SimpleString key)SimpleStringTypedProperties. 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)TypedPropertiesTypedProperties. putProperty(SimpleString key, Object value)voidTypedProperties. putShortProperty(SimpleString key, short value)voidTypedProperties. putSimpleStringProperty(SimpleString key, SimpleString value)ObjectTypedProperties. 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 SimpleString Modifier and Type Method Description voidTypedProperties. forEach(BiConsumer<SimpleString,Object> action)voidTypedProperties. forEachKey(Consumer<SimpleString> action)Constructor parameters in org.apache.activemq.artemis.utils.collections with type arguments of type SimpleString Constructor Description TypedProperties(Predicate<SimpleString> internalPropertyPredicate) -
Uses of SimpleString in org.apache.activemq.artemis.utils.uri
Methods in org.apache.activemq.artemis.utils.uri with parameters of type SimpleString Modifier and Type Method Description static booleanURISupport. containsQuery(SimpleString uri)
-