activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hadr...@apache.org
Subject [1/2] activemq git commit: Delete redundant persistenceAdapter.getTransactionContext
Date Thu, 03 Nov 2016 18:06:45 GMT
Repository: activemq
Updated Branches:
  refs/heads/master d54d046b8 -> d93509129


Delete redundant persistenceAdapter.getTransactionContext


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/0d90a2a6
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/0d90a2a6
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/0d90a2a6

Branch: refs/heads/master
Commit: 0d90a2a6835fc4401a44fe2d2cc391adc7fa57a5
Parents: d54d046
Author: Dominik Przybysz <dpr@touk.pl>
Authored: Mon Feb 29 13:21:58 2016 +0100
Committer: Hadrian Zbarcea <hadrian@apache.org>
Committed: Thu Nov 3 14:02:01 2016 -0400

----------------------------------------------------------------------
 .../apache/activemq/store/jdbc/JDBCMessageStore.java    | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/0d90a2a6/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCMessageStore.java
----------------------------------------------------------------------
diff --git a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCMessageStore.java
b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCMessageStore.java
index 744220d..29db04c 100644
--- a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCMessageStore.java
+++ b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCMessageStore.java
@@ -16,11 +16,6 @@
  */
 package org.apache.activemq.store.jdbc;
 
-import java.io.IOException;
-import java.sql.SQLException;
-import java.util.Arrays;
-import java.util.LinkedList;
-
 import org.apache.activemq.ActiveMQMessageAudit;
 import org.apache.activemq.broker.ConnectionContext;
 import org.apache.activemq.command.ActiveMQDestination;
@@ -38,6 +33,11 @@ import org.apache.activemq.wireformat.WireFormat;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.io.IOException;
+import java.sql.SQLException;
+import java.util.Arrays;
+import java.util.LinkedList;
+
 /**
  *
  */
@@ -86,7 +86,6 @@ public class JDBCMessageStore extends AbstractMessageStore {
     private void recordDestinationCreation(ActiveMQDestination destination) throws IOException
{
         TransactionContext c = persistenceAdapter.getTransactionContext();
         try {
-            c = persistenceAdapter.getTransactionContext();
             if (adapter.doGetLastAckedDurableSubscriberMessageId(c, destination, destination.getQualifiedName(),
destination.getQualifiedName()) < 0) {
                 adapter.doRecordDestination(c, destination);
             }
@@ -273,7 +272,6 @@ public class JDBCMessageStore extends AbstractMessageStore {
         // Get all the Message ids out of the database.
         TransactionContext c = persistenceAdapter.getTransactionContext();
         try {
-            c = persistenceAdapter.getTransactionContext();
             adapter.doRecover(c, destination, new JDBCMessageRecoveryListener() {
                 @Override
                 public boolean recoverMessage(long sequenceId, byte[] data) throws Exception
{


Mime
View raw message