This is an automated email from the ASF dual-hosted git repository.

jbertram pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new 3797b62  NO-JIRA Remove unnecessary null-check in ExpiryScanner
     new 41991e2  This closes #2961
3797b62 is described below

commit 3797b62420386abab35a82e96d8abc24279bc903
Author: Sebastian Thomschke <[email protected]>
AuthorDate: Fri Jan 31 09:22:47 2020 +0100

    NO-JIRA Remove unnecessary null-check in ExpiryScanner
---
 .../java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
index d03494a..5aea38c 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
@@ -2270,11 +2270,8 @@ public class QueueImpl extends CriticalComponentImpl 
implements Queue {
          }
 
          if (!expiredMessages.isEmpty()) {
-            Transaction tx = new TransactionImpl(storageManager);
+            final Transaction tx = new TransactionImpl(storageManager);
             for (MessageReference ref : expiredMessages) {
-               if (tx == null) {
-                  tx = new TransactionImpl(storageManager);
-               }
                try {
                   expire(tx, ref);
                   refRemoved(ref);

Reply via email to