diff options
Diffstat (limited to 'qpid')
3 files changed, 8 insertions, 8 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/txn/DistributedTransaction.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/txn/DistributedTransaction.java index 30a27c5049..35f2887562 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/txn/DistributedTransaction.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/txn/DistributedTransaction.java @@ -66,7 +66,7 @@ public class DistributedTransaction implements ServerTransaction { if(_branch != null) { - _branch.addPostTransactionAcion(postTransactionAction); + _branch.addPostTransactionAction(postTransactionAction); } else { @@ -79,7 +79,7 @@ public class DistributedTransaction implements ServerTransaction if(_branch != null) { _branch.dequeue(queue, message); - _branch.addPostTransactionAcion(postTransactionAction); + _branch.addPostTransactionAction(postTransactionAction); } else { @@ -95,7 +95,7 @@ public class DistributedTransaction implements ServerTransaction { _branch.dequeue(entry.getQueue(), entry.getMessage()); } - _branch.addPostTransactionAcion(postTransactionAction); + _branch.addPostTransactionAction(postTransactionAction); } else { @@ -108,7 +108,7 @@ public class DistributedTransaction implements ServerTransaction if(_branch != null) { _branch.enqueue(queue, message); - _branch.addPostTransactionAcion(postTransactionAction); + _branch.addPostTransactionAction(postTransactionAction); enqueue(Collections.singletonList(queue), message, postTransactionAction); } else @@ -126,7 +126,7 @@ public class DistributedTransaction implements ServerTransaction { _branch.enqueue(queue, message); } - _branch.addPostTransactionAcion(postTransactionAction); + _branch.addPostTransactionAction(postTransactionAction); } else { diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/txn/DtxBranch.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/txn/DtxBranch.java index f3f18c7c5d..6b12862690 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/txn/DtxBranch.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/txn/DtxBranch.java @@ -350,7 +350,7 @@ public class DtxBranch } - public void addPostTransactionAcion(ServerTransaction.Action postTransactionAction) + public void addPostTransactionAction(ServerTransaction.Action postTransactionAction) { _postTransactionActions.add(postTransactionAction); } diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostConfigRecoveryHandler.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostConfigRecoveryHandler.java index 21483e33cb..b7d3cf872b 100755 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostConfigRecoveryHandler.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostConfigRecoveryHandler.java @@ -133,7 +133,7 @@ public class VirtualHostConfigRecoveryHandler implements branch.enqueue(queue,message); - branch.addPostTransactionAcion(new ServerTransaction.Action() + branch.addPostTransactionAction(new ServerTransaction.Action() { public void postCommit() @@ -194,7 +194,7 @@ public class VirtualHostConfigRecoveryHandler implements branch.dequeue(queue, message); - branch.addPostTransactionAcion(new ServerTransaction.Action() + branch.addPostTransactionAction(new ServerTransaction.Action() { public void postCommit() |