Uses of Class
org.apache.activemq.artemis.api.core.ActiveMQException
-
-
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 class
ActiveMQAddressDoesNotExistException
An operation failed because an address exists on the server.class
ActiveMQAddressExistsException
An operation failed because an address exists on the server.class
ActiveMQAddressFullException
An address is full.class
ActiveMQAlreadyReplicatingException
The server is already paired with a replicating backup.class
ActiveMQClusterSecurityException
Security exception thrown when the cluster user fails authentication.class
ActiveMQConnectionTimedOutException
A client timed out will connecting to ActiveMQ Artemis server.class
ActiveMQDeleteAddressException
An operation failed because an address exists on the server.class
ActiveMQDisconnectedException
A client was disconnected from ActiveMQ Artemis server when the server has shut down.class
ActiveMQDivertDoesNotExistException
An operation failed because an address exists on the server.class
ActiveMQDuplicateIdException
A DuplicateID was rejected.class
ActiveMQDuplicateMetaDataException
A Session Metadata was set in duplicationclass
ActiveMQIllegalStateException
An ActiveMQ Artemis resource is not in a legal state (e.g.class
ActiveMQIncompatibleClientServerException
The server version and the client version are incompatible.class
ActiveMQInterceptorRejectedPacketException
An outgoing interceptor returned false.class
ActiveMQInternalErrorException
Internal error which prevented ActiveMQ Artemis from performing an important operation.class
ActiveMQInvalidFilterExpressionException
A filter expression was found to be invalid.class
ActiveMQInvalidQueueConfiguration
An operation failed because a queue exists on the server.class
ActiveMQInvalidTransientQueueUseException
An operation failed because a queue exists on the server.class
ActiveMQIOErrorException
Unexpected I/O error occurred on the server.class
ActiveMQLargeMessageException
A problem occurred while manipulating the body of a large message.class
ActiveMQLargeMessageInterruptedException
class
ActiveMQNativeIOError
An error has happened at ActiveMQ's native (non-Java) code used in reading and writing data.class
ActiveMQNonExistentQueueException
An operation failed because a queue does not exist on the server.class
ActiveMQNotConnectedException
A client is not able to connect to ActiveMQ Artemis server.class
ActiveMQNullRefException
An operation failed because is dereferencing null pointer.class
ActiveMQObjectClosedException
A client operation failed because the calling resource (ClientSession, ClientProducer, etc.) is closed.class
ActiveMQQueueExistsException
An operation failed because a queue exists on the server.class
ActiveMQQueueMaxConsumerLimitReached
An operation failed because a queue exists on the server.class
ActiveMQRemoteDisconnectException
A security problem occurred (authentication issues, permission issues,...)class
ActiveMQReplicationTimeooutException
The creation of a session was rejected by the server (e.g.class
ActiveMQRoutingException
A client was redirected.class
ActiveMQSecurityException
A security problem occurred (authentication issues, permission issues,...)class
ActiveMQSessionCreationException
The creation of a session was rejected by the server (e.g.class
ActiveMQShutdownException
An operation failed because an address exists on the server.class
ActiveMQTimeoutException
An operation timed out.class
ActiveMQTransactionOutcomeUnknownException
The outcome of a transaction is unknown.class
ActiveMQTransactionRolledBackException
A transaction was rolled back.class
ActiveMQTransactionTimeoutException
class
ActiveMQUnBlockedException
A blocking call from a client was unblocked during failover.class
ActiveMQUnexpectedRoutingTypeForAddress
An operation failed because a queue exists on the server.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 org.apache.activemq.artemis.core.message.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 sizeboolean
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 typevoid
ClientSession. createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated)
Deprecated.void
ClientSession. createAddress(SimpleString address, RoutingType routingType, boolean autoCreated)
Create Address with a single initial routing typeClientConsumer
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 addressClientProducer
ClientSession. createProducer(SimpleString address)
Creates a producer which sends messages to the given addressClientProducer
ClientSession. createProducer(SimpleString address, int rate)
Creates a producer which sends messages to the given addressvoid
ClientSession. createQueue(String address, String queueName)
Deprecated.void
ClientSession. createQueue(String address, String queueName, boolean durable)
Deprecated.void
ClientSession. createQueue(String address, String queueName, String filter, boolean durable)
Deprecated.void
ClientSession. createQueue(String address, String queueName, String filter, boolean durable, boolean autoCreated)
Deprecated.void
ClientSession. createQueue(String address, RoutingType routingType, String queueName)
Deprecated.void
ClientSession. createQueue(String address, RoutingType routingType, String queueName, boolean durable)
Deprecated.void
ClientSession. createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable)
Deprecated.void
ClientSession. createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable, boolean autoCreated)
Deprecated.void
ClientSession. createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers)
Deprecated.void
ClientSession. createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)
Deprecated.void
ClientSession. createQueue(QueueConfiguration queueConfiguration)
This method creates a queue based on theQueueConfiguration
input.void
ClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName)
Deprecated.void
ClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable)
Deprecated.void
ClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable)
Deprecated.void
ClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated)
Deprecated.void
ClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers)
Deprecated.void
ClientSession. createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)
Deprecated.void
ClientSession. createQueue(SimpleString address, SimpleString queueName)
Deprecated.void
ClientSession. createQueue(SimpleString address, SimpleString queueName, boolean durable)
Deprecated.void
ClientSession. createQueue(SimpleString address, SimpleString queueName, boolean autoCreated, QueueAttributes queueAttributes)
Deprecated.void
ClientSession. createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable)
Deprecated.void
ClientSession. createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated)
Deprecated.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 asClientSession.createQueue(QueueConfiguration)
with a few key exceptions.void
ClientSession. createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable)
Deprecated.void
ClientSession. createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable)
Deprecated.void
ClientSession. createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)
Deprecated.void
ClientSession. createSharedQueue(SimpleString address, SimpleString queueName, boolean durable)
Deprecated.void
ClientSession. createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes)
Deprecated.void
ClientSession. createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable)
Deprecated.void
ClientSession. createTemporaryQueue(String address, String queueName)
Deprecated.void
ClientSession. createTemporaryQueue(String address, String queueName, String filter)
Deprecated.void
ClientSession. createTemporaryQueue(String address, RoutingType routingType, String queueName)
Deprecated.void
ClientSession. createTemporaryQueue(String address, RoutingType routingType, String queueName, String filter)
Deprecated.void
ClientSession. createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName)
Deprecated.void
ClientSession. createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter)
Deprecated.void
ClientSession. createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue)
Deprecated.void
ClientSession. createTemporaryQueue(SimpleString address, SimpleString queueName)
Deprecated.void
ClientSession. createTemporaryQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes)
Deprecated.void
ClientSession. createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter)
Deprecated.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()
Returns the MessageHandler associated to this consumer.ClientMessage
ClientMessage. individualAcknowledge()
Acknowledges reception of a single message.void
ServerLocator. initialize()
This will only instantiate internal objects such as the topologyClientSession.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.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.server.plugin
Methods in org.apache.activemq.artemis.core.server.plugin that throw ActiveMQException Modifier and Type Method Description default void
ActiveMQServerBridgePlugin. afterAcknowledgeBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge, org.apache.activemq.artemis.core.server.MessageReference ref)
Called after delivered message over this bridge has been acknowledged by the remote brokerdefault void
ActiveMQServerAddressPlugin. afterAddAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo, boolean reload)
After an address has been added tot he brokerdefault void
ActiveMQServerBindingPlugin. afterAddBinding(org.apache.activemq.artemis.core.postoffice.Binding binding)
After a binding has been addeddefault void
ActiveMQServerConsumerPlugin. afterCloseConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer, boolean failed)
After a consumer is closeddefault void
ActiveMQServerFederationPlugin. afterCloseFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer)
After a federated queue consumer is closeddefault void
ActiveMQServerSessionPlugin. afterCloseSession(org.apache.activemq.artemis.core.server.ServerSession session, boolean failed)
After a session is closeddefault void
ActiveMQServerConnectionPlugin. afterCreateConnection(RemotingConnection connection)
A connection has been created.default void
ActiveMQServerConsumerPlugin. afterCreateConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer)
After a consumer has been createddefault void
ActiveMQServerFederationPlugin. afterCreateFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer)
After a federated queue consumer is createddefault void
ActiveMQServerQueuePlugin. afterCreateQueue(org.apache.activemq.artemis.core.server.Queue queue)
After a queue has been createddefault void
ActiveMQServerSessionPlugin. afterCreateSession(org.apache.activemq.artemis.core.server.ServerSession session)
After a session has been created.default void
ActiveMQServerMessagePlugin. afterDeliver(org.apache.activemq.artemis.core.server.MessageReference reference)
default void
ActiveMQServerMessagePlugin. afterDeliver(org.apache.activemq.artemis.core.server.ServerConsumer consumer, org.apache.activemq.artemis.core.server.MessageReference reference)
After a message is delivered to a client consumerdefault void
ActiveMQServerBridgePlugin. afterDeliverBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge, org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.HandleStatus status)
Called immediately after a bridge delivers a message but before the message is acknowledgeddefault void
ActiveMQServerBridgePlugin. afterDeployBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge)
After a bridge has been deployeddefault void
ActiveMQServerConnectionPlugin. afterDestroyConnection(RemotingConnection connection)
A connection has been destroyed.default void
ActiveMQServerQueuePlugin. afterDestroyQueue(org.apache.activemq.artemis.core.server.Queue queue, SimpleString address, org.apache.activemq.artemis.core.security.SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)
After a queue has been destroyeddefault void
ActiveMQServerFederationPlugin. afterFederatedQueueConsumerMessageHandled(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer, Message message)
After a federated queue consumer handles a messagedefault void
ActiveMQServerMessagePlugin. afterMessageRoute(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates, org.apache.activemq.artemis.core.postoffice.RoutingStatus result)
After a message is routeddefault void
ActiveMQServerResourcePlugin. afterPutTransaction(Xid xid, org.apache.activemq.artemis.core.transaction.Transaction tx, RemotingConnection remotingConnection)
After a transaction is putdefault void
ActiveMQServerAddressPlugin. afterRemoveAddress(SimpleString address, org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
After an address has been removeddefault void
ActiveMQServerBindingPlugin. afterRemoveBinding(org.apache.activemq.artemis.core.postoffice.Binding binding, org.apache.activemq.artemis.core.transaction.Transaction tx, boolean deleteData)
After a binding is removeddefault void
ActiveMQServerResourcePlugin. afterRemoveTransaction(Xid xid, RemotingConnection remotingConnection)
After a transaction is removeddefault void
ActiveMQServerMessagePlugin. afterSend(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, org.apache.activemq.artemis.core.postoffice.RoutingStatus result)
After a message is sentdefault void
ActiveMQServerMessagePlugin. afterSend(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, org.apache.activemq.artemis.core.postoffice.RoutingStatus result)
default void
ActiveMQServerSessionPlugin. afterSessionMetadataAdded(org.apache.activemq.artemis.core.server.ServerSession session, String key, String data)
After session metadata is added to the sessiondefault void
ActiveMQServerAddressPlugin. afterUpdateAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
After an address has been updateddefault void
ActiveMQServerAddressPlugin. beforeAddAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo, boolean reload)
Before an address is added tot he brokerdefault void
ActiveMQServerBindingPlugin. beforeAddBinding(org.apache.activemq.artemis.core.postoffice.Binding binding)
Before a binding is addeddefault void
ActiveMQServerConsumerPlugin. beforeCloseConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer, boolean failed)
Before a consumer is closeddefault void
ActiveMQServerFederationPlugin. beforeCloseFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer)
Before a federated queue consumer is closeddefault void
ActiveMQServerSessionPlugin. beforeCloseSession(org.apache.activemq.artemis.core.server.ServerSession session, boolean failed)
Before a session is closeddefault void
ActiveMQServerConsumerPlugin. beforeCreateConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage)
default void
ActiveMQServerConsumerPlugin. beforeCreateConsumer(long consumerID, org.apache.activemq.artemis.core.postoffice.QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage)
Before a consumer is createddefault void
ActiveMQServerFederationPlugin. beforeCreateFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedConsumerKey key)
Before a federated queue consumer is createddefault void
ActiveMQServerQueuePlugin. beforeCreateQueue(QueueConfiguration queueConfig)
Before a queue is createddefault void
ActiveMQServerQueuePlugin. beforeCreateQueue(org.apache.activemq.artemis.core.server.QueueConfig queueConfig)
Before a queue is createddefault void
ActiveMQServerSessionPlugin. beforeCreateSession(String name, String username, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, org.apache.activemq.artemis.core.persistence.OperationContext context, Map<SimpleString,RoutingType> prefixes)
Before a session is created.default void
ActiveMQServerMessagePlugin. beforeDeliver(org.apache.activemq.artemis.core.server.MessageReference reference)
Deprecated.use throws ActiveMQExceptionActiveMQServerMessagePlugin.beforeDeliver(ServerConsumer, MessageReference)
default void
ActiveMQServerMessagePlugin. beforeDeliver(org.apache.activemq.artemis.core.server.ServerConsumer consumer, org.apache.activemq.artemis.core.server.MessageReference reference)
Before a message is delivered to a client consumerdefault void
ActiveMQServerBridgePlugin. beforeDeliverBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge, org.apache.activemq.artemis.core.server.MessageReference ref)
Called immediately before a bridge delivers a messagedefault void
ActiveMQServerBridgePlugin. beforeDeployBridge(BridgeConfiguration config)
Before a bridge is deployeddefault void
ActiveMQServerQueuePlugin. beforeDestroyQueue(SimpleString queueName, org.apache.activemq.artemis.core.security.SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)
default void
ActiveMQServerQueuePlugin. beforeDestroyQueue(org.apache.activemq.artemis.core.server.Queue queue, org.apache.activemq.artemis.core.security.SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)
Before a queue is destroyeddefault void
ActiveMQServerFederationPlugin. beforeFederatedQueueConsumerMessageHandled(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer, Message message)
Before a federated queue consumer handles a messagedefault void
ActiveMQServerMessagePlugin. beforeMessageRoute(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates)
Before a message is routeddefault void
ActiveMQServerResourcePlugin. beforePutTransaction(Xid xid, org.apache.activemq.artemis.core.transaction.Transaction tx, RemotingConnection remotingConnection)
Before a transaction is putdefault void
ActiveMQServerAddressPlugin. beforeRemoveAddress(SimpleString address)
Before an address is removeddefault void
ActiveMQServerBindingPlugin. beforeRemoveBinding(SimpleString uniqueName, org.apache.activemq.artemis.core.transaction.Transaction tx, boolean deleteData)
Before a binding is removeddefault void
ActiveMQServerResourcePlugin. beforeRemoveTransaction(Xid xid, RemotingConnection remotingConnection)
Before a transaction is removeddefault void
ActiveMQServerMessagePlugin. beforeSend(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)
Before a message is sentdefault void
ActiveMQServerMessagePlugin. beforeSend(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)
default void
ActiveMQServerSessionPlugin. beforeSessionMetadataAdded(org.apache.activemq.artemis.core.server.ServerSession session, String key, String data)
Before session metadata is added to the sessiondefault void
ActiveMQServerAddressPlugin. beforeUpdateAddress(SimpleString address, EnumSet<RoutingType> routingTypes)
Before an address is updateddefault boolean
ActiveMQServerMessagePlugin. canAccept(org.apache.activemq.artemis.core.server.ServerConsumer consumer, org.apache.activemq.artemis.core.server.MessageReference reference)
Before a message is delivered to a client consumerdefault void
ActiveMQServerCriticalPlugin. criticalFailure(org.apache.activemq.artemis.utils.critical.CriticalComponent components)
A Critical failure has been detected.default void
ActiveMQServerSessionPlugin. duplicateSessionMetadataFailure(org.apache.activemq.artemis.core.server.ServerSession session, String key, String data)
Called when adding session metadata fails because the metadata is a duplicatedefault boolean
ActiveMQServerFederationPlugin. federatedAddressConditionalCreateConsumer(org.apache.activemq.artemis.core.server.Queue queue)
Conditionally create a federated queue consumer for a federated address.default boolean
ActiveMQServerFederationPlugin. federatedAddressConditionalCreateDivertConsumer(org.apache.activemq.artemis.core.postoffice.impl.DivertBinding divertBinding, org.apache.activemq.artemis.core.postoffice.QueueBinding queueBinding)
default boolean
ActiveMQServerFederationPlugin. federatedQueueConditionalCreateConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer)
Conditionally create a federated queue consumer for a federated queue.default void
ActiveMQServerFederationPlugin. federationStreamStarted(org.apache.activemq.artemis.core.server.federation.FederationStream stream)
After a federation stream has been starteddefault void
ActiveMQServerFederationPlugin. federationStreamStopped(org.apache.activemq.artemis.core.server.federation.FederationStream stream)
After a federation stream has been stoppeddefault void
ActiveMQServerMessagePlugin. messageAcknowledged(org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason)
default void
ActiveMQServerMessagePlugin. messageAcknowledged(org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason, org.apache.activemq.artemis.core.server.ServerConsumer consumer)
Deprecated.default void
ActiveMQServerMessagePlugin. messageAcknowledged(org.apache.activemq.artemis.core.transaction.Transaction tx, org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason, org.apache.activemq.artemis.core.server.ServerConsumer consumer)
A message has been acknowledgeddefault void
ActiveMQServerMessagePlugin. messageExpired(org.apache.activemq.artemis.core.server.MessageReference message, SimpleString messageExpiryAddress)
default void
ActiveMQServerMessagePlugin. messageExpired(org.apache.activemq.artemis.core.server.MessageReference message, SimpleString messageExpiryAddress, org.apache.activemq.artemis.core.server.ServerConsumer consumer)
A message has been expireddefault void
ActiveMQServerMessagePlugin. onMessageRouteException(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e)
When there was an error routing the messagedefault void
ActiveMQServerMessagePlugin. onSendException(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e)
When there was an exception sending the messagevoid
ActiveMQPluginRunnable. run(P plugin)
-
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.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 callsMethods 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 org.apache.activemq.artemis.core.client.impl.ClientConsumerInternal
SessionContext. createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor)
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(org.apache.activemq.artemis.core.protocol.core.impl.wireformat.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 sessionabstract void
SessionContext. recreateConsumerOnServer(org.apache.activemq.artemis.core.client.impl.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 packetabstract 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)
-