Uses of Interface
org.apache.activemq.artemis.core.transaction.Transaction
Packages that use Transaction
Package
Description
-
Uses of Transaction in org.apache.activemq.artemis.core.paging
Methods in org.apache.activemq.artemis.core.paging that return TransactionMethods in org.apache.activemq.artemis.core.paging with parameters of type TransactionModifier and TypeMethodDescriptionbooleanPagingStore.page(Message message, Transaction tx, RouteContextList listCtx) Write message to page if we are paging.intPagingStore.page(Message message, Transaction tx, RouteContextList listCtx, Function<Message, Message> pageDecorator, boolean useFlowControl) voidPageTransactionInfo.reloadPrepared(Transaction transaction) voidPageTransactionInfo.reloadUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) voidPageTransactionInfo.store(StorageManager storageManager, PagingManager pagingManager, Transaction tx) voidPageTransactionInfo.storeUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx) -
Uses of Transaction in org.apache.activemq.artemis.core.paging.cursor
Methods in org.apache.activemq.artemis.core.paging.cursor with parameters of type TransactionModifier and TypeMethodDescriptionvoidPagedReferenceImpl.acknowledge(Transaction tx) voidPagedReferenceImpl.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer) voidPagedReferenceImpl.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer, boolean delivering) voidPagedReferenceImpl.acknowledge(Transaction tx, ServerConsumer consumer) default voidPageSubscription.ackTx(Transaction tx, PagedReference position) voidPageSubscription.ackTx(Transaction tx, PagedReference position, boolean fromDelivery) voidPageSubscriptionCounter.applyIncrementOnTX(Transaction tx, int add, long persistentSize) voidPageSubscription.confirmPosition(Transaction tx, PagePosition position, boolean fromDelivery) voidPageSubscriptionCounter.delete(Transaction tx) voidPageSubscriptionCounter.increment(Transaction tx, int add, long persistentSize) voidPageSubscription.onPageModeCleared(Transaction tx) voidPageSubscription.reloadPreparedACK(Transaction tx, PagePosition position) To be used to avoid a redelivery of a prepared ACK after load -
Uses of Transaction in org.apache.activemq.artemis.core.paging.cursor.impl
Methods in org.apache.activemq.artemis.core.paging.cursor.impl with parameters of type TransactionModifier and TypeMethodDescriptionvoidPageSubscriptionImpl.ackTx(Transaction tx, PagedReference reference, boolean fromDelivery) voidPageSubscriptionCounterImpl.applyIncrementOnTX(Transaction tx, int add, long size) This method will install the TXsvoidPageSubscriptionImpl.confirmPosition(Transaction tx, PagePosition position, boolean fromDelivery) voidPageSubscriptionCounterImpl.delete(Transaction tx) voidPageSubscriptionCounterImpl.increment(Transaction tx, int add, long size) voidPageSubscriptionImpl.onPageModeCleared(Transaction tx) voidPageSubscriptionImpl.reloadPreparedACK(Transaction tx, PagePosition position) -
Uses of Transaction in org.apache.activemq.artemis.core.paging.impl
Methods in org.apache.activemq.artemis.core.paging.impl that return TransactionMethods in org.apache.activemq.artemis.core.paging.impl with parameters of type TransactionModifier and TypeMethodDescriptionintPageTimedWriter.addTask(OperationContext context, PagedMessage message, Transaction tx, RouteContextList listCtx, boolean useFlowControl) protected org.apache.activemq.artemis.core.paging.impl.PageTransactionInfoImpl.UpdatePageTXOperationPageTransactionInfoImpl.internalUpdatePageManager(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) booleanPagingStoreImpl.page(Message message, Transaction tx, RouteContextList listCtx) intPagingStoreImpl.page(Message message, Transaction tx, RouteContextList listCtx, Function<Message, Message> pageDecorator, boolean useFlowControl) voidPageTransactionInfoImpl.reloadPrepared(Transaction tx) voidPageTransactionInfoImpl.reloadUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) voidPageTransactionInfoImpl.store(StorageManager storageManager, PagingManager pagingManager, Transaction tx) voidPageTransactionInfoImpl.storeUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx) -
Uses of Transaction in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence with parameters of type TransactionModifier and TypeMethodDescriptionbooleanStorageManager.addToPage(PagingStore store, Message msg, Transaction tx, RouteContextList listCtx) Write message to page if we are paging.voidStorageManager.confirmPendingLargeMessageTX(Transaction transaction, long messageID, long recordID) Confirms that a large message was finished -
Uses of Transaction in org.apache.activemq.artemis.core.persistence.impl.journal
Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type TransactionModifier and TypeMethodDescriptionbooleanAbstractJournalStorageManager.addToPage(PagingStore store, Message msg, Transaction tx, RouteContextList listCtx) voidTXLargeMessageConfirmationOperation.afterRollback(Transaction tx) voidAbstractJournalStorageManager.confirmPendingLargeMessageTX(Transaction tx, long messageID, long recordID) -
Uses of Transaction in org.apache.activemq.artemis.core.persistence.impl.journal.codec
Methods in org.apache.activemq.artemis.core.persistence.impl.journal.codec with parameters of type TransactionModifier and TypeMethodDescriptionvoidFinishPageMessageOperation.afterCommit(Transaction tx) voidFinishPageMessageOperation.afterRollback(Transaction tx) -
Uses of Transaction in org.apache.activemq.artemis.core.persistence.impl.nullpm
Methods in org.apache.activemq.artemis.core.persistence.impl.nullpm with parameters of type TransactionModifier and TypeMethodDescriptionbooleanNullStorageManager.addToPage(PagingStore store, Message msg, Transaction tx, RouteContextList listCtx) voidNullStorageManager.confirmPendingLargeMessageTX(Transaction transaction, long messageID, long recordID) -
Uses of Transaction in org.apache.activemq.artemis.core.postoffice
Methods in org.apache.activemq.artemis.core.postoffice with parameters of type TransactionModifier and TypeMethodDescriptionvoidDuplicateIDCache.addToCache(byte[] duplicateID, Transaction tx) voidDuplicateIDCache.addToCache(byte[] duplicateID, Transaction tx, boolean instantAdd) It will add the data to the cache.booleanDuplicateIDCache.atomicVerify(byte[] duplID, Transaction tx) voidDuplicateIDCache.load(Transaction tx, byte[] duplID) default voidPostOffice.preAcknowledge(Transaction tx, MessageReference ref, AckReason reason) PostOffice.reload(Message message, Queue queue, Transaction tx) AddressManager.removeBinding(SimpleString uniqueName, Transaction tx) This will use a Transaction as we need to confirm the queue was removedPostOffice.removeBinding(SimpleString uniqueName, Transaction tx, boolean deleteData) default MessageReferencePostOffice.reroute(Message message, Queue queue, Transaction tx) Deprecated.PostOffice.route(Message message, Transaction tx, boolean direct) PostOffice.route(Message message, Transaction tx, boolean direct, boolean rejectDuplicates) PostOffice.route(Message message, Transaction tx, boolean direct, boolean rejectDuplicates, Binding binding) -
Uses of Transaction in org.apache.activemq.artemis.core.postoffice.impl
Methods in org.apache.activemq.artemis.core.postoffice.impl with parameters of type TransactionModifier and TypeMethodDescriptionvoidNoOpDuplicateIDCache.addToCache(byte[] duplicateID, Transaction tx) voidNoOpDuplicateIDCache.addToCache(byte[] duplicateID, Transaction tx, boolean instantAdd) voidPostOfficeImpl.AddOperation.afterCommit(Transaction tx) voidPostOfficeImpl.AddOperation.afterPrepare(Transaction tx) voidPostOfficeImpl.AddOperation.afterRollback(Transaction tx) booleanNoOpDuplicateIDCache.atomicVerify(byte[] duplID, Transaction tx) voidPostOfficeImpl.AddOperation.beforeCommit(Transaction tx) voidPostOfficeImpl.AddOperation.beforePrepare(Transaction tx) voidPostOfficeImpl.AddOperation.beforeRollback(Transaction tx) voidNoOpDuplicateIDCache.load(Transaction tx, byte[] duplID) voidPostOfficeImpl.preAcknowledge(Transaction tx, MessageReference ref, AckReason reason) PostOfficeImpl.reload(Message message, Queue queue, Transaction tx) PostOfficeImpl.removeBinding(SimpleString uniqueName, Transaction tx, boolean deleteData) SimpleAddressManager.removeBinding(SimpleString uniqueName, Transaction tx) WildcardAddressManager.removeBinding(SimpleString uniqueName, Transaction tx) PostOfficeImpl.route(Message message, Transaction tx, boolean direct) PostOfficeImpl.route(Message message, Transaction tx, boolean direct, boolean rejectDuplicates) PostOfficeImpl.route(Message message, Transaction tx, boolean direct, boolean rejectDuplicates, Binding binding) static voidPostOfficeImpl.storeDurableReference(StorageManager storageManager, Message message, Transaction tx, Queue queue, boolean sync) -
Uses of Transaction in org.apache.activemq.artemis.core.server
Methods in org.apache.activemq.artemis.core.server that return TransactionModifier and TypeMethodDescriptionServerSession.getCurrentTransaction()RoutingContext.getTransaction()ServerSession.newTransaction()Methods in org.apache.activemq.artemis.core.server with parameters of type TransactionModifier and TypeMethodDescriptionvoidMessageReference.acknowledge(Transaction tx) voidMessageReference.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer) voidMessageReference.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer, boolean delivering) voidMessageReference.acknowledge(Transaction tx, ServerConsumer consumer) voidQueue.acknowledge(Transaction tx, MessageReference ref) voidQueue.acknowledge(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer, boolean delivering) ServerConsumer.acknowledge(Transaction tx, long messageID) voidQueue.cancel(Transaction tx, MessageReference ref) voidQueue.cancel(Transaction tx, MessageReference ref, boolean ignoreRedeliveryCheck) ServerConsumer.cancelRefs(boolean failed, boolean lastConsumedAsDelivered, Transaction tx) ServerSession.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, String senderName, boolean noAutoCreateQueue) ServerSession.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, String senderName, boolean noAutoCreateQueue, RoutingContext routingContext) voidServerConsumer.individualAcknowledge(Transaction tx, long messageID) voidServerConsumer.metricsAcknowledge(MessageReference ref, Transaction transaction) This is needed when some protocols (OW) handle the acks themselves and need to update the metricsvoidQueue.reacknowledge(Transaction tx, MessageReference ref) ScheduledDeliveryHandler.removeReferenceWithID(long id, Transaction tx) voidServerSession.resetTX(Transaction transaction) To be used by protocol heads that needs to control the transaction outside the session context.ServerSession.send(Transaction tx, Message message, boolean direct, String senderName, boolean noAutoCreateQueue) ServerSession.send(Transaction tx, Message message, boolean direct, String senderName, boolean noAutoCreateQueue, RoutingContext routingContext) booleanQueue.sendToDeadLetterAddress(Transaction tx, MessageReference ref) Returns whether the message was actually sent to a DLA with bindings.voidRoutingContext.setTransaction(Transaction transaction) -
Uses of Transaction in org.apache.activemq.artemis.core.server.federation.address
Methods in org.apache.activemq.artemis.core.server.federation.address with parameters of type TransactionModifier and TypeMethodDescriptionvoidFederatedAddress.beforeRemoveBinding(SimpleString uniqueName, Transaction tx, boolean deleteData) -
Uses of Transaction in org.apache.activemq.artemis.core.server.impl
Fields in org.apache.activemq.artemis.core.server.impl declared as TransactionModifier and TypeFieldDescriptionprotected TransactionServerSessionImpl.pendingTXThis will store the Transaction between xaEnd and xaPrepare or xaCommit.protected TransactionServerSessionImpl.txMethods in org.apache.activemq.artemis.core.server.impl that return TransactionModifier and TypeMethodDescriptionServerSessionImpl.getCurrentTransaction()RoutingContextImpl.getTransaction()ServerSessionImpl.newTransaction()Methods in org.apache.activemq.artemis.core.server.impl with parameters of type TransactionModifier and TypeMethodDescriptionvoidGroupFirstMessageReference.acknowledge(Transaction tx) voidGroupFirstMessageReference.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer) voidGroupFirstMessageReference.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer, boolean delivering) voidGroupFirstMessageReference.acknowledge(Transaction tx, ServerConsumer consumer) voidLastValueQueue.acknowledge(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer, boolean delivering) voidMessageReferenceImpl.acknowledge(Transaction tx) voidMessageReferenceImpl.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer) voidMessageReferenceImpl.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer, boolean delivering) voidMessageReferenceImpl.acknowledge(Transaction tx, ServerConsumer consumer) voidQueueImpl.acknowledge(Transaction tx, MessageReference ref) voidQueueImpl.acknowledge(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer, boolean delivering) The parameter delivering can be sent as false in situation where the ack is coming outside of the context of delivering.ServerConsumerImpl.acknowledge(Transaction tx, long messageID) voidRefsOperation.afterCommit(Transaction tx) voidRefsOperation.afterRollback(Transaction tx) voidQueueImpl.cancel(Transaction tx, MessageReference reference) voidQueueImpl.cancel(Transaction tx, MessageReference reference, boolean ignoreRedeliveryCheck) ServerConsumerImpl.cancelRefs(boolean failed, boolean lastConsumedAsDelivered, Transaction tx) ServerSessionImpl.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, String senderName, boolean noAutoCreateQueue) ServerSessionImpl.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, String senderName, boolean noAutoCreateQueue, RoutingContext routingContext) voidJournalLoader.handlePreparedSendMessage(Message message, Transaction tx, long queueID) voidPostOfficeJournalLoader.handlePreparedSendMessage(Message message, Transaction tx, long queueID) voidJournalLoader.handlePreparedTransaction(Transaction tx, List<MessageReference> referencesToAck, Xid xid, ResourceManager resourceManager) voidPostOfficeJournalLoader.handlePreparedTransaction(Transaction tx, List<MessageReference> referencesToAck, Xid xid, ResourceManager resourceManager) voidServerConsumerImpl.individualAcknowledge(Transaction tx, long messageID) voidServerConsumerImpl.metricsAcknowledge(MessageReference ref, Transaction transaction) voidQueueImpl.reacknowledge(Transaction tx, MessageReference ref) ScheduledDeliveryHandlerImpl.removeReferenceWithID(long id, Transaction tx) voidServerSessionImpl.resetTX(Transaction transaction) Some protocols may chose to hold their transactions outside of the ServerSession.protected voidRefsOperation.rollbackRedelivery(Transaction tx, MessageReference ref, long timeBase, Map<QueueImpl, LinkedList<MessageReference>> queueMap) ServerSessionImpl.send(Transaction tx, Message msg, boolean direct, String senderName, boolean noAutoCreateQueue) ServerSessionImpl.send(Transaction tx, Message messageParameter, boolean direct, String senderName, boolean noAutoCreateQueue, RoutingContext routingContext) booleanQueueImpl.sendToDeadLetterAddress(Transaction tx, MessageReference ref) voidRoutingContextImpl.setTransaction(Transaction tx) Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type Transaction -
Uses of Transaction in org.apache.activemq.artemis.core.server.mirror
Methods in org.apache.activemq.artemis.core.server.mirror with parameters of type TransactionModifier and TypeMethodDescriptionvoidMirrorController.preAcknowledge(Transaction tx, MessageReference ref, AckReason reason) voidMirrorController.sendMessage(Transaction tx, Message message, RoutingContext context) -
Uses of Transaction in org.apache.activemq.artemis.core.server.plugin
Methods in org.apache.activemq.artemis.core.server.plugin with parameters of type TransactionModifier and TypeMethodDescriptiondefault voidActiveMQServerResourcePlugin.afterPutTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection) After a transaction is putdefault voidActiveMQServerBindingPlugin.afterRemoveBinding(Binding binding, Transaction tx, boolean deleteData) After a binding 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) Deprecated.default voidActiveMQServerResourcePlugin.beforePutTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection) Before a transaction is putdefault voidActiveMQServerBindingPlugin.beforeRemoveBinding(SimpleString uniqueName, Transaction tx, boolean deleteData) Before a binding 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 voidActiveMQServerMessagePlugin.messageAcknowledged(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer) A message has been acknowledgeddefault voidActiveMQServerMessagePlugin.messageMoved(Transaction tx, MessageReference ref, AckReason reason, SimpleString destAddress, Long destQueueID, ServerConsumer consumer, Message newMessage, RoutingStatus result) A message has been moveddefault voidActiveMQServerMessagePlugin.onSendException(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e) When there was an exception sending the message -
Uses of Transaction in org.apache.activemq.artemis.core.server.plugin.impl
Methods in org.apache.activemq.artemis.core.server.plugin.impl with parameters of type TransactionModifier and TypeMethodDescriptionvoidLoggingActiveMQServerPlugin.afterSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result) After a message is sentvoidLoggingActiveMQServerPluginLogger_impl.afterSendDetails(Message message, String result, Transaction tx, String sessionName, String connectionID, boolean direct, boolean noAutoCreateQueue) voidLoggingActiveMQServerPluginLogger.afterSendDetails(Message message, String result, Transaction tx, String sessionName, String connectionID, boolean direct, boolean noAutoCreateQueue) voidLoggingActiveMQServerPlugin.beforeSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) Before a message is sentvoidLoggingActiveMQServerPluginLogger_impl.beforeSend(Message message, Transaction tx, ServerSession session, boolean direct, boolean noAutoCreateQueue) voidLoggingActiveMQServerPluginLogger.beforeSend(Message message, Transaction tx, ServerSession session, boolean direct, boolean noAutoCreateQueue) voidLoggingActiveMQServerPlugin.messageAcknowledged(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer) A message has been acknowledgedvoidLoggingActiveMQServerPluginLogger_impl.messageAcknowledged(MessageReference ref, Transaction tx) voidLoggingActiveMQServerPluginLogger.messageAcknowledged(MessageReference ref, Transaction tx) voidLoggingActiveMQServerPluginLogger_impl.onSendErrorDetails(String messageID, Message message, String sessionName, Transaction tx, ServerSession session, boolean direct, boolean noAutoCreateQueue) voidLoggingActiveMQServerPluginLogger.onSendErrorDetails(String messageID, Message message, String sessionName, Transaction tx, ServerSession session, boolean direct, boolean noAutoCreateQueue) voidLoggingActiveMQServerPlugin.onSendException(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e) voidLoggingActiveMQServerPluginLogger_impl.rolledBackTransaction(Transaction tx, String resource) voidLoggingActiveMQServerPluginLogger.rolledBackTransaction(Transaction tx, String resource) -
Uses of Transaction in org.apache.activemq.artemis.core.transaction
Methods in org.apache.activemq.artemis.core.transaction that return TransactionModifier and TypeMethodDescriptionResourceManager.getTransaction(Xid xid) ResourceManager.removeTransaction(Xid xid, RemotingConnection remotingConnection) Transaction.setAsync(boolean async) To be used on control transactions that are meant as internal and don't really require a hard sync.Methods in org.apache.activemq.artemis.core.transaction with parameters of type TransactionModifier and TypeMethodDescriptionvoidTransactionOperation.afterCommit(Transaction tx) After commit shouldn't throw any exception.voidTransactionOperationAbstract.afterCommit(Transaction tx) After commit shouldn't throw any exception.voidTransactionOperation.afterPrepare(Transaction tx) After prepare shouldn't throw any exception.voidTransactionOperationAbstract.afterPrepare(Transaction tx) After prepare shouldn't throw any exception.voidTransactionOperation.afterRollback(Transaction tx) After rollback shouldn't throw any exception.voidTransactionOperationAbstract.afterRollback(Transaction tx) After rollback shouldn't throw any exception.voidTransactionOperation.beforeCommit(Transaction tx) voidTransactionOperationAbstract.beforeCommit(Transaction tx) voidTransactionOperation.beforePrepare(Transaction tx) voidTransactionOperationAbstract.beforePrepare(Transaction tx) voidTransactionOperation.beforeRollback(Transaction tx) voidTransactionOperationAbstract.beforeRollback(Transaction tx) TransactionDetailFactory.createTransactionDetail(Xid xid, Transaction tx, Long creation) booleanResourceManager.putTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection) Constructors in org.apache.activemq.artemis.core.transaction with parameters of type Transaction -
Uses of Transaction in org.apache.activemq.artemis.core.transaction.impl
Classes in org.apache.activemq.artemis.core.transaction.impl that implement TransactionMethods in org.apache.activemq.artemis.core.transaction.impl that return TransactionModifier and TypeMethodDescriptionResourceManagerImpl.getTransaction(Xid xid) ResourceManagerImpl.removeTransaction(Xid xid, RemotingConnection remotingConnection) Methods in org.apache.activemq.artemis.core.transaction.impl with parameters of type TransactionModifier and TypeMethodDescriptionbooleanResourceManagerImpl.putTransaction(Xid xid, Transaction tx, RemotingConnection remotingConnection) Constructors in org.apache.activemq.artemis.core.transaction.impl with parameters of type Transaction -
Uses of Transaction in org.apache.activemq.artemis.jms.transaction
Constructors in org.apache.activemq.artemis.jms.transaction with parameters of type Transaction -
Uses of Transaction in org.apache.activemq.artemis.spi.core.protocol
Methods in org.apache.activemq.artemis.spi.core.protocol that return Transaction
ActiveMQServerMessagePlugin.afterSend(ServerSession, Transaction, Message, boolean, boolean, RoutingStatus)