activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [01/43] activemq-artemis git commit: Added back Timer intialization [Forced Update!]
Date Tue, 09 Feb 2016 20:20:20 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/refactor-openwire 8dc14b46a -> 58cd458c7 (forced update)


Added back Timer intialization


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

Branch: refs/heads/refactor-openwire
Commit: 470daad22e38e7b959f36b63fffcd757b0e23e8c
Parents: fffd81f
Author: Martyn Taylor <mtaylor@redhat.com>
Authored: Tue Feb 9 13:39:25 2016 +0000
Committer: Martyn Taylor <mtaylor@redhat.com>
Committed: Tue Feb 9 13:39:25 2016 +0000

----------------------------------------------------------------------
 .../activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/470daad2/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java
----------------------------------------------------------------------
diff --git a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java
b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java
index e7a0165..a21b455 100644
--- a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java
+++ b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java
@@ -119,7 +119,7 @@ public class JDBCJournalImpl implements Journal {
       deleteJournalRecords = connection.prepareStatement(JDBCJournalRecord.deleteRecordsSQL(tableName));
       deleteJournalTxRecords = connection.prepareStatement(JDBCJournalRecord.deleteJournalTxRecordsSQL(tableName));
 
-
+      syncTimer = new Timer(timerThread, true);
       syncTimer.schedule(new JDBCJournalSync(this), SYNC_DELAY * 2, SYNC_DELAY);
 
       started = true;


Mime
View raw message