activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From martyntay...@apache.org
Subject [2/2] activemq-artemis git commit: ARTEMIS-1254 New OrderedExecutor for JDBC LargeMsg
Date Mon, 26 Jun 2017 18:12:34 GMT
ARTEMIS-1254 New OrderedExecutor for JDBC LargeMsg

(cherry picked from commit 222275dd8dc29450bce9bce0419b8a55b797673c)


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

Branch: refs/heads/1.x
Commit: 15990589a368bde944058fec9c012a71f37ca261
Parents: 21215e4
Author: Martyn Taylor <mtaylor@redhat.com>
Authored: Thu Jun 22 13:34:34 2017 +0100
Committer: Martyn Taylor <mtaylor@redhat.com>
Committed: Mon Jun 26 19:12:03 2017 +0100

----------------------------------------------------------------------
 .../core/persistence/impl/journal/JDBCJournalStorageManager.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/15990589/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JDBCJournalStorageManager.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JDBCJournalStorageManager.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JDBCJournalStorageManager.java
index 4b8392d..9923a3e 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JDBCJournalStorageManager.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JDBCJournalStorageManager.java
@@ -66,12 +66,12 @@ public class JDBCJournalStorageManager extends JournalStorageManager {
             }
             bindingsJournal = new JDBCJournalImpl(dbConf.getDataSource(), sqlProviderFactory.create(dbConf.getBindingsTableName(),
SQLProvider.DatabaseStoreType.BINDINGS_JOURNAL), dbConf.getBindingsTableName(), scheduledExecutorService,
executorFactory.getExecutor(), criticalErrorListener);
             messageJournal = new JDBCJournalImpl(dbConf.getDataSource(), sqlProviderFactory.create(dbConf.getMessageTableName(),
SQLProvider.DatabaseStoreType.MESSAGE_JOURNAL), dbConf.getMessageTableName(), scheduledExecutorService,
executorFactory.getExecutor(), criticalErrorListener);
-            largeMessagesFactory = new JDBCSequentialFileFactory(dbConf.getDataSource(),
sqlProviderFactory.create(dbConf.getLargeMessageTableName(), SQLProvider.DatabaseStoreType.LARGE_MESSAGE),
executor, criticalErrorListener);
+            largeMessagesFactory = new JDBCSequentialFileFactory(dbConf.getDataSource(),
sqlProviderFactory.create(dbConf.getLargeMessageTableName(), SQLProvider.DatabaseStoreType.LARGE_MESSAGE),
executorFactory.getExecutor(), criticalErrorListener);
          } else {
             String driverClassName = dbConf.getJdbcDriverClassName();
             bindingsJournal = new JDBCJournalImpl(dbConf.getJdbcConnectionUrl(), driverClassName,
JDBCUtils.getSQLProvider(driverClassName, dbConf.getBindingsTableName(), SQLProvider.DatabaseStoreType.BINDINGS_JOURNAL),
scheduledExecutorService, executorFactory.getExecutor(), criticalErrorListener);
             messageJournal = new JDBCJournalImpl(dbConf.getJdbcConnectionUrl(), driverClassName,
JDBCUtils.getSQLProvider(driverClassName, dbConf.getMessageTableName(), SQLProvider.DatabaseStoreType.MESSAGE_JOURNAL),
scheduledExecutorService, executorFactory.getExecutor(), criticalErrorListener);
-            largeMessagesFactory = new JDBCSequentialFileFactory(dbConf.getJdbcConnectionUrl(),
driverClassName, JDBCUtils.getSQLProvider(driverClassName, dbConf.getLargeMessageTableName(),
SQLProvider.DatabaseStoreType.LARGE_MESSAGE), executor, criticalErrorListener);
+            largeMessagesFactory = new JDBCSequentialFileFactory(dbConf.getJdbcConnectionUrl(),
driverClassName, JDBCUtils.getSQLProvider(driverClassName, dbConf.getLargeMessageTableName(),
SQLProvider.DatabaseStoreType.LARGE_MESSAGE), executorFactory.getExecutor(), criticalErrorListener);
          }
          final int networkTimeout = dbConf.getJdbcNetworkTimeout();
          if (networkTimeout >= 0) {


Mime
View raw message