You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/12/20 06:50:37 UTC
[pulsar] branch master updated: Optimize transaction FieldUpdater to static final (#13396)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new b261d6a Optimize transaction FieldUpdater to static final (#13396)
b261d6a is described below
commit b261d6abfc3a6a0707bf8ff6712a58cf7f0b6a1b
Author: ZhangJian He <sh...@gmail.com>
AuthorDate: Mon Dec 20 14:49:29 2021 +0800
Optimize transaction FieldUpdater to static final (#13396)
---
.../java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java
index 4128a6f..ebcb20e 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java
@@ -66,7 +66,7 @@ public class TransactionImpl implements Transaction , TimerTask {
private final ArrayList<CompletableFuture<MessageId>> sendFutureList;
private final ArrayList<CompletableFuture<Void>> ackFutureList;
private volatile State state;
- private final AtomicReferenceFieldUpdater<TransactionImpl, State> STATE_UPDATE =
+ private static final AtomicReferenceFieldUpdater<TransactionImpl, State> STATE_UPDATE =
AtomicReferenceFieldUpdater.newUpdater(TransactionImpl.class, State.class, "state");
@Override