Modifier and Type | Method and Description |
---|---|
void |
PageTransactionInfo.reloadUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
void |
PageTransactionInfo.store(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
void |
PageTransactionInfo.storeUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
void |
PagedReferenceImpl.acknowledge(Transaction tx) |
void |
PageSubscription.ackTx(Transaction tx,
PagedReference position) |
void |
PageSubscriptionCounter.applyIncrement(Transaction tx,
long recordID,
int add) |
void |
PageSubscription.confirmPosition(Transaction tx,
PagePosition position) |
void |
PageSubscriptionCounter.increment(Transaction tx,
int add) |
void |
PageSubscription.reloadPreparedACK(Transaction tx,
PagePosition position)
To be used to avoid a redelivery of a prepared ACK after load
|
Modifier and Type | Method and Description |
---|---|
void |
PageSubscriptionImpl.ackTx(Transaction tx,
PagedReference reference) |
void |
PageSubscriptionCounterImpl.applyIncrement(Transaction tx,
long recordID,
int add)
This method will install the prepared TXs
|
void |
PageSubscriptionImpl.confirmPosition(Transaction tx,
PagePosition position) |
void |
PageSubscriptionCounterImpl.increment(Transaction tx,
int add) |
void |
PageSubscriptionImpl.reloadPreparedACK(Transaction tx,
PagePosition position) |
Modifier and Type | Method and Description |
---|---|
protected org.hornetq.core.paging.impl.PageTransactionInfoImpl.UpdatePageTXOperation |
PageTransactionInfoImpl.internalUpdatePageManager(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
void |
PageTransactionInfoImpl.reloadUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx,
int increment) |
void |
PageTransactionInfoImpl.store(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
void |
PageTransactionInfoImpl.storeUpdate(StorageManager storageManager,
PagingManager pagingManager,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
void |
StorageManager.confirmPendingLargeMessageTX(Transaction transaction,
long messageID,
long recordID) |
Modifier and Type | Method and Description |
---|---|
void |
JournalStorageManager.confirmPendingLargeMessageTX(Transaction tx,
long messageID,
long recordID) |
Modifier and Type | Method and Description |
---|---|
void |
NullStorageManager.confirmPendingLargeMessageTX(Transaction transaction,
long messageID,
long recordID) |
Modifier and Type | Method and Description |
---|---|
void |
DuplicateIDCache.addToCache(byte[] duplicateID,
Transaction tx) |
void |
DuplicateIDCache.load(Transaction tx,
byte[] duplID) |
Pair<RoutingContext,ServerMessage> |
PostOffice.redistribute(ServerMessage message,
Queue originatingQueue,
Transaction tx) |
MessageReference |
PostOffice.reroute(ServerMessage message,
Queue queue,
Transaction tx) |
void |
PostOffice.route(ServerMessage message,
Transaction tx,
boolean direct) |
void |
PostOffice.route(ServerMessage message,
Transaction tx,
boolean direct,
boolean rejectDuplicates) |
Modifier and Type | Method and Description |
---|---|
void |
DuplicateIDCacheImpl.addToCache(byte[] duplID,
Transaction tx) |
void |
DuplicateIDCacheImpl.load(Transaction tx,
byte[] duplID) |
Pair<RoutingContext,ServerMessage> |
PostOfficeImpl.redistribute(ServerMessage message,
Queue originatingQueue,
Transaction tx)
The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different thread
|
MessageReference |
PostOfficeImpl.reroute(ServerMessage message,
Queue queue,
Transaction tx) |
void |
PostOfficeImpl.route(ServerMessage message,
Transaction tx,
boolean direct) |
void |
PostOfficeImpl.route(ServerMessage message,
Transaction tx,
boolean direct,
boolean rejectDuplicates) |
Modifier and Type | Method and Description |
---|---|
Transaction |
RoutingContext.getTransaction() |
Modifier and Type | Method and Description |
---|---|
void |
ServerConsumer.acknowledge(boolean autoCommitAcks,
Transaction tx,
long messageID) |
void |
MessageReference.acknowledge(Transaction tx) |
void |
Queue.acknowledge(Transaction tx,
MessageReference ref) |
void |
Queue.cancel(Transaction tx,
MessageReference ref) |
List<MessageReference> |
ServerConsumer.cancelRefs(boolean failed,
boolean lastConsumedAsDelivered,
Transaction tx) |
void |
ServerConsumer.individualAcknowledge(boolean autoCommitAcks,
Transaction tx,
long messageID) |
void |
Queue.reacknowledge(Transaction tx,
MessageReference ref) |
void |
RoutingContext.setTransaction(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
Transaction |
RoutingContextImpl.getTransaction() |
Modifier and Type | Method and Description |
---|---|
void |
ServerConsumerImpl.acknowledge(boolean autoCommitAcks,
Transaction tx,
long messageID) |
void |
MessageReferenceImpl.acknowledge(Transaction tx) |
void |
QueueImpl.acknowledge(Transaction tx,
MessageReference ref) |
void |
QueueImpl.cancel(Transaction tx,
MessageReference reference) |
LinkedList<MessageReference> |
ServerConsumerImpl.cancelRefs(boolean failed,
boolean lastConsumedAsDelivered,
Transaction tx) |
void |
ServerConsumerImpl.individualAcknowledge(boolean autoCommitAcks,
Transaction tx,
long messageID) |
void |
QueueImpl.reacknowledge(Transaction tx,
MessageReference ref) |
void |
RoutingContextImpl.setTransaction(Transaction tx) |
Constructor and Description |
---|
RoutingContextImpl(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
Transaction |
Transaction.copy()
Used for pages during commit.
|
Transaction |
ResourceManager.getTransaction(Xid xid) |
Transaction |
ResourceManager.removeTransaction(Xid xid) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionOperationAbstract.afterCommit(Transaction tx)
After commit shouldn't throw any exception.
|
void |
TransactionOperation.afterCommit(Transaction tx)
After commit shouldn't throw any exception.
|
void |
TransactionOperationAbstract.afterPrepare(Transaction tx)
After prepare shouldn't throw any exception.
|
void |
TransactionOperation.afterPrepare(Transaction tx)
After prepare shouldn't throw any exception.
|
void |
TransactionOperationAbstract.afterRollback(Transaction tx)
After rollback shouldn't throw any exception.
|
void |
TransactionOperation.afterRollback(Transaction tx)
After rollback shouldn't throw any exception.
|
void |
TransactionOperationAbstract.beforeCommit(Transaction tx) |
void |
TransactionOperation.beforeCommit(Transaction tx) |
void |
TransactionOperationAbstract.beforePrepare(Transaction tx) |
void |
TransactionOperation.beforePrepare(Transaction tx) |
void |
TransactionOperationAbstract.beforeRollback(Transaction tx) |
void |
TransactionOperation.beforeRollback(Transaction tx) |
boolean |
ResourceManager.putTransaction(Xid xid,
Transaction tx) |
Constructor and Description |
---|
TransactionDetail(Xid xid,
Transaction tx,
Long creation) |
Modifier and Type | Class and Description |
---|---|
class |
TransactionImpl
A TransactionImpl
|
Modifier and Type | Method and Description |
---|---|
Transaction |
TransactionImpl.copy() |
Transaction |
ResourceManagerImpl.getTransaction(Xid xid) |
Transaction |
ResourceManagerImpl.removeTransaction(Xid xid) |
Modifier and Type | Method and Description |
---|---|
boolean |
ResourceManagerImpl.putTransaction(Xid xid,
Transaction tx) |
Constructor and Description |
---|
CoreTransactionDetail(Xid xid,
Transaction tx,
Long creation) |
Constructor and Description |
---|
JMSTransactionDetail(Xid xid,
Transaction tx,
Long creation) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.