Uses of Class
org.apache.activemq.artemis.api.core.ActiveMQException

Packages that use ActiveMQException

Package	Description
org.apache.activemq.artemis.api.core
org.apache.activemq.artemis.api.core.client
org.apache.activemq.artemis.core.client.impl
org.apache.activemq.artemis.core.filter.impl
org.apache.activemq.artemis.core.io
org.apache.activemq.artemis.core.io.aio
org.apache.activemq.artemis.core.io.nio
org.apache.activemq.artemis.core.journal.impl
org.apache.activemq.artemis.core.management.impl
org.apache.activemq.artemis.core.message
org.apache.activemq.artemis.core.message.impl
org.apache.activemq.artemis.core.paging
org.apache.activemq.artemis.core.paging.impl
org.apache.activemq.artemis.core.persistence
org.apache.activemq.artemis.core.persistence.impl.journal
org.apache.activemq.artemis.core.persistence.impl.nullpm
org.apache.activemq.artemis.core.protocol.core
org.apache.activemq.artemis.core.protocol.core.impl
org.apache.activemq.artemis.core.protocol.core.impl.wireformat
org.apache.activemq.artemis.core.protocol.hornetq
org.apache.activemq.artemis.core.protocol.hornetq.client
org.apache.activemq.artemis.core.remoting
org.apache.activemq.artemis.core.remoting.server.impl
org.apache.activemq.artemis.core.replication
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.cluster
org.apache.activemq.artemis.core.server.cluster.ha
org.apache.activemq.artemis.core.server.cluster.impl
org.apache.activemq.artemis.core.server.cluster.quorum
org.apache.activemq.artemis.core.server.federation
org.apache.activemq.artemis.core.server.federation.queue
org.apache.activemq.artemis.core.server.impl
org.apache.activemq.artemis.core.server.impl.quorum
org.apache.activemq.artemis.core.server.plugin
org.apache.activemq.artemis.core.server.plugin.impl
org.apache.activemq.artemis.core.server.routing.targets
org.apache.activemq.artemis.core.transaction
org.apache.activemq.artemis.core.transaction.impl
org.apache.activemq.artemis.jdbc.store.file
org.apache.activemq.artemis.jms.client
org.apache.activemq.artemis.jms.server.impl
org.apache.activemq.artemis.ra
org.apache.activemq.artemis.ra.inflow
org.apache.activemq.artemis.reader
org.apache.activemq.artemis.service.extensions.xa.recovery
org.apache.activemq.artemis.spi.core.protocol
org.apache.activemq.artemis.spi.core.remoting
org.apache.activemq.artemis.utils
org.jboss.activemq.artemis.wildfly.integration.recovery

Uses of ActiveMQException in org.apache.activemq.artemis.api.core

Subclasses of ActiveMQException in org.apache.activemq.artemis.api.core

Modifier and Type	Class	Description
final class	ActiveMQAddressDoesNotExistException	An operation failed because an address exists on the server.
final class	ActiveMQAddressExistsException	An operation failed because an address exists on the server.
final class	ActiveMQAddressFullException	An address is full.
final class	ActiveMQAlreadyReplicatingException	The server is already paired with a replicating backup.
final class	ActiveMQClusterSecurityException	Security exception thrown when the cluster user fails authentication.
final class	ActiveMQConnectionTimedOutException	A client timed out will connecting to ActiveMQ Artemis server.
final class	ActiveMQDeleteAddressException	An operation failed because an address exists on the server.
final class	ActiveMQDisconnectedException	A client was disconnected from ActiveMQ Artemis server when the server has shut down.
final class	ActiveMQDivertDoesNotExistException	An operation failed because an address exists on the server.
final class	ActiveMQDuplicateIdException	A DuplicateID was rejected.
final class	ActiveMQDuplicateMetaDataException	A Session Metadata was set in duplication
final class	ActiveMQIllegalStateException	An ActiveMQ Artemis resource is not in a legal state (e.g. calling ClientConsumer.receive() if a MessageHandler is set).
final class	ActiveMQIncompatibleClientServerException	The server version and the client version are incompatible.
final class	ActiveMQInterceptorRejectedPacketException	An outgoing interceptor returned false.
final class	ActiveMQInternalErrorException	Internal error which prevented ActiveMQ Artemis from performing an important operation.
final class	ActiveMQInvalidFilterExpressionException	A filter expression was found to be invalid.
final class	ActiveMQInvalidQueueConfiguration	An operation failed because a queue exists on the server.
final class	ActiveMQInvalidTransientQueueUseException	An operation failed because a queue exists on the server.
final class	ActiveMQIOErrorException	Unexpected I/O error occurred on the server.
final class	ActiveMQLargeMessageException	A problem occurred while manipulating the body of a large message.
class	ActiveMQLargeMessageInterruptedException
final class	ActiveMQNativeIOError	An error has happened at ActiveMQ's native (non-Java) code used in reading and writing data.
final class	ActiveMQNonExistentQueueException	An operation failed because a queue does not exist on the server.
final class	ActiveMQNotConnectedException	A client is not able to connect to ActiveMQ Artemis server.
class	ActiveMQNullRefException	An operation failed because is dereferencing null pointer.
final class	ActiveMQObjectClosedException	A client operation failed because the calling resource (ClientSession, ClientProducer, etc.) is closed.
final class	ActiveMQQueueExistsException	An operation failed because a queue exists on the server.
final class	ActiveMQQueueMaxConsumerLimitReached	An operation failed because a queue exists on the server.
final class	ActiveMQRemoteDisconnectException	A security problem occurred (authentication issues, permission issues, etc.)
final class	ActiveMQReplicationTimeooutException	The creation of a session was rejected by the server (e.g. if the server is starting and has not finish to be initialized.
final class	ActiveMQRoutingException	A client was redirected.
final class	ActiveMQSecurityException	A security problem occurred (authentication issues, permission issues, etc.)
final class	ActiveMQSessionCreationException	The creation of a session was rejected by the server (e.g. if the server is starting and has not finish to be initialized.
final class	ActiveMQShutdownException	An operation failed because an address exists on the server.
final class	ActiveMQTimeoutException	An operation timed out.
final class	ActiveMQTransactionOutcomeUnknownException	The outcome of a transaction is unknown.
final class	ActiveMQTransactionRolledBackException	A transaction was rolled back.
class	ActiveMQTransactionTimeoutException
final class	ActiveMQUnBlockedException	A blocking call from a client was unblocked during failover.
final class	ActiveMQUnexpectedRoutingTypeForAddress	An operation failed because a queue exists on the server.
final class	ActiveMQUnsupportedPacketException	A packet of unsupported type was received by ActiveMQ Artemis PacketHandler.

Methods in org.apache.activemq.artemis.api.core that return ActiveMQException

Modifier and Type	Method	Description
static ActiveMQException	ActiveMQExceptionType.createException(int code, String msg)
ActiveMQException	ActiveMQExceptionType.createException(String msg)

Methods in org.apache.activemq.artemis.api.core that throw ActiveMQException

Modifier and Type	Method	Description
LargeBodyReader	ICoreMessage.getLargeBodyReader()
long	Message.getPersistentSize()	This is the size of the message when persisted on disk which is used for metrics tracking Note that even if the message itself is not persisted on disk (ie non-durable) this value is still used for metrics tracking If a normal message it will be the encoded message size If a large message it will be encoded message size + large message body size
boolean	BaseInterceptor.intercept(P packet, RemotingConnection connection)	Intercepts a packet which is received before it is sent to the channel

Uses of ActiveMQException in org.apache.activemq.artemis.api.core.client

Methods in org.apache.activemq.artemis.api.core.client with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	SessionFailureListener.beforeReconnect(ActiveMQException exception)	Notifies that a connection has failed due to the specified exception.

Methods in org.apache.activemq.artemis.api.core.client that throw ActiveMQException

Modifier and Type	Method	Description
ClientMessage	ClientMessage.acknowledge()	Acknowledges reception of this message.
void	ClientSession.addMetaData(String key, String data)	Attach any metadata to the session.
ClientSession.AddressQuery	ClientSession.addressQuery(SimpleString address)	Queries information on a binding.
void	ClientSession.addUniqueMetaData(String key, String data)	Attach any metadata to the session.
void	ClientMessage.checkCompletion()	This can be optionally used to verify if the entire message has been received.
void	ClientConsumer.close()	Closes the consumer.
void	ClientProducer.close()	Closes the ClientProducer.
void	ClientSession.close()	Closes the session.
void	ClientSession.commit()	Commits the current transaction, blocking.
void	ClientSession.commit(boolean block)	Commits the current transaction.
void	ClientSession.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated)	Create Address with a single initial routing type
void	ClientSession.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated)	Deprecated.
void	ClientSession.createAddress(SimpleString address, RoutingType routingType, boolean autoCreated)	Create Address with a single initial routing type
ClientConsumer	ClientSession.createConsumer(String queueName)	Creates a ClientConsumer to consume messages from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(String queueName, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(String queueName, String filter)	Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(String queueName, String filter, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(String queueName, String 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.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName)	Creates a ClientConsumer to consume message from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, SimpleString filter)	Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, SimpleString filter, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, SimpleString filter, int priority, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, SimpleString filter, int windowSize, int maxRate, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, SimpleString filter, int priority, int windowSize, int maxRate, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientProducer	ClientSession.createProducer()	Creates a producer with no default address.
ClientProducer	ClientSession.createProducer(String address)	Creates a producer which sends messages to the given address
ClientProducer	ClientSession.createProducer(SimpleString address)	Creates a producer which sends messages to the given address
ClientProducer	ClientSession.createProducer(SimpleString address, int rate)	Creates a producer which sends messages to the given address
void	ClientSession.createQueue(String address, String queueName)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(String address, String queueName, boolean durable)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(String address, String queueName, String filter, boolean durable)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(String address, String queueName, String filter, boolean durable, boolean autoCreated)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(String address, RoutingType routingType, String queueName)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(String address, RoutingType routingType, String queueName, boolean durable)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable, boolean autoCreated)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(QueueConfiguration queueConfiguration)	This method creates a queue based on the QueueConfiguration input.
void	ClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(SimpleString address, SimpleString queueName)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(SimpleString address, SimpleString queueName, boolean durable)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(SimpleString address, SimpleString queueName, boolean autoCreated, QueueAttributes queueAttributes)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
ClientSession	ClientSessionFactory.createSession()	Creates a non-transacted session.
ClientSession	ClientSessionFactory.createSession(boolean autoCommitSends, boolean autoCommitAcks)	Creates a session.
ClientSession	ClientSessionFactory.createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks)	Creates a session.
ClientSession	ClientSessionFactory.createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge)	Creates a session.
ClientSession	ClientSessionFactory.createSession(boolean autoCommitSends, boolean autoCommitAcks, int ackBatchSize)	Creates a session.
ClientSession	ClientSessionFactory.createSession(String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int ackBatchSize)	Creates an authenticated session.
ClientSession	ClientSessionFactory.createSession(String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int ackBatchSize, String clientID)	Creates an authenticated session.
void	ClientSession.createSharedQueue(QueueConfiguration queueConfiguration)	This method is essentially the same as ClientSession.createQueue(QueueConfiguration) with a few key exceptions.
void	ClientSession.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable)	Deprecated. use ClientSession.createSharedQueue(QueueConfiguration) instead
void	ClientSession.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable)	Deprecated. use ClientSession.createSharedQueue(QueueConfiguration) instead
void	ClientSession.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)	Deprecated. use ClientSession.createSharedQueue(QueueConfiguration) instead
void	ClientSession.createSharedQueue(SimpleString address, SimpleString queueName, boolean durable)	Deprecated. use ClientSession.createSharedQueue(QueueConfiguration) instead
void	ClientSession.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes)	Deprecated. use ClientSession.createSharedQueue(QueueConfiguration) instead
void	ClientSession.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable)	Deprecated. use ClientSession.createSharedQueue(QueueConfiguration) instead
void	ClientSession.createTemporaryQueue(String address, String queueName)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createTemporaryQueue(String address, String queueName, String filter)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createTemporaryQueue(String address, RoutingType routingType, String queueName)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createTemporaryQueue(String address, RoutingType routingType, String queueName, String filter)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createTemporaryQueue(SimpleString address, SimpleString queueName)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createTemporaryQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
void	ClientSession.createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter)	Deprecated. use ClientSession.createQueue(QueueConfiguration) instead
ClientSession	ClientSessionFactory.createTransactedSession()	Creates a transacted session.
ClientSession	ClientSessionFactory.createXASession()	Creates a session with XA transaction semantics.
void	ClientSession.deleteQueue(String queueName)	Deletes the queue.
void	ClientSession.deleteQueue(SimpleString queueName)	Deletes the queue.
MessageHandler	ClientConsumer.getMessageHandler()	Calling this method on a closed consumer will throw an ActiveMQException.
ClientMessage	ClientMessage.individualAcknowledge()	Acknowledges reception of a single message.
void	ServerLocator.initialize()	This will only instantiate internal objects such as the topology
ClientSession.QueueQuery	ClientSession.queueQuery(SimpleString queueName)	Queries information on a queue.
ClientMessage	ClientConsumer.receive()	Receives a message from a queue.
ClientMessage	ClientConsumer.receive(long timeout)	Receives a message from a queue.
ClientMessage	ClientConsumer.receiveImmediate()	Receives a message from a queue.
void	ClientSession.rollback()	Rolls back the current transaction.
void	ClientSession.rollback(boolean considerLastMessageAsDelivered)	Rolls back the current transaction.
void	ClientMessage.saveToOutputStream(OutputStream out)	Saves the content of the message to the OutputStream.
void	ClientProducer.send(String address, Message message)	Sends a message to the specified address instead of the ClientProducer's address.
void	ClientProducer.send(Message message)	Sends a message to an address. specified in ClientSession.createProducer(String) or similar methods.
void	ClientProducer.send(Message message, SendAcknowledgementHandler handler)	Sends a message to the specified address instead of the ClientProducer's address.
void	ClientProducer.send(SimpleString address, Message message)	Sends a message to the specified address instead of the ClientProducer's address.
void	ClientProducer.send(SimpleString address, Message message, SendAcknowledgementHandler handler)	Sends a message to the specified address instead of the ClientProducer's address.
ClientConsumer	ClientConsumer.setMessageHandler(MessageHandler handler)	Sets the MessageHandler for this consumer to consume messages asynchronously.
ClientMessage	ClientMessage.setOutputStream(OutputStream out)	Sets the OutputStream that will receive the content of a message received in a non blocking way.
ClientSession	ClientSession.start()	Starts the session.
void	ClientSession.stop()	Stops the session.
boolean	ClientMessage.waitOutputStreamCompletion(long timeMilliseconds)	Wait the outputStream completion of the message.

Uses of ActiveMQException in org.apache.activemq.artemis.core.client.impl

Methods in org.apache.activemq.artemis.core.client.impl with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	ClientSessionFactoryImpl.connectionException(Object connectionID, ActiveMQException me)
void	ClientSessionImpl.connectionFailed(ActiveMQException me, boolean failedOver)
void	ClientSessionImpl.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)
boolean	ClientSessionImpl.handleFailover(RemotingConnection backupConnection, ActiveMQException cause)
boolean	ClientSessionInternal.handleFailover(RemotingConnection backupConnection, ActiveMQException cause)

Methods in org.apache.activemq.artemis.core.client.impl that throw ActiveMQException

Modifier and Type	Method	Description
void	ClientConsumerImpl.acknowledge(ClientMessage message)
void	ClientConsumerInternal.acknowledge(ClientMessage message)
ClientMessageImpl	ClientMessageImpl.acknowledge()
void	ClientSessionImpl.acknowledge(ClientConsumer consumer, Message message)
void	ClientSessionInternal.acknowledge(ClientConsumer consumer, Message message)
void	AbstractProducerCreditsImpl.acquireCredits(int credits)
void	ClientProducerCredits.acquireCredits(int credits)
void	ClientSessionImpl.addMetaData(String key, String data)
ClientSession.AddressQuery	ClientSessionImpl.addressQuery(SimpleString address)
void	ClientSessionImpl.addUniqueMetaData(String key, String data)
void	ClientLargeMessageImpl.checkCompletion()
void	ClientMessageImpl.checkCompletion()
void	ClientConsumerInternal.cleanUp()
void	ClientSessionImpl.cleanUp(boolean failingOver)
void	ClientSessionInternal.cleanUp(boolean failingOver)
void	ClientConsumerImpl.clear(boolean waitForOnMessage)
void	ClientConsumerInternal.clear(boolean waitForOnMessage)
void	ClientConsumerImpl.close()
void	ClientProducerImpl.close()
void	ClientSessionImpl.close()
void	ClientSessionImpl.commit()
void	ClientSessionImpl.commit(boolean block)
void	ClientSessionFactoryImpl.connect(int initialConnectAttempts)
void	ClientSessionFactoryImpl.connect(int initialConnectAttempts, boolean failoverOnInitialConnection)	Deprecated.
void	ClientSessionFactoryInternal.connect(int reconnectAttempts)
void	ClientSessionFactoryInternal.connect(int reconnectAttempts, boolean failoverOnInitialConnection)	Deprecated. This method is no longer acceptable to connect.
ClientSessionFactoryInternal	ServerLocatorImpl.connect()
ClientSessionFactoryInternal	ServerLocatorInternal.connect()
ClientSessionFactoryInternal	ServerLocatorImpl.connectNoWarnings()
ClientSessionFactoryInternal	ServerLocatorInternal.connectNoWarnings()	Like ServerLocatorInternal.connect() but it does not log warnings if it fails to connect.
void	ClientSessionImpl.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated)
void	ClientSessionImpl.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated)
void	ClientSessionImpl.createAddress(SimpleString address, RoutingType routingType, boolean autoCreated)
ClientConsumer	ClientSessionImpl.createConsumer(String queueName)
ClientConsumer	ClientSessionImpl.createConsumer(String queueName, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(String queueName, String filterString)
ClientConsumer	ClientSessionImpl.createConsumer(String queueName, String filterString, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(String queueName, String filterString, int windowSize, int maxRate, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int windowSize, int maxRate, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, boolean browseOnly)	Note, we DO NOT currently support direct consumers (i.e. consumers where delivery occurs on the remoting thread).
ClientProducer	ClientSessionImpl.createProducer()
ClientProducer	ClientSessionImpl.createProducer(String address)
ClientProducer	ClientSessionImpl.createProducer(String address, int rate)
ClientProducer	ClientSessionImpl.createProducer(SimpleString address)
ClientProducer	ClientSessionImpl.createProducer(SimpleString address, int maxRate)
void	ClientSessionImpl.createQueue(String address, String queueName)
void	ClientSessionImpl.createQueue(String address, String queueName, boolean durable)
void	ClientSessionImpl.createQueue(String address, String queueName, String filterString, boolean durable)
void	ClientSessionImpl.createQueue(String address, String queueName, String filterString, boolean durable, boolean autoCreated)
void	ClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName)	Deprecated.
void	ClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName, boolean durable)
void	ClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable)
void	ClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName, String filterString, boolean durable, boolean autoCreated)
void	ClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName, String filterString, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers)	Deprecated.
void	ClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName, String filterString, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)
void	ClientSessionImpl.createQueue(QueueConfiguration queueConfiguration)
void	ClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName)	Deprecated.
void	ClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable)	Deprecated.
void	ClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable)	Deprecated.
void	ClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated)	Deprecated.
void	ClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers)	Deprecated.
void	ClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)	Deprecated.
void	ClientSessionImpl.createQueue(SimpleString address, SimpleString queueName)
void	ClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, boolean durable)
void	ClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, boolean autoCreated, QueueAttributes queueAttributes)	Deprecated.
void	ClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable)
void	ClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated)
ClientSession	ClientSessionFactoryImpl.createSession()
ClientSession	ClientSessionFactoryImpl.createSession(boolean autoCommitSends, boolean autoCommitAcks)
ClientSession	ClientSessionFactoryImpl.createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks)
ClientSession	ClientSessionFactoryImpl.createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge)
ClientSession	ClientSessionFactoryImpl.createSession(boolean autoCommitSends, boolean autoCommitAcks, int ackBatchSize)
ClientSession	ClientSessionFactoryImpl.createSession(String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int ackBatchSize)
ClientSession	ClientSessionFactoryImpl.createSession(String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int ackBatchSize, String clientID)
protected SessionContext	ClientSessionFactoryImpl.createSessionChannel(String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, String clientID)
ClientSessionFactory	ServerLocatorImpl.createSessionFactory()
void	ClientSessionImpl.createSharedQueue(QueueConfiguration queueConfiguration)
void	ClientSessionImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable)
void	ClientSessionImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable)
void	ClientSessionImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)	Deprecated.
void	ClientSessionImpl.createSharedQueue(SimpleString address, SimpleString queueName, boolean durable)
void	ClientSessionImpl.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes)	Deprecated.
void	ClientSessionImpl.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable)
void	ClientSessionImpl.createTemporaryQueue(String address, String queueName)
void	ClientSessionImpl.createTemporaryQueue(String address, String queueName, String filter)
void	ClientSessionImpl.createTemporaryQueue(String address, RoutingType routingType, String queueName)
void	ClientSessionImpl.createTemporaryQueue(String address, RoutingType routingType, String queueName, String filter)
void	ClientSessionImpl.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName)
void	ClientSessionImpl.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter)	Deprecated.
void	ClientSessionImpl.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)	Deprecated.
void	ClientSessionImpl.createTemporaryQueue(SimpleString address, SimpleString queueName)
void	ClientSessionImpl.createTemporaryQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes)	Deprecated.
void	ClientSessionImpl.createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter)
ClientSession	ClientSessionFactoryImpl.createTransactedSession()
ClientSession	ClientSessionFactoryImpl.createXASession()
void	ClientSessionImpl.deleteQueue(String queueName)
void	ClientSessionImpl.deleteQueue(SimpleString queueName)
void	ClientSessionImpl.expire(ClientConsumer consumer, Message message)
void	ClientSessionInternal.expire(ClientConsumer consumer, Message message)
void	ClientConsumerImpl.flowControl(int messageBytes, boolean discountSlowConsumer)	LargeMessageBuffer will call flowcontrol here, while other handleMessage will also be calling flowControl.
void	ClientConsumerInternal.flowControl(int messageBytes, boolean discountSlowConsumer)
void	ClientConsumerImpl.flushAcks()
void	ClientConsumerInternal.flushAcks()
LargeBodyReader	ClientMessageImpl.getLargeBodyReader()
MessageHandler	ClientConsumerImpl.getMessageHandler()
void	ClientSessionImpl.handleConsumerDisconnect(ConsumerContext context)
void	ClientSessionInternal.handleConsumerDisconnect(ConsumerContext consumerContext)
void	ClientConsumerImpl.individualAcknowledge(ClientMessage message)
void	ClientConsumerInternal.individualAcknowledge(ClientMessage message)
ClientMessageImpl	ClientMessageImpl.individualAcknowledge()
void	ClientSessionImpl.individualAcknowledge(ClientConsumer consumer, Message message)
void	ClientSessionInternal.individualAcknowledge(ClientConsumer consumer, Message message)
void	ServerLocatorImpl.initialize()
Thread	ClientConsumerImpl.prepareForClose(FutureLatch future)	To be used by MDBs to stop any more handling of messages.
Thread	ClientConsumerInternal.prepareForClose(FutureLatch future)	To be called by things like MDBs during shutdown of the server
ClientSession.QueueQuery	ClientSessionImpl.queueQuery(SimpleString queueName)
ClientMessage	ClientConsumerImpl.receive()
ClientMessage	ClientConsumerImpl.receive(long timeout)
ClientMessage	ClientConsumerImpl.receiveImmediate()
void	ClientSessionImpl.removeConsumer(ClientConsumerInternal consumer)
void	ClientSessionInternal.removeConsumer(ClientConsumerInternal consumer)
void	ClientSessionImpl.resetIfNeeded()
void	ClientSessionInternal.resetIfNeeded()
void	ClientSessionImpl.rollback()
void	ClientSessionImpl.rollback(boolean isLastMessageAsDelivered)
void	ClientSessionImpl.rollback(boolean isLastMessageAsDelivered, boolean waitConsumers)
void	LargeMessageController.saveBuffer(OutputStream output)	Saves this buffer to the specified output.
void	LargeMessageControllerImpl.saveBuffer(OutputStream output)
void	ClientLargeMessageImpl.saveToOutputStream(OutputStream out)
void	ClientMessageImpl.saveToOutputStream(OutputStream out)
void	ClientProducerImpl.send(String address1, Message message)
void	ClientProducerImpl.send(Message msg)
void	ClientProducerImpl.send(Message message, SendAcknowledgementHandler handler)
void	ClientProducerImpl.send(SimpleString address1, Message msg)
void	ClientProducerImpl.send(SimpleString address1, Message message, SendAcknowledgementHandler handler)
ClientConsumer	ClientConsumerImpl.setManualFlowMessageHandler(MessageHandler theHandler)
ClientConsumer	ClientConsumerInternal.setManualFlowMessageHandler(MessageHandler theHandler)
ClientConsumerImpl	ClientConsumerImpl.setMessageHandler(MessageHandler theHandler)
ClientLargeMessageImpl	ClientLargeMessageImpl.setOutputStream(OutputStream out)
ClientMessageImpl	ClientMessageImpl.setOutputStream(OutputStream out)
void	LargeMessageController.setOutputStream(OutputStream output)	Sets the OutputStream of this buffer to the specified output.
void	LargeMessageControllerImpl.setOutputStream(OutputStream output)
ClientSessionImpl	ClientSessionImpl.start()
void	ClientConsumerImpl.stop(boolean waitForOnMessage)
void	ClientConsumerInternal.stop(boolean waitForOnMessage)
void	ClientSessionImpl.stop()
void	ClientSessionImpl.stop(boolean waitForOnMessage)
boolean	LargeMessageController.waitCompletion(long timeWait)	Waits for the completion for the specified waiting time (in milliseconds).
boolean	LargeMessageControllerImpl.waitCompletion(long timeWait)
boolean	ClientLargeMessageImpl.waitOutputStreamCompletion(long timeMilliseconds)
boolean	ClientMessageImpl.waitOutputStreamCompletion(long timeMilliseconds)

Uses of ActiveMQException in org.apache.activemq.artemis.core.filter.impl

Methods in org.apache.activemq.artemis.core.filter.impl that throw ActiveMQException

Modifier and Type	Method	Description
static Filter	FilterImpl.createFilter(String filterStr)	Returns null if filterStr is null or an empty String and a valid filter else.
static Filter	FilterImpl.createFilter(SimpleString filterStr)	Returns null if filterStr is null or an empty String and a valid filter else.

Uses of ActiveMQException in org.apache.activemq.artemis.core.io

Methods in org.apache.activemq.artemis.core.io that throw ActiveMQException

Modifier and Type	Method	Description
void	AbstractSequentialFile.close()
final void	AbstractSequentialFile.delete()
void	SequentialFile.delete()
final void	AbstractSequentialFile.renameTo(String newFileName)
void	AbstractSequentialFile.write(ActiveMQBuffer bytes, boolean sync)
void	AbstractSequentialFile.write(EncodingSupport bytes, boolean sync)

Uses of ActiveMQException in org.apache.activemq.artemis.core.io.aio

Methods in org.apache.activemq.artemis.core.io.aio that throw ActiveMQException

Modifier and Type	Method	Description
void	AIOSequentialFile.close()
void	AIOSequentialFile.close(boolean waitSync, boolean blockOnWait)
void	AIOSequentialFile.open(int maxIO, boolean useExecutor)
int	AIOSequentialFile.read(ByteBuffer bytes, IOCallback callback)

Uses of ActiveMQException in org.apache.activemq.artemis.core.io.nio

Methods in org.apache.activemq.artemis.core.io.nio that throw ActiveMQException

Modifier and Type	Method	Description
void	NIOSequentialFile.close()
void	NIOSequentialFile.close(boolean waitSync, boolean blockOnPending)

Uses of ActiveMQException in org.apache.activemq.artemis.core.journal.impl

Methods in org.apache.activemq.artemis.core.journal.impl that throw ActiveMQException

Modifier and Type	Method	Description
void	SimpleWaitIOCallback.waitCompletion()
boolean	SimpleWaitIOCallback.waitCompletion(long timeout)

Uses of ActiveMQException in org.apache.activemq.artemis.core.management.impl

Methods in org.apache.activemq.artemis.core.management.impl with parameters of type ActiveMQException

Modifier and Type	Method	Description
Future	ManagementRemotingConnection.asyncFail(ActiveMQException me)
void	ManagementRemotingConnection.fail(ActiveMQException me)
void	ManagementRemotingConnection.fail(ActiveMQException me, String scaleDownTargetNodeID)

Methods in org.apache.activemq.artemis.core.management.impl that throw ActiveMQException

Modifier and Type	Method	Description
Map<String,Map<String,Object>[]>	QueueControlImpl.listDeliveringMessages()

Uses of ActiveMQException in org.apache.activemq.artemis.core.message

Methods in org.apache.activemq.artemis.core.message that throw ActiveMQException

Modifier and Type	Method	Description
void	BodyEncoder.close()	Deprecated. This method must not be called directly by ActiveMQ Artemis clients.
void	LargeBodyReader.close()	This method must not be called directly by ActiveMQ Artemis clients.
int	BodyEncoder.encode(ByteBuffer bufferRead)	Deprecated. This method must not be called directly by ActiveMQ Artemis clients.
int	BodyEncoder.encode(ActiveMQBuffer bufferOut, int size)	Deprecated. This method must not be called directly by ActiveMQ Artemis clients.
long	LargeBodyReader.getSize()	This method must not be called directly by ActiveMQ Artemis clients.
void	BodyEncoder.open()	Deprecated. This method must not be called directly by ActiveMQ Artemis clients.
void	LargeBodyReader.open()	This method must not be called directly by ActiveMQ Artemis clients.
void	LargeBodyReader.position(long position)	This method must not be called directly by ActiveMQ Artemis clients.
int	LargeBodyReader.readInto(ByteBuffer bufferRead)	This method must not be called directly by ActiveMQ Artemis clients.

Uses of ActiveMQException in org.apache.activemq.artemis.core.message.impl

Methods in org.apache.activemq.artemis.core.message.impl that throw ActiveMQException

Modifier and Type	Method	Description
BodyEncoder	MessageInternal.getBodyEncoder()	Deprecated.
BodyEncoder	MessageInternalImpl.getBodyEncoder()	Deprecated.
LargeBodyReader	CoreMessage.getLargeBodyReader()
long	CoreMessage.getPersistentSize()
long	MessageInternalImpl.getPersistentSize()	Deprecated.

Uses of ActiveMQException in org.apache.activemq.artemis.core.paging

Methods in org.apache.activemq.artemis.core.paging that throw ActiveMQException

Modifier and Type	Method	Description
long	PagedMessage.getPersistentSize()	This is the size of the message when persisted on disk and is used for metrics tracking If a normal message it will be the encoded message size If a large message it will be encoded message size + large message body size

Uses of ActiveMQException in org.apache.activemq.artemis.core.paging.impl

Methods in org.apache.activemq.artemis.core.paging.impl that throw ActiveMQException

Modifier and Type	Method	Description
long	PagedMessageImpl.getPersistentSize()

Uses of ActiveMQException in org.apache.activemq.artemis.core.persistence

Methods in org.apache.activemq.artemis.core.persistence that throw ActiveMQException

Modifier and Type	Method	Description
void	StorageManager.deleteLargeMessageBody(LargeServerMessage largeServerMessage)
void	StorageManager.largeMessageClosed(LargeServerMessage largeServerMessage)

Uses of ActiveMQException in org.apache.activemq.artemis.core.persistence.impl.journal

Methods in org.apache.activemq.artemis.core.persistence.impl.journal that throw ActiveMQException

Modifier and Type	Method	Description
void	JournalStorageManager.deleteLargeMessageBody(LargeServerMessage largeServerMessage)
void	LargeBody.ensureFileExists(boolean toOpen)
SequentialFile	LargeBody.getAppendFile()
SequentialFile	LargeServerMessageImpl.getAppendFile()
long	LargeBody.getBodySize()
long	LargeServerMessageImpl.getBodySize()
long	LargeServerMessageImpl.getPersistentSize()
SequentialFile	LargeBody.getReadingFile()	This will return its own File useful for reading the file on the large message while delivering, browsing.. etc
SequentialFile	LargeServerMessageInSync.getSyncFile()
void	JournalStorageManager.largeMessageClosed(LargeServerMessage largeServerMessage)
boolean	OperationContextImpl.waitCompletion(long timeout)

Uses of ActiveMQException in org.apache.activemq.artemis.core.persistence.impl.nullpm

Methods in org.apache.activemq.artemis.core.persistence.impl.nullpm that throw ActiveMQException

Modifier and Type	Method	Description
void	NullStorageManager.deleteLargeMessageBody(LargeServerMessage largeServerMessage)
void	NullStorageManager.largeMessageClosed(LargeServerMessage largeServerMessage)

Uses of ActiveMQException in org.apache.activemq.artemis.core.protocol.core

Methods in org.apache.activemq.artemis.core.protocol.core with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	ServerSessionPacketHandler.connectionFailed(ActiveMQException exception, boolean failedOver)

Methods in org.apache.activemq.artemis.core.protocol.core that throw ActiveMQException

Modifier and Type	Method	Description
Packet	Channel.sendBlocking(Packet packet, byte expectedPacket)	Sends a packet on this channel and then blocks until a response is received or a timeout occurs.
Packet	Channel.sendBlocking(Packet packet, int reconnectID, byte expectedPacket)	Sends a packet on this channel and then blocks until a response is received or a timeout occurs.
Packet	Channel.sendBlocking(Packet packet, int reconnectID, byte expectedPacket, long timeout, boolean failOnTimeout)

Uses of ActiveMQException in org.apache.activemq.artemis.core.protocol.core.impl

Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type ActiveMQException

Modifier and Type	Method	Description
boolean	ActiveMQClientProtocolManager.cleanupBeforeFailover(ActiveMQException cause)
void	ResponseCache.errorAll(ActiveMQException exception)
void	RemotingConnectionImpl.fail(ActiveMQException me, String scaleDownTargetNodeID)
void	ActiveMQSessionContext.returnBlocking(ActiveMQException cause)

Methods in org.apache.activemq.artemis.core.protocol.core.impl that throw ActiveMQException

Modifier and Type	Method	Description
ClientSession.AddressQuery	ActiveMQSessionContext.addressQuery(SimpleString address)
void	ActiveMQSessionContext.addSessionMetadata(String key, String data)
void	ActiveMQSessionContext.addUniqueMetaData(String key, String data)
boolean	ActiveMQClientProtocolManager.checkForFailover(String nodeID)
void	ActiveMQSessionContext.closeConsumer(ClientConsumer consumer)
boolean	ActiveMQSessionContext.configureTransactionTimeout(int seconds)
void	ActiveMQSessionContext.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated)
void	ActiveMQSessionContext.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated)
ClientConsumerInternal	ActiveMQSessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout)
void	ActiveMQSessionContext.createQueue(QueueConfiguration queueConfiguration)
void	ActiveMQSessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated)	Deprecated.
void	ActiveMQSessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated, Boolean exclusive, Boolean lastValue)	Deprecated.
void	ActiveMQSessionContext.createQueue(SimpleString address, SimpleString queueName, boolean temp, boolean autoCreated, QueueAttributes queueAttributes)	Deprecated.
void	ActiveMQSessionContext.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, boolean autoCreated)	Deprecated.
SessionContext	ActiveMQClientProtocolManager.createSessionContext(String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, String clientID)
SessionContext	ActiveMQClientProtocolManager.createSessionContext(Version clientVersion, String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, String clientID)
void	ActiveMQSessionContext.createSharedQueue(QueueConfiguration queueConfiguration)
void	ActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes)	Deprecated.
void	ActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable)	Deprecated.
void	ActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)	Deprecated.
void	ActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable)	Deprecated.
void	ActiveMQSessionContext.deleteQueue(SimpleString queueName)
void	ActiveMQSessionContext.expireMessage(ClientConsumer consumer, Message message)
void	ActiveMQSessionContext.forceDelivery(ClientConsumer consumer, long sequence)
int	ActiveMQSessionContext.getDefaultConsumerWindowSize(SessionQueueQueryResponseMessage response)
ClientSession.QueueQuery	ActiveMQSessionContext.queueQuery(SimpleString queueName)
boolean	ActiveMQSessionContext.reattachOnNewConnection(RemotingConnection newConnection)
int	ActiveMQSessionContext.recoverSessionTimeout()
void	ActiveMQSessionContext.recreateConsumerOnServer(ClientConsumerInternal consumerInternal, long consumerId, boolean isSessionStarted)
void	ActiveMQSessionContext.recreateSession(String username, String password, int minLargeMessageSize, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge)
void	ActiveMQSessionContext.restartSession()
void	ActiveMQSessionContext.sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message)
Packet	ChannelImpl.sendBlocking(Packet packet, byte expectedPacket)
Packet	ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket)
Packet	ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket, long timeout, boolean failOnTimeout)	Due to networking issues or server issues the server may take longer to answer than expected.. the client may timeout the call throwing an exception and the client could eventually retry another call, but the server could then answer a previous command issuing a class-cast-exception.
void	ActiveMQSessionContext.sendFullMessage(ICoreMessage msgI, boolean sendBlocking, SendAcknowledgementHandler handler, SimpleString defaultAddress, int senderID)
int	ActiveMQSessionContext.sendInitialChunkOnLargeMessage(Message msgI)
int	ActiveMQSessionContext.sendLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int reconnectID, int senderID, SendAcknowledgementHandler messageHandler)
int	ActiveMQSessionContext.sendServerLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int senderID, SendAcknowledgementHandler messageHandler)
void	ActiveMQSessionContext.sessionClose()
void	ActiveMQSessionContext.sessionStart()
void	ActiveMQSessionContext.sessionStop()
void	ActiveMQSessionContext.simpleCommit()
void	ActiveMQSessionContext.simpleCommit(boolean block)
void	ActiveMQSessionContext.simpleRollback(boolean lastMessageAsDelivered)
void	ActiveMQSessionContext.xaCommit(Xid xid, boolean onePhase)
void	ActiveMQSessionContext.xaEnd(Xid xid, int flags)
void	ActiveMQSessionContext.xaFailed(Xid xid)
void	ActiveMQSessionContext.xaForget(Xid xid)
int	ActiveMQSessionContext.xaPrepare(Xid xid)
void	ActiveMQSessionContext.xaRollback(Xid xid, boolean wasStarted)
Xid[]	ActiveMQSessionContext.xaScan()
void	ActiveMQSessionContext.xaStart(Xid xid, int flags)

Uses of ActiveMQException in org.apache.activemq.artemis.core.protocol.core.impl.wireformat

Fields in org.apache.activemq.artemis.core.protocol.core.impl.wireformat declared as ActiveMQException

Modifier and Type	Field	Description
protected ActiveMQException	ActiveMQExceptionMessage.exception

Methods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return ActiveMQException

Modifier and Type	Method	Description
ActiveMQException	ActiveMQExceptionMessage.getException()

Constructors in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type ActiveMQException

Modifier	Constructor	Description
	ActiveMQExceptionMessage(ActiveMQException exception)
	ActiveMQExceptionMessage_V2(long correlationID, ActiveMQException exception)

Uses of ActiveMQException in org.apache.activemq.artemis.core.protocol.hornetq

Methods in org.apache.activemq.artemis.core.protocol.hornetq that throw ActiveMQException

Modifier and Type	Method	Description
boolean	HQPropertiesConversionInterceptor.intercept(Packet packet, RemotingConnection connection)

Uses of ActiveMQException in org.apache.activemq.artemis.core.protocol.hornetq.client

Methods in org.apache.activemq.artemis.core.protocol.hornetq.client that throw ActiveMQException

Modifier and Type	Method	Description
ClientSession.AddressQuery	HornetQClientSessionContext.addressQuery(SimpleString address)
boolean	HornetQClientProtocolManager.checkForFailover(String nodeID)
ClientConsumerInternal	HornetQClientSessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout)
ClientSession.QueueQuery	HornetQClientSessionContext.queueQuery(SimpleString queueName)

Uses of ActiveMQException in org.apache.activemq.artemis.core.remoting

Methods in org.apache.activemq.artemis.core.remoting with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	FailureListener.connectionFailed(ActiveMQException exception, boolean failedOver)	Notifies that a connection has failed due to the specified exception.
void	FailureListener.connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID)	Notifies that a connection has failed due to the specified exception.

Uses of ActiveMQException in org.apache.activemq.artemis.core.remoting.server.impl

Methods in org.apache.activemq.artemis.core.remoting.server.impl with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	RemotingServiceImpl.connectionException(Object connectionID, ActiveMQException me)

Uses of ActiveMQException in org.apache.activemq.artemis.core.replication

Methods in org.apache.activemq.artemis.core.replication that throw ActiveMQException

Modifier and Type	Method	Description
void	ReplicationEndpoint.ReplicationEndpointEventListener.onPrimaryStopping(ReplicationPrimaryIsStoppingMessage.PrimaryStopping message)
void	ReplicationManager.sendStartSyncMessage(JournalFile[] datafiles, AbstractJournalStorageManager.JournalContent contentType, String nodeID, boolean allowsAutoFailBack)	Reserve the following fileIDs in the backup server.
void	ReplicationManager.start()

Uses of ActiveMQException in org.apache.activemq.artemis.core.server

Subclasses of ActiveMQException in org.apache.activemq.artemis.core.server

Modifier and Type	Class	Description
class	ActiveMQLockAcquisitionTimeoutException

Methods in org.apache.activemq.artemis.core.server that return ActiveMQException

Modifier and Type	Method	Description
ActiveMQException	ActiveMQMessageBundle_impl.connectionDestroyed(String remoteAddress)
ActiveMQException	ActiveMQMessageBundle.connectionDestroyed(String remoteAddress)
ActiveMQException	ActiveMQMessageBundle_impl.embeddedWebServerRestartFailed(Exception e)
ActiveMQException	ActiveMQMessageBundle.embeddedWebServerRestartFailed(Exception e)
ActiveMQException	ActiveMQMessageBundle_impl.groupWhileStopping()
ActiveMQException	ActiveMQMessageBundle.groupWhileStopping()
ActiveMQException	ActiveMQMessageBundle_impl.noConfigurationFoundForScaleDown()
ActiveMQException	ActiveMQMessageBundle.noConfigurationFoundForScaleDown()
ActiveMQException	ActiveMQMessageBundle_impl.noDiscoveryGroupFound(DiscoveryGroupConfiguration dg)
ActiveMQException	ActiveMQMessageBundle.noDiscoveryGroupFound(DiscoveryGroupConfiguration dg)

Methods in org.apache.activemq.artemis.core.server that throw ActiveMQException

Modifier and Type	Method	Description
void	ActiveMQServer.callBrokerAddressPlugins(ActiveMQPluginRunnable<ActiveMQServerAddressPlugin> pluginRun)
void	ActiveMQServer.callBrokerAMQPFederationPlugins(ActiveMQPluginRunnable<AMQPFederationBrokerPlugin> pluginRun)
void	ActiveMQServer.callBrokerBindingPlugins(ActiveMQPluginRunnable<ActiveMQServerBindingPlugin> pluginRun)
void	ActiveMQServer.callBrokerBridgePlugins(ActiveMQPluginRunnable<ActiveMQServerBridgePlugin> pluginRun)
void	ActiveMQServer.callBrokerConnectionPlugins(ActiveMQPluginRunnable<ActiveMQServerConnectionPlugin> pluginRun)
void	ActiveMQServer.callBrokerConsumerPlugins(ActiveMQPluginRunnable<ActiveMQServerConsumerPlugin> pluginRun)
void	ActiveMQServer.callBrokerCriticalPlugins(ActiveMQPluginRunnable<ActiveMQServerCriticalPlugin> pluginRun)
void	ActiveMQServer.callBrokerFederationPlugins(ActiveMQPluginRunnable<ActiveMQServerFederationPlugin> pluginRun)
void	ActiveMQServer.callBrokerMessagePlugins(ActiveMQPluginRunnable<ActiveMQServerMessagePlugin> pluginRun)
boolean	ActiveMQServer.callBrokerMessagePluginsCanAccept(ServerConsumer serverConsumer, MessageReference messageReference)
void	ActiveMQServer.callBrokerPlugins(ActiveMQPluginRunnable pluginRun)
void	ActiveMQServer.callBrokerQueuePlugins(ActiveMQPluginRunnable<ActiveMQServerQueuePlugin> pluginRun)
void	ActiveMQServer.callBrokerResourcePlugins(ActiveMQPluginRunnable<ActiveMQServerResourcePlugin> pluginRun)
void	ActiveMQServer.callBrokerSessionPlugins(ActiveMQPluginRunnable<ActiveMQServerSessionPlugin> pluginRun)
List<MessageReference>	ScheduledDeliveryHandler.cancel(Predicate<MessageReference> predicate)
void	NodeLocator.connectToCluster(ServerLocatorInternal serverLocator)	connects to the cluster
void	Queue.deliverScheduledMessage(long messageId)	cancels scheduled message with the corresponding message ID and sends it to the head of the queue.
void	Queue.deliverScheduledMessages()	cancels scheduled messages and send them to the head of the queue.
void	Queue.deliverScheduledMessages(String filter)	cancels scheduled messages which match the filter and send them to the head of the queue.
static QueueConfig	QueueConfig.fromQueueConfiguration(QueueConfiguration queueConfiguration)	Deprecated.
SequentialFile	LargeServerMessage.getAppendFile()	This will return the File suitable for appending the message
LargeBodyReader	LargeServerMessage.getLargeBodyReader()
long	MessageReference.getPersistentSize()	This is the size of the message when persisted on disk which is used for metrics tracking Note that even if the message itself is not persisted on disk (ie non-durable) this value is still used for metrics tracking for the amount of data on a queue
abstract void	NodeLocator.locateNode()	Locates a server in a cluster
abstract void	NodeLocator.locateNode(long timeout)	Locates a server in a cluster with a timeout

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.cluster

Methods in org.apache.activemq.artemis.core.server.cluster that throw ActiveMQException

Modifier and Type	Method	Description
void	ClusterControl.announceReplicatingBackupToPrimary(boolean attemptingFailBack, String replicationClusterName)	Announce replicating backup to primary server.
void	ClusterControl.authorize()	authorise this cluster control so it can communicate with the cluster, it will set the cluster channel on a successful authentication.
boolean	ClusterManager.IncomingInterceptorLookingForExceptionMessage.intercept(Packet packet, RemotingConnection connection)

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.cluster.ha

Methods in org.apache.activemq.artemis.core.server.cluster.ha that throw ActiveMQException

Modifier and Type	Method	Description
static ServerLocatorInternal	ScaleDownPolicy.getScaleDownConnector(ScaleDownPolicy scaleDownPolicy, ActiveMQServer activeMQServer)

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.cluster.impl

Methods in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	BridgeImpl.beforeReconnect(ActiveMQException exception)
void	BridgeImpl.connectionFailed(ActiveMQException me, boolean failedOver)
void	BridgeImpl.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)

Constructors in org.apache.activemq.artemis.core.server.cluster.impl that throw ActiveMQException

Modifier	Constructor	Description
	BridgeImpl(ServerLocatorInternal serverLocator, BridgeConfiguration configuration, UUID nodeUUID, Queue queue, Executor executor, ScheduledExecutorService scheduledExecutor, ActiveMQServer server)
	ClusterConnectionBridge(ClusterConnection clusterConnection, ClusterManager clusterManager, ServerLocatorInternal targetLocator, ServerLocatorInternal discoveryLocator, int initialConnectAttempts, int reconnectAttempts, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, long targetNodeEventUID, String targetNodeID, SimpleString name, Queue queue, Executor executor, Filter filterString, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, TransformerConfiguration transformer, boolean useDuplicateDetection, String user, String password, ActiveMQServer server, SimpleString managementAddress, SimpleString managementNotificationAddress, MessageFlowRecord flowRecord, TransportConfiguration connector, String storeAndForwardPrefix, StorageManager storageManager, String clientId)

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.cluster.quorum

Methods in org.apache.activemq.artemis.core.server.cluster.quorum with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	SharedNothingBackupQuorum.beforeReconnect(ActiveMQException exception)
void	SharedNothingBackupQuorum.connectionFailed(ActiveMQException exception, boolean failedOver)	if the connection to our replicated primary goes down then decide on an action
void	SharedNothingBackupQuorum.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.federation

Methods in org.apache.activemq.artemis.core.server.federation with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	FederatedQueueConsumerImpl.beforeReconnect(ActiveMQException exception)
void	FederationDownstream.beforeReconnect(ActiveMQException exception)
void	FederatedQueueConsumerImpl.connectionFailed(ActiveMQException exception, boolean failedOver)
void	FederatedQueueConsumerImpl.connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID)
void	FederationDownstream.connectionFailed(ActiveMQException exception, boolean failedOver)
void	FederationDownstream.connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID)

Methods in org.apache.activemq.artemis.core.server.federation that throw ActiveMQException

Modifier and Type	Method	Description
void	FederatedQueueConsumerImpl.ClientSessionCallback.callback(ClientSession clientSession)
void	Federation.deploy()
boolean	Federation.deploy(FederationDownstreamConfiguration downstreamConfiguration, Map<String,FederationPolicy> federationPolicyMap)
boolean	Federation.deploy(FederationUpstreamConfiguration upstreamConfiguration, Map<String,FederationPolicy> federationPolicyMap)
void	FederationDownstream.deploy(FederationConfiguration federationConfiguration)
void	FederationManager.deploy()
boolean	FederationManager.deploy(FederationConfiguration federationConfiguration)
void	FederationUpstream.deploy(Set<String> policyRefsToDeploy, Map<String,FederationPolicy> policyMap)
boolean	FederationUpstream.deploy(FederationAddressPolicyConfiguration federatedAddressConfig)
boolean	FederationUpstream.deploy(FederationQueuePolicyConfiguration federatedQueueConfig)
void	Federation.start()
void	FederationManager.start()

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.federation.queue

Constructors in org.apache.activemq.artemis.core.server.federation.queue that throw ActiveMQException

Modifier	Constructor	Description
	FederatedQueue(Federation federation, FederationQueuePolicyConfiguration config, ActiveMQServer server, FederationUpstream federationUpstream)

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.impl

Methods in org.apache.activemq.artemis.core.server.impl with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	ServerSessionImpl.connectionFailed(ActiveMQException me, boolean failedOver)
void	ServerSessionImpl.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)
void	ServerSessionImpl.TempQueueCleanerUpper.connectionFailed(ActiveMQException exception, boolean failedOver)
void	ServerSessionImpl.TempQueueCleanerUpper.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)

Methods in org.apache.activemq.artemis.core.server.impl that throw ActiveMQException

Modifier and Type	Method	Description
void	ActiveMQServerImpl.callBrokerAddressPlugins(ActiveMQPluginRunnable<ActiveMQServerAddressPlugin> pluginRun)
void	ActiveMQServerImpl.callBrokerAMQPFederationPlugins(ActiveMQPluginRunnable<AMQPFederationBrokerPlugin> pluginRun)
void	ActiveMQServerImpl.callBrokerBindingPlugins(ActiveMQPluginRunnable<ActiveMQServerBindingPlugin> pluginRun)
void	ActiveMQServerImpl.callBrokerBridgePlugins(ActiveMQPluginRunnable<ActiveMQServerBridgePlugin> pluginRun)
void	ActiveMQServerImpl.callBrokerConnectionPlugins(ActiveMQPluginRunnable<ActiveMQServerConnectionPlugin> pluginRun)
void	ActiveMQServerImpl.callBrokerConsumerPlugins(ActiveMQPluginRunnable<ActiveMQServerConsumerPlugin> pluginRun)
void	ActiveMQServerImpl.callBrokerCriticalPlugins(ActiveMQPluginRunnable<ActiveMQServerCriticalPlugin> pluginRun)
void	ActiveMQServerImpl.callBrokerFederationPlugins(ActiveMQPluginRunnable<ActiveMQServerFederationPlugin> pluginRun)
void	ActiveMQServerImpl.callBrokerMessagePlugins(ActiveMQPluginRunnable<ActiveMQServerMessagePlugin> pluginRun)
boolean	ActiveMQServerImpl.callBrokerMessagePluginsCanAccept(ServerConsumer serverConsumer, MessageReference messageReference)
void	ActiveMQServerImpl.callBrokerPlugins(ActiveMQPluginRunnable pluginRun)
void	ActiveMQServerImpl.callBrokerQueuePlugins(ActiveMQPluginRunnable<ActiveMQServerQueuePlugin> pluginRun)
void	ActiveMQServerImpl.callBrokerResourcePlugins(ActiveMQPluginRunnable<ActiveMQServerResourcePlugin> pluginRun)
void	ActiveMQServerImpl.callBrokerSessionPlugins(ActiveMQPluginRunnable<ActiveMQServerSessionPlugin> pluginRun)
List<MessageReference>	ScheduledDeliveryHandlerImpl.cancel(Predicate<MessageReference> predicate)
JournalLoader	Activation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer)	create the Journal loader needed for this Activation.
JournalLoader	SharedNothingBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer)
JournalLoader	SharedStoreBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer)
void	QueueImpl.deliverScheduledMessage(long messageId)
void	QueueImpl.deliverScheduledMessages()
void	QueueImpl.deliverScheduledMessages(String filterString)
long	GroupFirstMessageReference.getPersistentSize()
long	MessageReferenceImpl.getPersistentSize()
void	AnyNodeLocatorForReplication.locateNode()
void	AnyNodeLocatorForReplication.locateNode(long timeout)
void	AnyNodeLocatorForScaleDown.locateNode()
void	AnyNodeLocatorForScaleDown.locateNode(long timeout)
void	NamedNodeIdLocatorForReplication.locateNode()
void	NamedNodeIdLocatorForReplication.locateNode(long timeout)
void	NamedNodeIdNodeLocator.locateNode()
void	NamedNodeIdNodeLocator.locateNode(long timeout)
void	NamedNodeLocatorForReplication.locateNode()
void	NamedNodeLocatorForReplication.locateNode(long timeout)
void	NamedNodeLocatorForScaleDown.locateNode()
void	NamedNodeLocatorForScaleDown.locateNode(long timeout)
void	SharedNothingBackupActivation.onPrimaryStopping(ReplicationPrimaryIsStoppingMessage.PrimaryStopping finalMessage)
void	SharedNothingPrimaryActivation.startReplication(CoreRemotingConnection rc, ClusterConnection clusterConnection, Pair<TransportConfiguration,TransportConfiguration> pair, boolean isFailBackRequest)

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.impl.quorum

Methods in org.apache.activemq.artemis.core.server.impl.quorum that throw ActiveMQException

Modifier and Type	Method	Description
static void	ActivationSequenceStateMachine.ensureSequentialAccessToNodeData(String serverDescription, NodeManager nodeManager, org.apache.activemq.artemis.lockmanager.DistributedLockManager distributedManager, Logger logger)	This is going to increment the coordinated activation sequence and the local activation sequence (using NodeManager.writeNodeActivationSequence(long)) while holding the primary lock, failing with some exception otherwise.

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.plugin

Methods in org.apache.activemq.artemis.core.server.plugin that throw ActiveMQException

Modifier and Type	Method	Description
default void	ActiveMQServerBridgePlugin.afterAcknowledgeBridge(Bridge bridge, MessageReference ref)	Called after delivered message over this bridge has been acknowledged by the remote broker
default void	ActiveMQServerAddressPlugin.afterAddAddress(AddressInfo addressInfo, boolean reload)	After an address has been added tot he broker
default void	ActiveMQServerBindingPlugin.afterAddBinding(Binding binding)	After a binding has been added
default void	ActiveMQServerConsumerPlugin.afterCloseConsumer(ServerConsumer consumer, boolean failed)	After a consumer is closed
default void	ActiveMQServerFederationPlugin.afterCloseFederatedQueueConsumer(FederatedQueueConsumer consumer)	After a federated queue consumer is closed
default void	ActiveMQServerSessionPlugin.afterCloseSession(ServerSession session, boolean failed)	After a session is closed
default void	ActiveMQServerConnectionPlugin.afterCreateConnection(RemotingConnection connection)	A connection has been created.
default void	ActiveMQServerConsumerPlugin.afterCreateConsumer(ServerConsumer consumer)	After a consumer has been created
default void	ActiveMQServerFederationPlugin.afterCreateFederatedQueueConsumer(FederatedQueueConsumer consumer)	After a federated queue consumer is created
default void	ActiveMQServerQueuePlugin.afterCreateQueue(Queue queue)	After a queue has been created
default void	ActiveMQServerSessionPlugin.afterCreateSession(ServerSession session)	After a session has been created.
default void	ActiveMQServerMessagePlugin.afterDeliver(MessageReference reference)	Deprecated. use ActiveMQServerMessagePlugin.afterDeliver(ServerConsumer, MessageReference)
default void	ActiveMQServerMessagePlugin.afterDeliver(ServerConsumer consumer, MessageReference reference)	After a message is delivered to a client consumer
default void	ActiveMQServerBridgePlugin.afterDeliverBridge(Bridge bridge, MessageReference ref, HandleStatus status)	Called immediately after a bridge delivers a message but before the message is acknowledged
default void	ActiveMQServerBridgePlugin.afterDeployBridge(Bridge bridge)	After a bridge has been deployed
default void	ActiveMQServerConnectionPlugin.afterDestroyConnection(RemotingConnection connection)	A connection has been destroyed.
default void	ActiveMQServerQueuePlugin.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)	After a queue has been destroyed
default void	ActiveMQServerFederationPlugin.afterFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer, Message message)	After a federated queue consumer handles a message
default void	ActiveMQServerMessagePlugin.afterMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, RoutingStatus result)	After a message is routed
default void	ActiveMQServerResourcePlugin.afterPutTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection)	After a transaction is put
default void	ActiveMQServerAddressPlugin.afterRemoveAddress(SimpleString address, AddressInfo addressInfo)	After an address has been removed
default void	ActiveMQServerBindingPlugin.afterRemoveBinding(Binding binding, Transaction tx, boolean deleteData)	After a binding is removed
default void	ActiveMQServerResourcePlugin.afterRemoveTransaction(Xid xid, RemotingConnection remotingConnection)	After a transaction is removed
default void	ActiveMQServerMessagePlugin.afterSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result)	After a message is sent
default void	ActiveMQServerMessagePlugin.afterSend(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result)	Deprecated. use ActiveMQServerMessagePlugin.afterSend(ServerSession, Transaction, Message, boolean, boolean, RoutingStatus)
default void	ActiveMQServerSessionPlugin.afterSessionMetadataAdded(ServerSession session, String key, String data)	After session metadata is added to the session
default void	ActiveMQServerAddressPlugin.afterUpdateAddress(AddressInfo addressInfo)	After an address has been updated
default void	ActiveMQServerAddressPlugin.beforeAddAddress(AddressInfo addressInfo, boolean reload)	Before an address is added tot he broker
default void	ActiveMQServerBindingPlugin.beforeAddBinding(Binding binding)	Before a binding is added
default void	ActiveMQServerConsumerPlugin.beforeCloseConsumer(ServerConsumer consumer, boolean failed)	Before a consumer is closed
default void	ActiveMQServerFederationPlugin.beforeCloseFederatedQueueConsumer(FederatedQueueConsumer consumer)	Before a federated queue consumer is closed
default void	ActiveMQServerSessionPlugin.beforeCloseSession(ServerSession session, boolean failed)	Before a session is closed
default void	ActiveMQServerConsumerPlugin.beforeCreateConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage)	Deprecated. use ActiveMQServerConsumerPlugin.beforeCreateConsumer(long, QueueBinding, SimpleString, boolean, boolean)
default void	ActiveMQServerConsumerPlugin.beforeCreateConsumer(long consumerID, QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage)	Before a consumer is created
default void	ActiveMQServerFederationPlugin.beforeCreateFederatedQueueConsumer(FederatedConsumerKey key)	Before a federated queue consumer is created
default void	ActiveMQServerQueuePlugin.beforeCreateQueue(QueueConfiguration queueConfig)	Before a queue is created
default void	ActiveMQServerQueuePlugin.beforeCreateQueue(QueueConfig queueConfig)	Before a queue is created
default void	ActiveMQServerSessionPlugin.beforeCreateSession(String name, String username, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString,RoutingType> prefixes)	Before a session is created.
default void	ActiveMQServerMessagePlugin.beforeDeliver(MessageReference reference)	Deprecated. use throws ActiveMQException ActiveMQServerMessagePlugin.beforeDeliver(ServerConsumer, MessageReference)
default void	ActiveMQServerMessagePlugin.beforeDeliver(ServerConsumer consumer, MessageReference reference)	Before a message is delivered to a client consumer
default void	ActiveMQServerBridgePlugin.beforeDeliverBridge(Bridge bridge, MessageReference ref)	Called immediately before a bridge delivers a message
default void	ActiveMQServerBridgePlugin.beforeDeployBridge(BridgeConfiguration config)	Before a bridge is deployed
default void	ActiveMQServerQueuePlugin.beforeDestroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)	Deprecated. use ActiveMQServerQueuePlugin.beforeDestroyQueue(Queue, SecurityAuth, boolean, boolean, boolean)
default void	ActiveMQServerQueuePlugin.beforeDestroyQueue(Queue queue, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)	Before a queue is destroyed
default void	ActiveMQServerFederationPlugin.beforeFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer, Message message)	Before a federated queue consumer handles a message
default void	ActiveMQServerMessagePlugin.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)	Before a message is routed
default void	ActiveMQServerResourcePlugin.beforePutTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection)	Before a transaction is put
default void	ActiveMQServerAddressPlugin.beforeRemoveAddress(SimpleString address)	Before an address is removed
default void	ActiveMQServerBindingPlugin.beforeRemoveBinding(SimpleString uniqueName, Transaction tx, boolean deleteData)	Before a binding is removed
default void	ActiveMQServerResourcePlugin.beforeRemoveTransaction(Xid xid, RemotingConnection remotingConnection)	Before a transaction is removed
default void	ActiveMQServerMessagePlugin.beforeSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)	Before a message is sent
default void	ActiveMQServerMessagePlugin.beforeSend(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)	Deprecated. use ActiveMQServerMessagePlugin.beforeSend(ServerSession, Transaction, Message, boolean, boolean)
default void	ActiveMQServerSessionPlugin.beforeSessionMetadataAdded(ServerSession session, String key, String data)	Before session metadata is added to the session
default void	ActiveMQServerAddressPlugin.beforeUpdateAddress(SimpleString address, EnumSet<RoutingType> routingTypes)	Before an address is updated
default boolean	ActiveMQServerMessagePlugin.canAccept(ServerConsumer consumer, MessageReference reference)	Before a message is delivered to a client consumer
default void	ActiveMQServerCriticalPlugin.criticalFailure(CriticalComponent components)	A Critical failure has been detected.
default void	ActiveMQServerSessionPlugin.duplicateSessionMetadataFailure(ServerSession session, String key, String data)	Called when adding session metadata fails because the metadata is a duplicate
default boolean	ActiveMQServerFederationPlugin.federatedAddressConditionalCreateConsumer(Queue queue)	Conditionally create a federated queue consumer for a federated address.
default boolean	ActiveMQServerFederationPlugin.federatedAddressConditionalCreateDivertConsumer(DivertBinding divertBinding, QueueBinding queueBinding)
default boolean	ActiveMQServerFederationPlugin.federatedQueueConditionalCreateConsumer(ServerConsumer consumer)	Conditionally create a federated queue consumer for a federated queue.
default void	ActiveMQServerFederationPlugin.federationStreamStarted(FederationStream stream)	After a federation stream has been started
default void	ActiveMQServerFederationPlugin.federationStreamStopped(FederationStream stream)	After a federation stream has been stopped
default void	ActiveMQServerMessagePlugin.messageAcknowledged(MessageReference ref, AckReason reason)	Deprecated. use ActiveMQServerMessagePlugin.messageAcknowledged(MessageReference, AckReason, ServerConsumer)
default void	ActiveMQServerMessagePlugin.messageAcknowledged(MessageReference ref, AckReason reason, ServerConsumer consumer)	Deprecated.
default void	ActiveMQServerMessagePlugin.messageAcknowledged(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer)	A message has been acknowledged
default void	ActiveMQServerMessagePlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress)	Deprecated. use ActiveMQServerMessagePlugin.messageExpired(MessageReference, SimpleString, ServerConsumer)
default void	ActiveMQServerMessagePlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer)	A message has been expired
default void	ActiveMQServerMessagePlugin.messageMoved(Transaction tx, MessageReference ref, AckReason reason, SimpleString destAddress, Long destQueueID, ServerConsumer consumer, Message newMessage, RoutingStatus result)	A message has been moved
default void	ActiveMQServerMessagePlugin.onMessageRouteException(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e)	When there was an error routing the message
default void	ActiveMQServerMessagePlugin.onSendException(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e)	When there was an exception sending the message
void	ActiveMQPluginRunnable.run(P plugin)

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.plugin.impl

Methods in org.apache.activemq.artemis.core.server.plugin.impl that throw ActiveMQException

Modifier and Type	Method	Description
void	NotificationActiveMQServerPlugin.afterAddAddress(AddressInfo addressInfo, boolean reload)
void	LoggingActiveMQServerPlugin.afterCloseConsumer(ServerConsumer consumer, boolean failed)	After a consumer is closed
void	LoggingActiveMQServerPlugin.afterCloseSession(ServerSession session, boolean failed)	After a session is closed
void	LoggingActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection)	A connection has been created.
void	NotificationActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection)
void	LoggingActiveMQServerPlugin.afterCreateConsumer(ServerConsumer consumer)	After a consumer has been created
void	LoggingActiveMQServerPlugin.afterCreateQueue(Queue queue)	After a queue has been created
void	LoggingActiveMQServerPlugin.afterCreateSession(ServerSession session)	After a session has been created.
void	LoggingActiveMQServerPlugin.afterDeliver(ServerConsumer consumer, MessageReference reference)	After a message is delivered to a client consumer
void	NotificationActiveMQServerPlugin.afterDeliver(ServerConsumer consumer, MessageReference reference)
void	LoggingActiveMQServerPlugin.afterDeployBridge(Bridge bridge)	After a bridge has been deployed
void	LoggingActiveMQServerPlugin.afterDestroyConnection(RemotingConnection connection)	A connection has been destroyed.
void	NotificationActiveMQServerPlugin.afterDestroyConnection(RemotingConnection connection)
void	LoggingActiveMQServerPlugin.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)	After a queue has been destroyed
void	LoggingActiveMQServerPlugin.afterMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, RoutingStatus result)	After a message is routed
void	NotificationActiveMQServerPlugin.afterRemoveAddress(SimpleString address, AddressInfo addressInfo)
void	LoggingActiveMQServerPlugin.afterSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result)	After a message is sent
void	LoggingActiveMQServerPlugin.afterSessionMetadataAdded(ServerSession session, String key, String data)	After session metadata is added to the session
void	LoggingActiveMQServerPlugin.beforeCloseConsumer(ServerConsumer consumer, boolean failed)	Before a consumer is closed
void	LoggingActiveMQServerPlugin.beforeCloseSession(ServerSession session, boolean failed)	Before a session is closed
void	LoggingActiveMQServerPlugin.beforeCreateConsumer(long consumerID, QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage)	Before a consumer is created
void	LoggingActiveMQServerPlugin.beforeCreateQueue(QueueConfiguration queueConfig)	Before a queue is created
void	LoggingActiveMQServerPlugin.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.
void	LoggingActiveMQServerPlugin.beforeDeliver(ServerConsumer consumer, MessageReference reference)	Before a message is delivered to a client consumer
void	LoggingActiveMQServerPlugin.beforeDeployBridge(BridgeConfiguration config)	Before a bridge is deployed
void	LoggingActiveMQServerPlugin.beforeDestroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)	Before a queue is destroyed
void	LoggingActiveMQServerPlugin.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)	Before a message is routed
void	LoggingActiveMQServerPlugin.beforeSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)	Before a message is sent
void	LoggingActiveMQServerPlugin.beforeSessionMetadataAdded(ServerSession session, String key, String data)	Before session metadata is added to the session
boolean	BrokerMessageAuthorizationPlugin.canAccept(ServerConsumer consumer, MessageReference reference)
void	LoggingActiveMQServerPlugin.criticalFailure(CriticalComponent components)	A Critical failure has been detected.
void	LoggingActiveMQServerPlugin.messageAcknowledged(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer)	A message has been acknowledged
void	LoggingActiveMQServerPlugin.onMessageRouteException(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e)
void	LoggingActiveMQServerPlugin.onSendException(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e)

Uses of ActiveMQException in org.apache.activemq.artemis.core.server.routing.targets

Methods in org.apache.activemq.artemis.core.server.routing.targets with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	ActiveMQTarget.connectionFailed(ActiveMQException exception, boolean failedOver)
void	ActiveMQTarget.connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID)

Uses of ActiveMQException in org.apache.activemq.artemis.core.transaction

Methods in org.apache.activemq.artemis.core.transaction with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	Transaction.markAsRollbackOnly(ActiveMQException exception)

Methods in org.apache.activemq.artemis.core.transaction that throw ActiveMQException

Modifier and Type	Method	Description
boolean	ResourceManager.putTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection)
Transaction	ResourceManager.removeTransaction(Xid xid, RemotingConnection remotingConnection)

Uses of ActiveMQException in org.apache.activemq.artemis.core.transaction.impl

Methods in org.apache.activemq.artemis.core.transaction.impl with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	TransactionImpl.markAsRollbackOnly(ActiveMQException exception)

Methods in org.apache.activemq.artemis.core.transaction.impl that throw ActiveMQException

Modifier and Type	Method	Description
boolean	ResourceManagerImpl.putTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection)
Transaction	ResourceManagerImpl.removeTransaction(Xid xid, RemotingConnection remotingConnection)

Uses of ActiveMQException in org.apache.activemq.artemis.jdbc.store.file

Methods in org.apache.activemq.artemis.jdbc.store.file that throw ActiveMQException

Modifier and Type	Method	Description
void	JDBCSequentialFile.delete()

Uses of ActiveMQException in org.apache.activemq.artemis.jms.client

Methods in org.apache.activemq.artemis.jms.client with parameters of type ActiveMQException

Modifier and Type	Method	Description
static JMSException	JMSExceptionHelper.convertFromActiveMQException(ActiveMQException me)

Methods in org.apache.activemq.artemis.jms.client that throw ActiveMQException

Modifier and Type	Method	Description
void	ActiveMQBytesMessage.doBeforeReceive()
void	ActiveMQMapMessage.doBeforeReceive()
void	ActiveMQMessage.doBeforeReceive()
void	ActiveMQObjectMessage.doBeforeReceive()
void	ActiveMQTextMessage.doBeforeReceive()
protected Queue	ActiveMQSession.internalCreateQueue(String queueName)
protected ActiveMQQueue	ActiveMQSession.internalCreateQueueCompatibility(String queueName)
protected Topic	ActiveMQSession.internalCreateTopic(String topicName, boolean retry)

Uses of ActiveMQException in org.apache.activemq.artemis.jms.server.impl

Methods in org.apache.activemq.artemis.jms.server.impl that throw ActiveMQException

Modifier and Type	Method	Description
protected ActiveMQConnectionFactory	JMSServerManagerImpl.internalCreateCFPOJO(ConnectionFactoryConfiguration cfConfig)	Deprecated.

Uses of ActiveMQException in org.apache.activemq.artemis.ra

Methods in org.apache.activemq.artemis.ra that throw ActiveMQException

Modifier and Type	Method	Description
void	ActiveMQRAProperties.init()
protected void	ActiveMQResourceAdapter.setup()

Uses of ActiveMQException in org.apache.activemq.artemis.ra.inflow

Methods in org.apache.activemq.artemis.ra.inflow that throw ActiveMQException

Modifier and Type	Method	Description
void	ActiveMQMessageHandler.start()

Uses of ActiveMQException in org.apache.activemq.artemis.reader

Methods in org.apache.activemq.artemis.reader that throw ActiveMQException

Modifier and Type	Method	Description
static final void	MessageUtil.setJMSCorrelationIDAsBytes(Message message, byte[] correlationID)

Uses of ActiveMQException in org.apache.activemq.artemis.service.extensions.xa.recovery

Methods in org.apache.activemq.artemis.service.extensions.xa.recovery with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	ActiveMQXAResourceWrapper.beforeReconnect(ActiveMQException me)
void	ActiveMQXAResourceWrapper.connectionFailed(ActiveMQException me, boolean failedOver)
void	ActiveMQXAResourceWrapper.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)

Uses of ActiveMQException in org.apache.activemq.artemis.spi.core.protocol

Methods in org.apache.activemq.artemis.spi.core.protocol with parameters of type ActiveMQException

Modifier and Type	Method	Description
Future	AbstractRemotingConnection.asyncFail(ActiveMQException me)
Future	RemotingConnection.asyncFail(ActiveMQException me)	Same thing as fail, but using an executor. semantic of send here, is asynchrounous.
protected void	AbstractRemotingConnection.callFailureListeners(ActiveMQException me, String scaleDownTargetNodeID)
void	AbstractRemotingConnection.fail(ActiveMQException me)
void	RemotingConnection.fail(ActiveMQException me)	called when the underlying connection fails.
void	RemotingConnection.fail(ActiveMQException me, String scaleDownTargetNodeID)	called when the underlying connection fails.

Uses of ActiveMQException in org.apache.activemq.artemis.spi.core.remoting

Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type ActiveMQException

Modifier and Type	Method	Description
boolean	ClientProtocolManager.cleanupBeforeFailover(ActiveMQException cause)
void	BaseConnectionLifeCycleListener.connectionException(Object connectionID, ActiveMQException me)	Called when an error occurs on the connection.
abstract void	SessionContext.returnBlocking(ActiveMQException cause)	Interrupt and return any blocked calls

Methods in org.apache.activemq.artemis.spi.core.remoting that throw ActiveMQException

Modifier and Type	Method	Description
abstract ClientSession.AddressQuery	SessionContext.addressQuery(SimpleString address)
abstract void	SessionContext.addSessionMetadata(String key, String data)
abstract void	SessionContext.addUniqueMetaData(String key, String data)
boolean	ClientProtocolManager.checkForFailover(String nodeID)
abstract void	SessionContext.closeConsumer(ClientConsumer consumer)
abstract boolean	SessionContext.configureTransactionTimeout(int seconds)
abstract void	SessionContext.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated)
abstract void	SessionContext.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated)	Deprecated.
abstract ClientConsumerInternal	SessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout)
abstract void	SessionContext.createQueue(QueueConfiguration queueConfiguration)
abstract void	SessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated)	Deprecated.
abstract void	SessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated, Boolean exclusive, Boolean lastVale)
abstract void	SessionContext.createQueue(SimpleString address, SimpleString queueName, boolean temp, boolean autoCreated, QueueAttributes queueAttributes)
abstract void	SessionContext.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, boolean autoCreated)	Deprecated.
SessionContext	ClientProtocolManager.createSessionContext(String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, String clientID)
abstract void	SessionContext.createSharedQueue(QueueConfiguration queueConfiguration)
abstract void	SessionContext.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes)	Deprecated.
abstract void	SessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable)	Deprecated.
abstract void	SessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)	Deprecated.
abstract void	SessionContext.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable)	Deprecated.
abstract void	SessionContext.deleteQueue(SimpleString queueName)
abstract void	SessionContext.expireMessage(ClientConsumer consumer, Message message)
abstract void	SessionContext.forceDelivery(ClientConsumer consumer, long sequence)
abstract int	SessionContext.getDefaultConsumerWindowSize(SessionQueueQueryResponseMessage response)
abstract ClientSession.QueueQuery	SessionContext.queueQuery(SimpleString queueName)
abstract boolean	SessionContext.reattachOnNewConnection(RemotingConnection newConnection)	it will either reattach or reconnect, preferably reattaching it.
abstract int	SessionContext.recoverSessionTimeout()	Performs a round trip to the server requesting what is the current tx timeout on the session
abstract void	SessionContext.recreateConsumerOnServer(ClientConsumerInternal consumerInternal, long consumerId, boolean isSessionStarted)
abstract void	SessionContext.recreateSession(String username, String password, int minLargeMessageSize, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge)
abstract void	SessionContext.restartSession()
abstract void	SessionContext.sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message)
abstract void	SessionContext.sendFullMessage(ICoreMessage msgI, boolean sendBlocking, SendAcknowledgementHandler handler, SimpleString defaultAddress, int senderID)
abstract int	SessionContext.sendInitialChunkOnLargeMessage(Message msgI)	it should return the number of credits (or bytes) used to send this packet
abstract int	SessionContext.sendLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int reconnectID, int senderID, SendAcknowledgementHandler messageHandler)
abstract int	SessionContext.sendServerLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int senderID, SendAcknowledgementHandler messageHandler)
abstract void	SessionContext.sessionClose()
abstract void	SessionContext.sessionStart()
abstract void	SessionContext.sessionStop()
abstract void	SessionContext.simpleCommit()
abstract void	SessionContext.simpleCommit(boolean block)
abstract void	SessionContext.simpleRollback(boolean lastMessageAsDelivered)	If we are doing a simple rollback on the RA, we need to ack the last message sent to the consumer, otherwise DLQ won't work.
abstract void	SessionContext.xaCommit(Xid xid, boolean onePhase)
abstract void	SessionContext.xaEnd(Xid xid, int flags)
abstract void	SessionContext.xaFailed(Xid xid)
abstract void	SessionContext.xaForget(Xid xid)
abstract int	SessionContext.xaPrepare(Xid xid)
abstract void	SessionContext.xaRollback(Xid xid, boolean wasStarted)
abstract Xid[]	SessionContext.xaScan()
abstract void	SessionContext.xaStart(Xid xid, int flags)

Uses of ActiveMQException in org.apache.activemq.artemis.utils

Methods in org.apache.activemq.artemis.utils that throw ActiveMQException

Modifier and Type	Method	Description
static void	AutoCreateUtil.autoCreateQueue(ClientSession session, SimpleString destAddress, SimpleString selectorString)
static SensitiveDataCodec<String>	PasswordMaskingUtil.getCodec(String codecDesc)	Loading the codec class.

Uses of ActiveMQException in org.jboss.activemq.artemis.wildfly.integration.recovery

Methods in org.jboss.activemq.artemis.wildfly.integration.recovery with parameters of type ActiveMQException

Modifier and Type	Method	Description
void	WildFlyRecoveryDiscovery.beforeReconnect(ActiveMQException exception)
void	WildFlyRecoveryDiscovery.connectionFailed(ActiveMQException exception, boolean failedOver)
void	WildFlyRecoveryDiscovery.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)