Uses of Class
org.apache.activemq.artemis.api.core.ActiveMQException
Packages that use ActiveMQException
Package
Description
-
Uses of ActiveMQException in org.apache.activemq.artemis.api.core
Subclasses of ActiveMQException in org.apache.activemq.artemis.api.coreModifier and TypeClassDescriptionfinal classAn operation failed because an address exists on the server.final classAn operation failed because an address exists on the server.final classAn address is full.final classThe server is already paired with a replicating backup.final classSecurity exception thrown when the cluster user fails authentication.final classA client timed out will connecting to ActiveMQ Artemis server.final classAn operation failed because an address exists on the server.final classA client was disconnected from ActiveMQ Artemis server when the server has shut down.final classAn operation failed because an address exists on the server.final classA DuplicateID was rejected.final classA Session Metadata was set in duplicationfinal classAn ActiveMQ Artemis resource is not in a legal state (e.g. calling ClientConsumer.receive() if a MessageHandler is set).final classThe server version and the client version are incompatible.final classAn outgoing interceptor returned false.final classInternal error which prevented ActiveMQ Artemis from performing an important operation.final classA filter expression was found to be invalid.final classAn operation failed because a queue exists on the server.final classAn operation failed because a queue exists on the server.final classUnexpected I/O error occurred on the server.final classA problem occurred while manipulating the body of a large message.classfinal classAn error has happened at ActiveMQ's native (non-Java) code used in reading and writing data.final classAn operation failed because a queue does not exist on the server.final classA client is not able to connect to ActiveMQ Artemis server.classAn operation failed because is dereferencing null pointer.final classA client operation failed because the calling resource (ClientSession, ClientProducer, etc.) is closed.final classAn operation failed because a queue exists on the server.final classAn operation failed because a queue exists on the server.final classA security problem occurred (authentication issues, permission issues, etc.)final classThe creation of a session was rejected by the server (e.g. if the server is starting and has not finish to be initialized.final classA client was redirected.final classA security problem occurred (authentication issues, permission issues, etc.)final classThe creation of a session was rejected by the server (e.g. if the server is starting and has not finish to be initialized.final classAn operation failed because an address exists on the server.final classAn operation timed out.final classThe outcome of a transaction is unknown.final classA transaction was rolled back.classfinal classA blocking call from a client was unblocked during failover.final classAn operation failed because a queue exists on the server.final classA packet of unsupported type was received by ActiveMQ Artemis PacketHandler.Methods in org.apache.activemq.artemis.api.core that return ActiveMQExceptionModifier and TypeMethodDescriptionstatic ActiveMQExceptionActiveMQExceptionType.createException(int code, String msg) ActiveMQExceptionType.createException(String msg) Methods in org.apache.activemq.artemis.api.core that throw ActiveMQExceptionModifier and TypeMethodDescriptionICoreMessage.getLargeBodyReader()longMessage.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 sizebooleanBaseInterceptor.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidSessionFailureListener.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 ActiveMQExceptionModifier and TypeMethodDescriptionClientMessage.acknowledge()Acknowledges reception of this message.voidClientSession.addMetaData(String key, String data) Attach any metadata to the session.ClientSession.addressQuery(SimpleString address) Queries information on a binding.voidClientSession.addUniqueMetaData(String key, String data) Attach any metadata to the session.voidClientMessage.checkCompletion()This can be optionally used to verify if the entire message has been received.voidClientConsumer.close()Closes the consumer.voidClientProducer.close()Closes the ClientProducer.voidClientSession.close()Closes the session.voidClientSession.commit()Commits the current transaction, blocking.voidClientSession.commit(boolean block) Commits the current transaction.voidClientSession.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) Create Address with a single initial routing typevoidClientSession.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated) Deprecated.voidClientSession.createAddress(SimpleString address, RoutingType routingType, boolean autoCreated) Create Address with a single initial routing typeClientSession.createConsumer(String queueName) Creates a ClientConsumer to consume messages from the queue with the given name.ClientSession.createConsumer(String queueName, boolean browseOnly) Creates a ClientConsumer to consume or browse messages from the queue with the given name.ClientSession.createConsumer(String queueName, String filter) Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.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.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.ClientSession.createConsumer(SimpleString queueName) Creates a ClientConsumer to consume message from the queue with the given name.ClientSession.createConsumer(SimpleString queueName, boolean browseOnly) Creates a ClientConsumer to consume or browse messages from the queue with the given name.ClientSession.createConsumer(SimpleString queueName, SimpleString filter) Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.ClientSession.createConsumer(SimpleString queueName, SimpleString filter, boolean browseOnly) Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.ClientSession.createConsumer(SimpleString queueName, SimpleString filter, int priority, boolean browseOnly) Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.ClientSession.createConsumer(SimpleString queueName, SimpleString filter, int windowSize, int maxRate, boolean browseOnly) Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.ClientSession.createConsumer(SimpleString queueName, SimpleString filter, int priority, int windowSize, int maxRate, boolean browseOnly) Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.ClientSession.createProducer()Creates a producer with no default address.ClientSession.createProducer(String address) Creates a producer which sends messages to the given addressClientSession.createProducer(SimpleString address) Creates a producer which sends messages to the given addressClientSession.createProducer(SimpleString address, int rate) Creates a producer which sends messages to the given addressvoidClientSession.createQueue(String address, String queueName) Deprecated.voidClientSession.createQueue(String address, String queueName, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(String address, String queueName, String filter, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(String address, String queueName, String filter, boolean durable, boolean autoCreated) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(String address, RoutingType routingType, String queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(String address, RoutingType routingType, String queueName, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable, boolean autoCreated) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(QueueConfiguration queueConfiguration) This method creates a queue based on theQueueConfigurationinput.voidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, SimpleString queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, SimpleString queueName, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, SimpleString queueName, boolean autoCreated, QueueAttributes queueAttributes) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean autoCreated) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadClientSessionFactory.createSession()Creates a non-transacted session.ClientSessionFactory.createSession(boolean autoCommitSends, boolean autoCommitAcks) Creates a session.ClientSessionFactory.createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks) Creates a session.ClientSessionFactory.createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge) Creates a session.ClientSessionFactory.createSession(boolean autoCommitSends, boolean autoCommitAcks, int ackBatchSize) Creates a session.ClientSessionFactory.createSession(String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int ackBatchSize) Creates an authenticated session.ClientSessionFactory.createSession(String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int ackBatchSize, String clientID) Creates an authenticated session.voidClientSession.createSharedQueue(QueueConfiguration queueConfiguration) This method is essentially the same asClientSession.createQueue(QueueConfiguration)with a few key exceptions.voidClientSession.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable) Deprecated.voidClientSession.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.voidClientSession.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidClientSession.createSharedQueue(SimpleString address, SimpleString queueName, boolean durable) Deprecated.voidClientSession.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.voidClientSession.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.voidClientSession.createTemporaryQueue(String address, String queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(String address, String queueName, String filter) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(String address, RoutingType routingType, String queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(String address, RoutingType routingType, String queueName, String filter) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, SimpleString queueName) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadvoidClientSession.createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter) Deprecated.useClientSession.createQueue(QueueConfiguration)insteadClientSessionFactory.createTransactedSession()Creates a transacted session.ClientSessionFactory.createXASession()Creates a session with XA transaction semantics.voidClientSession.deleteQueue(String queueName) Deletes the queue.voidClientSession.deleteQueue(SimpleString queueName) Deletes the queue.ClientConsumer.getMessageHandler()Calling this method on a closed consumer will throw an ActiveMQException.ClientMessage.individualAcknowledge()Acknowledges reception of a single message.voidServerLocator.initialize()This will only instantiate internal objects such as the topologyClientSession.queueQuery(SimpleString queueName) Queries information on a queue.ClientConsumer.receive()Receives a message from a queue.ClientConsumer.receive(long timeout) Receives a message from a queue.ClientConsumer.receiveImmediate()Receives a message from a queue.voidClientSession.rollback()Rolls back the current transaction.voidClientSession.rollback(boolean considerLastMessageAsDelivered) Rolls back the current transaction.voidClientMessage.saveToOutputStream(OutputStream out) Saves the content of the message to the OutputStream.voidSends a message to the specified address instead of the ClientProducer's address.voidSends a message to an address. specified inClientSession.createProducer(String)or similar methods.voidClientProducer.send(Message message, SendAcknowledgementHandler handler) Sends a message to the specified address instead of the ClientProducer's address.voidClientProducer.send(SimpleString address, Message message) Sends a message to the specified address instead of the ClientProducer's address.voidClientProducer.send(SimpleString address, Message message, SendAcknowledgementHandler handler) Sends a message to the specified address instead of the ClientProducer's address.ClientConsumer.setMessageHandler(MessageHandler handler) Sets the MessageHandler for this consumer to consume messages asynchronously.ClientMessage.setOutputStream(OutputStream out) Sets the OutputStream that will receive the content of a message received in a non blocking way.ClientSession.start()Starts the session.voidClientSession.stop()Stops the session.booleanClientMessage.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidClientSessionFactoryImpl.connectionException(Object connectionID, ActiveMQException me) voidClientSessionImpl.connectionFailed(ActiveMQException me, boolean failedOver) voidClientSessionImpl.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID) booleanClientSessionImpl.handleFailover(RemotingConnection backupConnection, ActiveMQException cause) booleanClientSessionInternal.handleFailover(RemotingConnection backupConnection, ActiveMQException cause) Methods in org.apache.activemq.artemis.core.client.impl that throw ActiveMQExceptionModifier and TypeMethodDescriptionvoidClientConsumerImpl.acknowledge(ClientMessage message) voidClientConsumerInternal.acknowledge(ClientMessage message) ClientMessageImpl.acknowledge()voidClientSessionImpl.acknowledge(ClientConsumer consumer, Message message) voidClientSessionInternal.acknowledge(ClientConsumer consumer, Message message) voidAbstractProducerCreditsImpl.acquireCredits(int credits) voidClientProducerCredits.acquireCredits(int credits) voidClientSessionImpl.addMetaData(String key, String data) ClientSessionImpl.addressQuery(SimpleString address) voidClientSessionImpl.addUniqueMetaData(String key, String data) voidClientLargeMessageImpl.checkCompletion()voidClientMessageImpl.checkCompletion()voidClientConsumerInternal.cleanUp()voidClientSessionImpl.cleanUp(boolean failingOver) voidClientSessionInternal.cleanUp(boolean failingOver) voidClientConsumerImpl.clear(boolean waitForOnMessage) voidClientConsumerInternal.clear(boolean waitForOnMessage) voidClientConsumerImpl.close()voidClientProducerImpl.close()voidClientSessionImpl.close()voidClientSessionImpl.commit()voidClientSessionImpl.commit(boolean block) voidClientSessionFactoryImpl.connect(int initialConnectAttempts) voidClientSessionFactoryImpl.connect(int initialConnectAttempts, boolean failoverOnInitialConnection) Deprecated.voidClientSessionFactoryInternal.connect(int reconnectAttempts) voidClientSessionFactoryInternal.connect(int reconnectAttempts, boolean failoverOnInitialConnection) Deprecated.This method is no longer acceptable to connect.ServerLocatorImpl.connect()ServerLocatorInternal.connect()ServerLocatorImpl.connectNoWarnings()ServerLocatorInternal.connectNoWarnings()LikeServerLocatorInternal.connect()but it does not log warnings if it fails to connect.voidClientSessionImpl.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) voidClientSessionImpl.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated) voidClientSessionImpl.createAddress(SimpleString address, RoutingType routingType, boolean autoCreated) ClientSessionImpl.createConsumer(String queueName) ClientSessionImpl.createConsumer(String queueName, boolean browseOnly) ClientSessionImpl.createConsumer(String queueName, String filterString) ClientSessionImpl.createConsumer(String queueName, String filterString, boolean browseOnly) ClientSessionImpl.createConsumer(String queueName, String filterString, int windowSize, int maxRate, boolean browseOnly) ClientSessionImpl.createConsumer(SimpleString queueName) ClientSessionImpl.createConsumer(SimpleString queueName, boolean browseOnly) ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString) ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, boolean browseOnly) ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly) ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int windowSize, int maxRate, boolean browseOnly) ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, boolean browseOnly) Note, we DO NOT currently support direct consumers (i.e. consumers where delivery occurs on the remoting thread).ClientSessionImpl.createProducer()ClientSessionImpl.createProducer(String address) ClientSessionImpl.createProducer(String address, int rate) ClientSessionImpl.createProducer(SimpleString address) ClientSessionImpl.createProducer(SimpleString address, int maxRate) voidClientSessionImpl.createQueue(String address, String queueName) voidClientSessionImpl.createQueue(String address, String queueName, boolean durable) voidClientSessionImpl.createQueue(String address, String queueName, String filterString, boolean durable) voidClientSessionImpl.createQueue(String address, String queueName, String filterString, boolean durable, boolean autoCreated) voidClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName) Deprecated.voidClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName, boolean durable) voidClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName, String filter, boolean durable) voidClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName, String filterString, boolean durable, boolean autoCreated) voidClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName, String filterString, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers) Deprecated.voidClientSessionImpl.createQueue(String address, RoutingType routingType, String queueName, String filterString, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) voidClientSessionImpl.createQueue(QueueConfiguration queueConfiguration) voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, SimpleString queueName) voidClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, boolean durable) voidClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, boolean autoCreated, QueueAttributes queueAttributes) Deprecated.voidClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable) voidClientSessionImpl.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean autoCreated) ClientSessionFactoryImpl.createSession()ClientSessionFactoryImpl.createSession(boolean autoCommitSends, boolean autoCommitAcks) ClientSessionFactoryImpl.createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks) ClientSessionFactoryImpl.createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge) ClientSessionFactoryImpl.createSession(boolean autoCommitSends, boolean autoCommitAcks, int ackBatchSize) ClientSessionFactoryImpl.createSession(String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int ackBatchSize) ClientSessionFactoryImpl.createSession(String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int ackBatchSize, String clientID) protected SessionContextClientSessionFactoryImpl.createSessionChannel(String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, String clientID) ServerLocatorImpl.createSessionFactory()voidClientSessionImpl.createSharedQueue(QueueConfiguration queueConfiguration) voidClientSessionImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, boolean durable) voidClientSessionImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable) voidClientSessionImpl.createSharedQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidClientSessionImpl.createSharedQueue(SimpleString address, SimpleString queueName, boolean durable) voidClientSessionImpl.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.voidClientSessionImpl.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable) voidClientSessionImpl.createTemporaryQueue(String address, String queueName) voidClientSessionImpl.createTemporaryQueue(String address, String queueName, String filter) voidClientSessionImpl.createTemporaryQueue(String address, RoutingType routingType, String queueName) voidClientSessionImpl.createTemporaryQueue(String address, RoutingType routingType, String queueName, String filter) voidClientSessionImpl.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName) voidClientSessionImpl.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter) Deprecated.voidClientSessionImpl.createTemporaryQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidClientSessionImpl.createTemporaryQueue(SimpleString address, SimpleString queueName) voidClientSessionImpl.createTemporaryQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.voidClientSessionImpl.createTemporaryQueue(SimpleString address, SimpleString queueName, SimpleString filter) ClientSessionFactoryImpl.createTransactedSession()ClientSessionFactoryImpl.createXASession()voidClientSessionImpl.deleteQueue(String queueName) voidClientSessionImpl.deleteQueue(SimpleString queueName) voidClientSessionImpl.expire(ClientConsumer consumer, Message message) voidClientSessionInternal.expire(ClientConsumer consumer, Message message) voidClientConsumerImpl.flowControl(int messageBytes, boolean discountSlowConsumer) LargeMessageBuffer will call flowcontrol here, while other handleMessage will also be calling flowControl.voidClientConsumerInternal.flowControl(int messageBytes, boolean discountSlowConsumer) voidClientConsumerImpl.flushAcks()voidClientConsumerInternal.flushAcks()ClientMessageImpl.getLargeBodyReader()ClientConsumerImpl.getMessageHandler()voidClientSessionImpl.handleConsumerDisconnect(ConsumerContext context) voidClientSessionInternal.handleConsumerDisconnect(ConsumerContext consumerContext) voidClientConsumerImpl.individualAcknowledge(ClientMessage message) voidClientConsumerInternal.individualAcknowledge(ClientMessage message) ClientMessageImpl.individualAcknowledge()voidClientSessionImpl.individualAcknowledge(ClientConsumer consumer, Message message) voidClientSessionInternal.individualAcknowledge(ClientConsumer consumer, Message message) voidServerLocatorImpl.initialize()ClientConsumerImpl.prepareForClose(FutureLatch future) To be used by MDBs to stop any more handling of messages.ClientConsumerInternal.prepareForClose(FutureLatch future) To be called by things like MDBs during shutdown of the serverClientSessionImpl.queueQuery(SimpleString queueName) ClientConsumerImpl.receive()ClientConsumerImpl.receive(long timeout) ClientConsumerImpl.receiveImmediate()voidClientSessionImpl.removeConsumer(ClientConsumerInternal consumer) voidClientSessionInternal.removeConsumer(ClientConsumerInternal consumer) voidClientSessionImpl.resetIfNeeded()voidClientSessionInternal.resetIfNeeded()voidClientSessionImpl.rollback()voidClientSessionImpl.rollback(boolean isLastMessageAsDelivered) voidClientSessionImpl.rollback(boolean isLastMessageAsDelivered, boolean waitConsumers) voidLargeMessageController.saveBuffer(OutputStream output) Saves this buffer to the specified output.voidLargeMessageControllerImpl.saveBuffer(OutputStream output) voidClientLargeMessageImpl.saveToOutputStream(OutputStream out) voidClientMessageImpl.saveToOutputStream(OutputStream out) voidvoidvoidClientProducerImpl.send(Message message, SendAcknowledgementHandler handler) voidClientProducerImpl.send(SimpleString address1, Message msg) voidClientProducerImpl.send(SimpleString address1, Message message, SendAcknowledgementHandler handler) ClientConsumerImpl.setManualFlowMessageHandler(MessageHandler theHandler) ClientConsumerInternal.setManualFlowMessageHandler(MessageHandler theHandler) ClientConsumerImpl.setMessageHandler(MessageHandler theHandler) ClientLargeMessageImpl.setOutputStream(OutputStream out) ClientMessageImpl.setOutputStream(OutputStream out) voidLargeMessageController.setOutputStream(OutputStream output) Sets the OutputStream of this buffer to the specified output.voidLargeMessageControllerImpl.setOutputStream(OutputStream output) ClientSessionImpl.start()voidClientConsumerImpl.stop(boolean waitForOnMessage) voidClientConsumerInternal.stop(boolean waitForOnMessage) voidClientSessionImpl.stop()voidClientSessionImpl.stop(boolean waitForOnMessage) booleanLargeMessageController.waitCompletion(long timeWait) Waits for the completion for the specified waiting time (in milliseconds).booleanLargeMessageControllerImpl.waitCompletion(long timeWait) booleanClientLargeMessageImpl.waitOutputStreamCompletion(long timeMilliseconds) booleanClientMessageImpl.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 ActiveMQExceptionModifier and TypeMethodDescriptionstatic FilterFilterImpl.createFilter(String filterStr) Returns null iffilterStris null or an empty String and a valid filter else.static FilterFilterImpl.createFilter(SimpleString filterStr) Returns null iffilterStris 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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidAbstractSequentialFile.close()final voidAbstractSequentialFile.delete()voidSequentialFile.delete()final voidvoidAbstractSequentialFile.write(ActiveMQBuffer bytes, boolean sync) voidAbstractSequentialFile.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidAIOSequentialFile.close()voidAIOSequentialFile.close(boolean waitSync, boolean blockOnWait) voidAIOSequentialFile.open(int maxIO, boolean useExecutor) intAIOSequentialFile.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 -
Uses of ActiveMQException in org.apache.activemq.artemis.core.journal.impl
Methods in org.apache.activemq.artemis.core.journal.impl that throw ActiveMQExceptionModifier and TypeMethodDescriptionvoidSimpleWaitIOCallback.waitCompletion()booleanSimpleWaitIOCallback.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 ActiveMQExceptionModifier and TypeMethodDescriptionManagementRemotingConnection.asyncFail(ActiveMQException me) voidManagementRemotingConnection.fail(ActiveMQException me) voidManagementRemotingConnection.fail(ActiveMQException me, String scaleDownTargetNodeID) Methods in org.apache.activemq.artemis.core.management.impl that throw ActiveMQException -
Uses of ActiveMQException in org.apache.activemq.artemis.core.message
Methods in org.apache.activemq.artemis.core.message that throw ActiveMQExceptionModifier and TypeMethodDescriptionvoidBodyEncoder.close()Deprecated.This method must not be called directly by ActiveMQ Artemis clients.voidLargeBodyReader.close()This method must not be called directly by ActiveMQ Artemis clients.intBodyEncoder.encode(ByteBuffer bufferRead) Deprecated.This method must not be called directly by ActiveMQ Artemis clients.intBodyEncoder.encode(ActiveMQBuffer bufferOut, int size) Deprecated.This method must not be called directly by ActiveMQ Artemis clients.longLargeBodyReader.getSize()This method must not be called directly by ActiveMQ Artemis clients.voidBodyEncoder.open()Deprecated.This method must not be called directly by ActiveMQ Artemis clients.voidLargeBodyReader.open()This method must not be called directly by ActiveMQ Artemis clients.voidLargeBodyReader.position(long position) This method must not be called directly by ActiveMQ Artemis clients.intLargeBodyReader.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 ActiveMQExceptionModifier and TypeMethodDescriptionMessageInternal.getBodyEncoder()Deprecated.MessageInternalImpl.getBodyEncoder()Deprecated.CoreMessage.getLargeBodyReader()longCoreMessage.getPersistentSize()longMessageInternalImpl.getPersistentSize()Deprecated. -
Uses of ActiveMQException in org.apache.activemq.artemis.core.paging
Methods in org.apache.activemq.artemis.core.paging that throw ActiveMQExceptionModifier and TypeMethodDescriptionlongPagedMessage.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 -
Uses of ActiveMQException in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence that throw ActiveMQExceptionModifier and TypeMethodDescriptionvoidStorageManager.deleteLargeMessageBody(LargeServerMessage largeServerMessage) voidStorageManager.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidJournalStorageManager.deleteLargeMessageBody(LargeServerMessage largeServerMessage) voidLargeBody.ensureFileExists(boolean toOpen) LargeBody.getAppendFile()LargeServerMessageImpl.getAppendFile()longLargeBody.getBodySize()longLargeServerMessageImpl.getBodySize()longLargeServerMessageImpl.getPersistentSize()LargeBody.getReadingFile()This will return its own File useful for reading the file on the large message while delivering, browsing.. etcLargeServerMessageInSync.getSyncFile()voidJournalStorageManager.largeMessageClosed(LargeServerMessage largeServerMessage) booleanOperationContextImpl.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidNullStorageManager.deleteLargeMessageBody(LargeServerMessage largeServerMessage) voidNullStorageManager.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidServerSessionPacketHandler.connectionFailed(ActiveMQException exception, boolean failedOver) Methods in org.apache.activemq.artemis.core.protocol.core that throw ActiveMQExceptionModifier and TypeMethodDescriptionChannel.sendBlocking(Packet packet, byte expectedPacket) Sends a packet on this channel and then blocks until a response is received or a timeout occurs.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.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 ActiveMQExceptionModifier and TypeMethodDescriptionbooleanActiveMQClientProtocolManager.cleanupBeforeFailover(ActiveMQException cause) voidResponseCache.errorAll(ActiveMQException exception) voidRemotingConnectionImpl.fail(ActiveMQException me, String scaleDownTargetNodeID) voidActiveMQSessionContext.returnBlocking(ActiveMQException cause) Methods in org.apache.activemq.artemis.core.protocol.core.impl that throw ActiveMQExceptionModifier and TypeMethodDescriptionActiveMQSessionContext.addressQuery(SimpleString address) voidActiveMQSessionContext.addSessionMetadata(String key, String data) voidActiveMQSessionContext.addUniqueMetaData(String key, String data) booleanActiveMQClientProtocolManager.checkForFailover(String nodeID) voidActiveMQSessionContext.closeConsumer(ClientConsumer consumer) booleanActiveMQSessionContext.configureTransactionTimeout(int seconds) voidActiveMQSessionContext.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) voidActiveMQSessionContext.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated) ActiveMQSessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout) voidActiveMQSessionContext.createQueue(QueueConfiguration queueConfiguration) voidActiveMQSessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated) Deprecated.voidActiveMQSessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated, Boolean exclusive, Boolean lastValue) Deprecated.voidActiveMQSessionContext.createQueue(SimpleString address, SimpleString queueName, boolean temp, boolean autoCreated, QueueAttributes queueAttributes) Deprecated.voidActiveMQSessionContext.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, boolean autoCreated) Deprecated.ActiveMQClientProtocolManager.createSessionContext(String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, String clientID) ActiveMQClientProtocolManager.createSessionContext(Version clientVersion, String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, String clientID) voidActiveMQSessionContext.createSharedQueue(QueueConfiguration queueConfiguration) voidActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.voidActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable) Deprecated.voidActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.voidActiveMQSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable) Deprecated.voidActiveMQSessionContext.deleteQueue(SimpleString queueName) voidActiveMQSessionContext.expireMessage(ClientConsumer consumer, Message message) voidActiveMQSessionContext.forceDelivery(ClientConsumer consumer, long sequence) intActiveMQSessionContext.getDefaultConsumerWindowSize(SessionQueueQueryResponseMessage response) ActiveMQSessionContext.queueQuery(SimpleString queueName) booleanActiveMQSessionContext.reattachOnNewConnection(RemotingConnection newConnection) intActiveMQSessionContext.recoverSessionTimeout()voidActiveMQSessionContext.recreateConsumerOnServer(ClientConsumerInternal consumerInternal, long consumerId, boolean isSessionStarted) voidActiveMQSessionContext.recreateSession(String username, String password, int minLargeMessageSize, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge) voidActiveMQSessionContext.restartSession()voidActiveMQSessionContext.sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message) ChannelImpl.sendBlocking(Packet packet, byte expectedPacket) ChannelImpl.sendBlocking(Packet packet, int reconnectID, byte expectedPacket) 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.voidActiveMQSessionContext.sendFullMessage(ICoreMessage msgI, boolean sendBlocking, SendAcknowledgementHandler handler, SimpleString defaultAddress, int senderID) intActiveMQSessionContext.sendInitialChunkOnLargeMessage(Message msgI) intActiveMQSessionContext.sendLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int reconnectID, int senderID, SendAcknowledgementHandler messageHandler) intActiveMQSessionContext.sendServerLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int senderID, SendAcknowledgementHandler messageHandler) voidActiveMQSessionContext.sessionClose()voidActiveMQSessionContext.sessionStart()voidActiveMQSessionContext.sessionStop()voidActiveMQSessionContext.simpleCommit()voidActiveMQSessionContext.simpleCommit(boolean block) voidActiveMQSessionContext.simpleRollback(boolean lastMessageAsDelivered) voidvoidvoidvoidintvoidActiveMQSessionContext.xaRollback(Xid xid, boolean wasStarted) Xid[]ActiveMQSessionContext.xaScan()void -
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 ActiveMQExceptionMethods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return ActiveMQExceptionConstructors in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type ActiveMQExceptionModifierConstructorDescriptionActiveMQExceptionMessage(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 ActiveMQExceptionModifier and TypeMethodDescriptionbooleanHQPropertiesConversionInterceptor.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 ActiveMQExceptionModifier and TypeMethodDescriptionHornetQClientSessionContext.addressQuery(SimpleString address) booleanHornetQClientProtocolManager.checkForFailover(String nodeID) HornetQClientSessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout) HornetQClientSessionContext.queueQuery(SimpleString queueName) -
Uses of ActiveMQException in org.apache.activemq.artemis.core.remoting
Methods in org.apache.activemq.artemis.core.remoting with parameters of type ActiveMQExceptionModifier and TypeMethodDescriptionvoidFailureListener.connectionFailed(ActiveMQException exception, boolean failedOver) Notifies that a connection has failed due to the specified exception.voidFailureListener.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidRemotingServiceImpl.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidReplicationEndpoint.ReplicationEndpointEventListener.onPrimaryStopping(ReplicationPrimaryIsStoppingMessage.PrimaryStopping message) voidReplicationManager.sendStartSyncMessage(JournalFile[] datafiles, AbstractJournalStorageManager.JournalContent contentType, String nodeID, boolean allowsAutoFailBack) Reserve the following fileIDs in the backup server.voidReplicationManager.start() -
Uses of ActiveMQException in org.apache.activemq.artemis.core.server
Subclasses of ActiveMQException in org.apache.activemq.artemis.core.serverMethods in org.apache.activemq.artemis.core.server that return ActiveMQExceptionModifier and TypeMethodDescriptionActiveMQMessageBundle_impl.connectionDestroyed(String remoteAddress) ActiveMQMessageBundle.connectionDestroyed(String remoteAddress) ActiveMQMessageBundle_impl.embeddedWebServerRestartFailed(Exception e) ActiveMQMessageBundle.embeddedWebServerRestartFailed(Exception e) ActiveMQMessageBundle_impl.groupWhileStopping()ActiveMQMessageBundle.groupWhileStopping()ActiveMQMessageBundle_impl.noConfigurationFoundForScaleDown()ActiveMQMessageBundle.noConfigurationFoundForScaleDown()ActiveMQMessageBundle_impl.noDiscoveryGroupFound(DiscoveryGroupConfiguration dg) ActiveMQMessageBundle.noDiscoveryGroupFound(DiscoveryGroupConfiguration dg) Methods in org.apache.activemq.artemis.core.server that throw ActiveMQExceptionModifier and TypeMethodDescriptionvoidActiveMQServer.callBrokerAddressPlugins(ActiveMQPluginRunnable<ActiveMQServerAddressPlugin> pluginRun) voidActiveMQServer.callBrokerAMQPFederationPlugins(ActiveMQPluginRunnable<AMQPFederationBrokerPlugin> pluginRun) voidActiveMQServer.callBrokerBindingPlugins(ActiveMQPluginRunnable<ActiveMQServerBindingPlugin> pluginRun) voidActiveMQServer.callBrokerBridgePlugins(ActiveMQPluginRunnable<ActiveMQServerBridgePlugin> pluginRun) voidActiveMQServer.callBrokerConnectionPlugins(ActiveMQPluginRunnable<ActiveMQServerConnectionPlugin> pluginRun) voidActiveMQServer.callBrokerConsumerPlugins(ActiveMQPluginRunnable<ActiveMQServerConsumerPlugin> pluginRun) voidActiveMQServer.callBrokerCriticalPlugins(ActiveMQPluginRunnable<ActiveMQServerCriticalPlugin> pluginRun) voidActiveMQServer.callBrokerFederationPlugins(ActiveMQPluginRunnable<ActiveMQServerFederationPlugin> pluginRun) voidActiveMQServer.callBrokerMessagePlugins(ActiveMQPluginRunnable<ActiveMQServerMessagePlugin> pluginRun) booleanActiveMQServer.callBrokerMessagePluginsCanAccept(ServerConsumer serverConsumer, MessageReference messageReference) voidActiveMQServer.callBrokerPlugins(ActiveMQPluginRunnable pluginRun) voidActiveMQServer.callBrokerQueuePlugins(ActiveMQPluginRunnable<ActiveMQServerQueuePlugin> pluginRun) voidActiveMQServer.callBrokerResourcePlugins(ActiveMQPluginRunnable<ActiveMQServerResourcePlugin> pluginRun) voidActiveMQServer.callBrokerSessionPlugins(ActiveMQPluginRunnable<ActiveMQServerSessionPlugin> pluginRun) ScheduledDeliveryHandler.cancel(Predicate<MessageReference> predicate) voidNodeLocator.connectToCluster(ServerLocatorInternal serverLocator) connects to the clustervoidQueue.deliverScheduledMessage(long messageId) cancels scheduled message with the corresponding message ID and sends it to the head of the queue.voidQueue.deliverScheduledMessages()cancels scheduled messages and send them to the head of the queue.voidQueue.deliverScheduledMessages(String filter) cancels scheduled messages which match the filter and send them to the head of the queue.static QueueConfigQueueConfig.fromQueueConfiguration(QueueConfiguration queueConfiguration) Deprecated.LargeServerMessage.getAppendFile()This will return the File suitable for appending the messageLargeServerMessage.getLargeBodyReader()longMessageReference.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 queueabstract voidNodeLocator.locateNode()Locates a server in a clusterabstract voidNodeLocator.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidClusterControl.announceReplicatingBackupToPrimary(boolean attemptingFailBack, String replicationClusterName) Announce replicating backup to primary server.voidClusterControl.authorize()authorise this cluster control so it can communicate with the cluster, it will set the cluster channel on a successful authentication.booleanClusterManager.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 ActiveMQExceptionModifier and TypeMethodDescriptionstatic ServerLocatorInternalScaleDownPolicy.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidBridgeImpl.beforeReconnect(ActiveMQException exception) voidBridgeImpl.connectionFailed(ActiveMQException me, boolean failedOver) voidBridgeImpl.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID) Constructors in org.apache.activemq.artemis.core.server.cluster.impl that throw ActiveMQExceptionModifierConstructorDescriptionBridgeImpl(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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidSharedNothingBackupQuorum.beforeReconnect(ActiveMQException exception) voidSharedNothingBackupQuorum.connectionFailed(ActiveMQException exception, boolean failedOver) if the connection to our replicated primary goes down then decide on an actionvoidSharedNothingBackupQuorum.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidFederatedQueueConsumerImpl.beforeReconnect(ActiveMQException exception) voidFederationDownstream.beforeReconnect(ActiveMQException exception) voidFederatedQueueConsumerImpl.connectionFailed(ActiveMQException exception, boolean failedOver) voidFederatedQueueConsumerImpl.connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID) voidFederationDownstream.connectionFailed(ActiveMQException exception, boolean failedOver) voidFederationDownstream.connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID) Methods in org.apache.activemq.artemis.core.server.federation that throw ActiveMQExceptionModifier and TypeMethodDescriptionvoidFederatedQueueConsumerImpl.ClientSessionCallback.callback(ClientSession clientSession) voidFederation.deploy()booleanFederation.deploy(FederationDownstreamConfiguration downstreamConfiguration, Map<String, FederationPolicy> federationPolicyMap) booleanFederation.deploy(FederationUpstreamConfiguration upstreamConfiguration, Map<String, FederationPolicy> federationPolicyMap) voidFederationDownstream.deploy(FederationConfiguration federationConfiguration) voidFederationManager.deploy()booleanFederationManager.deploy(FederationConfiguration federationConfiguration) voidbooleanFederationUpstream.deploy(FederationAddressPolicyConfiguration federatedAddressConfig) booleanFederationUpstream.deploy(FederationQueuePolicyConfiguration federatedQueueConfig) voidFederation.start()voidFederationManager.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 ActiveMQExceptionModifierConstructorDescriptionFederatedQueue(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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidServerSessionImpl.connectionFailed(ActiveMQException me, boolean failedOver) voidServerSessionImpl.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID) voidServerSessionImpl.TempQueueCleanerUpper.connectionFailed(ActiveMQException exception, boolean failedOver) voidServerSessionImpl.TempQueueCleanerUpper.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID) Methods in org.apache.activemq.artemis.core.server.impl that throw ActiveMQExceptionModifier and TypeMethodDescriptionvoidActiveMQServerImpl.callBrokerAddressPlugins(ActiveMQPluginRunnable<ActiveMQServerAddressPlugin> pluginRun) voidActiveMQServerImpl.callBrokerAMQPFederationPlugins(ActiveMQPluginRunnable<AMQPFederationBrokerPlugin> pluginRun) voidActiveMQServerImpl.callBrokerBindingPlugins(ActiveMQPluginRunnable<ActiveMQServerBindingPlugin> pluginRun) voidActiveMQServerImpl.callBrokerBridgePlugins(ActiveMQPluginRunnable<ActiveMQServerBridgePlugin> pluginRun) voidActiveMQServerImpl.callBrokerConnectionPlugins(ActiveMQPluginRunnable<ActiveMQServerConnectionPlugin> pluginRun) voidActiveMQServerImpl.callBrokerConsumerPlugins(ActiveMQPluginRunnable<ActiveMQServerConsumerPlugin> pluginRun) voidActiveMQServerImpl.callBrokerCriticalPlugins(ActiveMQPluginRunnable<ActiveMQServerCriticalPlugin> pluginRun) voidActiveMQServerImpl.callBrokerFederationPlugins(ActiveMQPluginRunnable<ActiveMQServerFederationPlugin> pluginRun) voidActiveMQServerImpl.callBrokerMessagePlugins(ActiveMQPluginRunnable<ActiveMQServerMessagePlugin> pluginRun) booleanActiveMQServerImpl.callBrokerMessagePluginsCanAccept(ServerConsumer serverConsumer, MessageReference messageReference) voidActiveMQServerImpl.callBrokerPlugins(ActiveMQPluginRunnable pluginRun) voidActiveMQServerImpl.callBrokerQueuePlugins(ActiveMQPluginRunnable<ActiveMQServerQueuePlugin> pluginRun) voidActiveMQServerImpl.callBrokerResourcePlugins(ActiveMQPluginRunnable<ActiveMQServerResourcePlugin> pluginRun) voidActiveMQServerImpl.callBrokerSessionPlugins(ActiveMQPluginRunnable<ActiveMQServerSessionPlugin> pluginRun) ScheduledDeliveryHandlerImpl.cancel(Predicate<MessageReference> predicate) 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.SharedNothingBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) SharedStoreBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) voidQueueImpl.deliverScheduledMessage(long messageId) voidQueueImpl.deliverScheduledMessages()voidQueueImpl.deliverScheduledMessages(String filterString) longGroupFirstMessageReference.getPersistentSize()longMessageReferenceImpl.getPersistentSize()voidAnyNodeLocatorForReplication.locateNode()voidAnyNodeLocatorForReplication.locateNode(long timeout) voidAnyNodeLocatorForScaleDown.locateNode()voidAnyNodeLocatorForScaleDown.locateNode(long timeout) voidNamedNodeIdLocatorForReplication.locateNode()voidNamedNodeIdLocatorForReplication.locateNode(long timeout) voidNamedNodeIdNodeLocator.locateNode()voidNamedNodeIdNodeLocator.locateNode(long timeout) voidNamedNodeLocatorForReplication.locateNode()voidNamedNodeLocatorForReplication.locateNode(long timeout) voidNamedNodeLocatorForScaleDown.locateNode()voidNamedNodeLocatorForScaleDown.locateNode(long timeout) voidSharedNothingBackupActivation.onPrimaryStopping(ReplicationPrimaryIsStoppingMessage.PrimaryStopping finalMessage) voidSharedNothingPrimaryActivation.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 ActiveMQExceptionModifier and TypeMethodDescriptionstatic voidActivationSequenceStateMachine.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 (usingNodeManager.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 ActiveMQExceptionModifier and TypeMethodDescriptiondefault voidActiveMQServerBridgePlugin.afterAcknowledgeBridge(Bridge bridge, MessageReference ref) Called after delivered message over this bridge has been acknowledged by the remote brokerdefault voidActiveMQServerAddressPlugin.afterAddAddress(AddressInfo addressInfo, boolean reload) After an address has been added tot he brokerdefault voidActiveMQServerBindingPlugin.afterAddBinding(Binding binding) After a binding has been addeddefault voidActiveMQServerConsumerPlugin.afterCloseConsumer(ServerConsumer consumer, boolean failed) After a consumer is closeddefault voidActiveMQServerFederationPlugin.afterCloseFederatedQueueConsumer(FederatedQueueConsumer consumer) After a federated queue consumer is closeddefault voidActiveMQServerSessionPlugin.afterCloseSession(ServerSession session, boolean failed) After a session is closeddefault voidActiveMQServerConnectionPlugin.afterCreateConnection(RemotingConnection connection) A connection has been created.default voidActiveMQServerConsumerPlugin.afterCreateConsumer(ServerConsumer consumer) After a consumer has been createddefault voidActiveMQServerFederationPlugin.afterCreateFederatedQueueConsumer(FederatedQueueConsumer consumer) After a federated queue consumer is createddefault voidActiveMQServerQueuePlugin.afterCreateQueue(Queue queue) After a queue has been createddefault voidActiveMQServerSessionPlugin.afterCreateSession(ServerSession session) After a session has been created.default voidActiveMQServerMessagePlugin.afterDeliver(MessageReference reference) default voidActiveMQServerMessagePlugin.afterDeliver(ServerConsumer consumer, MessageReference reference) After a message is delivered to a client consumerdefault voidActiveMQServerBridgePlugin.afterDeliverBridge(Bridge bridge, MessageReference ref, HandleStatus status) Called immediately after a bridge delivers a message but before the message is acknowledgeddefault voidActiveMQServerBridgePlugin.afterDeployBridge(Bridge bridge) After a bridge has been deployeddefault voidActiveMQServerConnectionPlugin.afterDestroyConnection(RemotingConnection connection) A connection has been destroyed.default voidActiveMQServerQueuePlugin.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) After a queue has been destroyeddefault voidActiveMQServerFederationPlugin.afterFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer, Message message) After a federated queue consumer handles a messagedefault voidActiveMQServerMessagePlugin.afterMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, RoutingStatus result) After a message is routeddefault voidActiveMQServerResourcePlugin.afterPutTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection) After a transaction is putdefault voidActiveMQServerAddressPlugin.afterRemoveAddress(SimpleString address, AddressInfo addressInfo) After an address has been removeddefault voidActiveMQServerBindingPlugin.afterRemoveBinding(Binding binding, Transaction tx, boolean deleteData) After a binding is removeddefault voidActiveMQServerResourcePlugin.afterRemoveTransaction(Xid xid, RemotingConnection remotingConnection) After a transaction is removeddefault voidActiveMQServerMessagePlugin.afterSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result) After a message is sentdefault voidActiveMQServerMessagePlugin.afterSend(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result) default voidActiveMQServerSessionPlugin.afterSessionMetadataAdded(ServerSession session, String key, String data) After session metadata is added to the sessiondefault voidActiveMQServerAddressPlugin.afterUpdateAddress(AddressInfo addressInfo) After an address has been updateddefault voidActiveMQServerAddressPlugin.beforeAddAddress(AddressInfo addressInfo, boolean reload) Before an address is added tot he brokerdefault voidActiveMQServerBindingPlugin.beforeAddBinding(Binding binding) Before a binding is addeddefault voidActiveMQServerConsumerPlugin.beforeCloseConsumer(ServerConsumer consumer, boolean failed) Before a consumer is closeddefault voidActiveMQServerFederationPlugin.beforeCloseFederatedQueueConsumer(FederatedQueueConsumer consumer) Before a federated queue consumer is closeddefault voidActiveMQServerSessionPlugin.beforeCloseSession(ServerSession session, boolean failed) Before a session is closeddefault voidActiveMQServerConsumerPlugin.beforeCreateConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) default voidActiveMQServerConsumerPlugin.beforeCreateConsumer(long consumerID, QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) Before a consumer is createddefault voidActiveMQServerFederationPlugin.beforeCreateFederatedQueueConsumer(FederatedConsumerKey key) Before a federated queue consumer is createddefault voidActiveMQServerQueuePlugin.beforeCreateQueue(QueueConfiguration queueConfig) Before a queue is createddefault voidActiveMQServerQueuePlugin.beforeCreateQueue(QueueConfig queueConfig) Before a queue is createddefault voidActiveMQServerSessionPlugin.beforeCreateSession(String name, String username, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString, RoutingType> prefixes) Before a session is created.default voidActiveMQServerMessagePlugin.beforeDeliver(MessageReference reference) Deprecated.use throws ActiveMQExceptionActiveMQServerMessagePlugin.beforeDeliver(ServerConsumer, MessageReference)default voidActiveMQServerMessagePlugin.beforeDeliver(ServerConsumer consumer, MessageReference reference) Before a message is delivered to a client consumerdefault voidActiveMQServerBridgePlugin.beforeDeliverBridge(Bridge bridge, MessageReference ref) Called immediately before a bridge delivers a messagedefault voidActiveMQServerBridgePlugin.beforeDeployBridge(BridgeConfiguration config) Before a bridge is deployeddefault voidActiveMQServerQueuePlugin.beforeDestroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) default voidActiveMQServerQueuePlugin.beforeDestroyQueue(Queue queue, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) Before a queue is destroyeddefault voidActiveMQServerFederationPlugin.beforeFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer, Message message) Before a federated queue consumer handles a messagedefault voidActiveMQServerMessagePlugin.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates) Before a message is routeddefault voidActiveMQServerResourcePlugin.beforePutTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection) Before a transaction is putdefault voidActiveMQServerAddressPlugin.beforeRemoveAddress(SimpleString address) Before an address is removeddefault voidActiveMQServerBindingPlugin.beforeRemoveBinding(SimpleString uniqueName, Transaction tx, boolean deleteData) Before a binding is removeddefault voidActiveMQServerResourcePlugin.beforeRemoveTransaction(Xid xid, RemotingConnection remotingConnection) Before a transaction is removeddefault voidActiveMQServerMessagePlugin.beforeSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) Before a message is sentdefault voidActiveMQServerMessagePlugin.beforeSend(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) default voidActiveMQServerSessionPlugin.beforeSessionMetadataAdded(ServerSession session, String key, String data) Before session metadata is added to the sessiondefault voidActiveMQServerAddressPlugin.beforeUpdateAddress(SimpleString address, EnumSet<RoutingType> routingTypes) Before an address is updateddefault booleanActiveMQServerMessagePlugin.canAccept(ServerConsumer consumer, MessageReference reference) Before a message is delivered to a client consumerdefault voidActiveMQServerCriticalPlugin.criticalFailure(CriticalComponent components) A Critical failure has been detected.default voidActiveMQServerSessionPlugin.duplicateSessionMetadataFailure(ServerSession session, String key, String data) Called when adding session metadata fails because the metadata is a duplicatedefault booleanActiveMQServerFederationPlugin.federatedAddressConditionalCreateConsumer(Queue queue) Conditionally create a federated queue consumer for a federated address.default booleanActiveMQServerFederationPlugin.federatedAddressConditionalCreateDivertConsumer(DivertBinding divertBinding, QueueBinding queueBinding) default booleanActiveMQServerFederationPlugin.federatedQueueConditionalCreateConsumer(ServerConsumer consumer) Conditionally create a federated queue consumer for a federated queue.default voidActiveMQServerFederationPlugin.federationStreamStarted(FederationStream stream) After a federation stream has been starteddefault voidActiveMQServerFederationPlugin.federationStreamStopped(FederationStream stream) After a federation stream has been stoppeddefault voidActiveMQServerMessagePlugin.messageAcknowledged(MessageReference ref, AckReason reason) default voidActiveMQServerMessagePlugin.messageAcknowledged(MessageReference ref, AckReason reason, ServerConsumer consumer) Deprecated.default voidActiveMQServerMessagePlugin.messageAcknowledged(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer) A message has been acknowledgeddefault voidActiveMQServerMessagePlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress) default voidActiveMQServerMessagePlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer) A message has been expireddefault voidActiveMQServerMessagePlugin.messageMoved(Transaction tx, MessageReference ref, AckReason reason, SimpleString destAddress, Long destQueueID, ServerConsumer consumer, Message newMessage, RoutingStatus result) A message has been moveddefault voidActiveMQServerMessagePlugin.onMessageRouteException(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e) When there was an error routing the messagedefault voidActiveMQServerMessagePlugin.onSendException(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e) When there was an exception sending the messagevoid -
Uses of ActiveMQException in org.apache.activemq.artemis.core.server.plugin.impl
Methods in org.apache.activemq.artemis.core.server.plugin.impl that throw ActiveMQExceptionModifier and TypeMethodDescriptionvoidNotificationActiveMQServerPlugin.afterAddAddress(AddressInfo addressInfo, boolean reload) voidLoggingActiveMQServerPlugin.afterCloseConsumer(ServerConsumer consumer, boolean failed) After a consumer is closedvoidLoggingActiveMQServerPlugin.afterCloseSession(ServerSession session, boolean failed) After a session is closedvoidLoggingActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection) A connection has been created.voidNotificationActiveMQServerPlugin.afterCreateConnection(RemotingConnection connection) voidLoggingActiveMQServerPlugin.afterCreateConsumer(ServerConsumer consumer) After a consumer has been createdvoidLoggingActiveMQServerPlugin.afterCreateQueue(Queue queue) After a queue has been createdvoidLoggingActiveMQServerPlugin.afterCreateSession(ServerSession session) After a session has been created.voidLoggingActiveMQServerPlugin.afterDeliver(ServerConsumer consumer, MessageReference reference) After a message is delivered to a client consumervoidNotificationActiveMQServerPlugin.afterDeliver(ServerConsumer consumer, MessageReference reference) voidLoggingActiveMQServerPlugin.afterDeployBridge(Bridge bridge) After a bridge has been deployedvoidLoggingActiveMQServerPlugin.afterDestroyConnection(RemotingConnection connection) A connection has been destroyed.voidNotificationActiveMQServerPlugin.afterDestroyConnection(RemotingConnection connection) voidLoggingActiveMQServerPlugin.afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) After a queue has been destroyedvoidLoggingActiveMQServerPlugin.afterMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, RoutingStatus result) After a message is routedvoidNotificationActiveMQServerPlugin.afterRemoveAddress(SimpleString address, AddressInfo addressInfo) voidLoggingActiveMQServerPlugin.afterSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result) After a message is sentvoidLoggingActiveMQServerPlugin.afterSessionMetadataAdded(ServerSession session, String key, String data) After session metadata is added to the sessionvoidLoggingActiveMQServerPlugin.beforeCloseConsumer(ServerConsumer consumer, boolean failed) Before a consumer is closedvoidLoggingActiveMQServerPlugin.beforeCloseSession(ServerSession session, boolean failed) Before a session is closedvoidLoggingActiveMQServerPlugin.beforeCreateConsumer(long consumerID, QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) Before a consumer is createdvoidLoggingActiveMQServerPlugin.beforeCreateQueue(QueueConfiguration queueConfig) Before a queue is createdvoidLoggingActiveMQServerPlugin.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.voidLoggingActiveMQServerPlugin.beforeDeliver(ServerConsumer consumer, MessageReference reference) Before a message is delivered to a client consumervoidLoggingActiveMQServerPlugin.beforeDeployBridge(BridgeConfiguration config) Before a bridge is deployedvoidLoggingActiveMQServerPlugin.beforeDestroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) Before a queue is destroyedvoidLoggingActiveMQServerPlugin.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates) Before a message is routedvoidLoggingActiveMQServerPlugin.beforeSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) Before a message is sentvoidLoggingActiveMQServerPlugin.beforeSessionMetadataAdded(ServerSession session, String key, String data) Before session metadata is added to the sessionbooleanBrokerMessageAuthorizationPlugin.canAccept(ServerConsumer consumer, MessageReference reference) voidLoggingActiveMQServerPlugin.criticalFailure(CriticalComponent components) A Critical failure has been detected.voidLoggingActiveMQServerPlugin.messageAcknowledged(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer) A message has been acknowledgedvoidLoggingActiveMQServerPlugin.onMessageRouteException(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e) voidLoggingActiveMQServerPlugin.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidActiveMQTarget.connectionFailed(ActiveMQException exception, boolean failedOver) voidActiveMQTarget.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidTransaction.markAsRollbackOnly(ActiveMQException exception) Methods in org.apache.activemq.artemis.core.transaction that throw ActiveMQExceptionModifier and TypeMethodDescriptionbooleanResourceManager.putTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection) 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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidTransactionImpl.markAsRollbackOnly(ActiveMQException exception) Methods in org.apache.activemq.artemis.core.transaction.impl that throw ActiveMQExceptionModifier and TypeMethodDescriptionbooleanResourceManagerImpl.putTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection) 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 -
Uses of ActiveMQException in org.apache.activemq.artemis.jms.client
Methods in org.apache.activemq.artemis.jms.client with parameters of type ActiveMQExceptionModifier and TypeMethodDescriptionstatic JMSExceptionJMSExceptionHelper.convertFromActiveMQException(ActiveMQException me) Methods in org.apache.activemq.artemis.jms.client that throw ActiveMQExceptionModifier and TypeMethodDescriptionvoidActiveMQBytesMessage.doBeforeReceive()voidActiveMQMapMessage.doBeforeReceive()voidActiveMQMessage.doBeforeReceive()voidActiveMQObjectMessage.doBeforeReceive()voidActiveMQTextMessage.doBeforeReceive()protected QueueActiveMQSession.internalCreateQueue(String queueName) protected ActiveMQQueueActiveMQSession.internalCreateQueueCompatibility(String queueName) protected TopicActiveMQSession.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 ActiveMQExceptionModifier and TypeMethodDescriptionprotected ActiveMQConnectionFactoryJMSServerManagerImpl.internalCreateCFPOJO(ConnectionFactoryConfiguration cfConfig) Deprecated. -
Uses of ActiveMQException in org.apache.activemq.artemis.ra
Methods in org.apache.activemq.artemis.ra that throw ActiveMQException -
Uses of ActiveMQException in org.apache.activemq.artemis.ra.inflow
Methods in org.apache.activemq.artemis.ra.inflow that throw ActiveMQException -
Uses of ActiveMQException in org.apache.activemq.artemis.reader
Methods in org.apache.activemq.artemis.reader that throw ActiveMQExceptionModifier and TypeMethodDescriptionstatic final voidMessageUtil.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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidActiveMQXAResourceWrapper.beforeReconnect(ActiveMQException me) voidActiveMQXAResourceWrapper.connectionFailed(ActiveMQException me, boolean failedOver) voidActiveMQXAResourceWrapper.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 ActiveMQExceptionModifier and TypeMethodDescriptionAbstractRemotingConnection.asyncFail(ActiveMQException me) RemotingConnection.asyncFail(ActiveMQException me) Same thing as fail, but using an executor. semantic of send here, is asynchrounous.protected voidAbstractRemotingConnection.callFailureListeners(ActiveMQException me, String scaleDownTargetNodeID) voidAbstractRemotingConnection.fail(ActiveMQException me) voidRemotingConnection.fail(ActiveMQException me) called when the underlying connection fails.voidRemotingConnection.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 ActiveMQExceptionModifier and TypeMethodDescriptionbooleanClientProtocolManager.cleanupBeforeFailover(ActiveMQException cause) voidBaseConnectionLifeCycleListener.connectionException(Object connectionID, ActiveMQException me) Called when an error occurs on the connection.abstract voidSessionContext.returnBlocking(ActiveMQException cause) Interrupt and return any blocked callsMethods in org.apache.activemq.artemis.spi.core.remoting that throw ActiveMQExceptionModifier and TypeMethodDescriptionabstract ClientSession.AddressQuerySessionContext.addressQuery(SimpleString address) abstract voidSessionContext.addSessionMetadata(String key, String data) abstract voidSessionContext.addUniqueMetaData(String key, String data) booleanClientProtocolManager.checkForFailover(String nodeID) abstract voidSessionContext.closeConsumer(ClientConsumer consumer) abstract booleanSessionContext.configureTransactionTimeout(int seconds) abstract voidSessionContext.createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) abstract voidSessionContext.createAddress(SimpleString address, Set<RoutingType> routingTypes, boolean autoCreated) Deprecated.abstract ClientConsumerInternalSessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout) abstract voidSessionContext.createQueue(QueueConfiguration queueConfiguration) abstract voidSessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated) Deprecated.abstract voidSessionContext.createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated, Boolean exclusive, Boolean lastVale) abstract voidSessionContext.createQueue(SimpleString address, SimpleString queueName, boolean temp, boolean autoCreated, QueueAttributes queueAttributes) abstract voidSessionContext.createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temp, boolean autoCreated) Deprecated.ClientProtocolManager.createSessionContext(String name, String username, String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int minLargeMessageSize, int confirmationWindowSize, String clientID) abstract voidSessionContext.createSharedQueue(QueueConfiguration queueConfiguration) abstract voidSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, QueueAttributes queueAttributes) Deprecated.abstract voidSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable) Deprecated.abstract voidSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) Deprecated.abstract voidSessionContext.createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable) Deprecated.abstract voidSessionContext.deleteQueue(SimpleString queueName) abstract voidSessionContext.expireMessage(ClientConsumer consumer, Message message) abstract voidSessionContext.forceDelivery(ClientConsumer consumer, long sequence) abstract intSessionContext.getDefaultConsumerWindowSize(SessionQueueQueryResponseMessage response) abstract ClientSession.QueueQuerySessionContext.queueQuery(SimpleString queueName) abstract booleanSessionContext.reattachOnNewConnection(RemotingConnection newConnection) it will either reattach or reconnect, preferably reattaching it.abstract intSessionContext.recoverSessionTimeout()Performs a round trip to the server requesting what is the current tx timeout on the sessionabstract voidSessionContext.recreateConsumerOnServer(ClientConsumerInternal consumerInternal, long consumerId, boolean isSessionStarted) abstract voidSessionContext.recreateSession(String username, String password, int minLargeMessageSize, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge) abstract voidSessionContext.restartSession()abstract voidSessionContext.sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message) abstract voidSessionContext.sendFullMessage(ICoreMessage msgI, boolean sendBlocking, SendAcknowledgementHandler handler, SimpleString defaultAddress, int senderID) abstract intSessionContext.sendInitialChunkOnLargeMessage(Message msgI) it should return the number of credits (or bytes) used to send this packetabstract intSessionContext.sendLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int reconnectID, int senderID, SendAcknowledgementHandler messageHandler) abstract intSessionContext.sendServerLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int senderID, SendAcknowledgementHandler messageHandler) abstract voidSessionContext.sessionClose()abstract voidSessionContext.sessionStart()abstract voidSessionContext.sessionStop()abstract voidSessionContext.simpleCommit()abstract voidSessionContext.simpleCommit(boolean block) abstract voidSessionContext.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 voidabstract voidabstract voidabstract voidabstract intabstract voidSessionContext.xaRollback(Xid xid, boolean wasStarted) abstract Xid[]SessionContext.xaScan()abstract void -
Uses of ActiveMQException in org.apache.activemq.artemis.utils
Methods in org.apache.activemq.artemis.utils that throw ActiveMQExceptionModifier and TypeMethodDescriptionstatic voidAutoCreateUtil.autoCreateQueue(ClientSession session, SimpleString destAddress, SimpleString selectorString) static SensitiveDataCodec<String>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 ActiveMQExceptionModifier and TypeMethodDescriptionvoidWildFlyRecoveryDiscovery.beforeReconnect(ActiveMQException exception) voidWildFlyRecoveryDiscovery.connectionFailed(ActiveMQException exception, boolean failedOver) voidWildFlyRecoveryDiscovery.connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)
ClientSession.createQueue(QueueConfiguration)instead