You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by an...@apache.org on 2016/02/09 15:36:36 UTC
[1/2] activemq-artemis git commit: Added back Timer intialization
Repository: activemq-artemis
Updated Branches:
refs/heads/master fffd81f80 -> e0f5cb6ee
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/master
Commit: 470daad22e38e7b959f36b63fffcd757b0e23e8c
Parents: fffd81f
Author: Martyn Taylor <mt...@redhat.com>
Authored: Tue Feb 9 13:39:25 2016 +0000
Committer: Martyn Taylor <mt...@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;
[2/2] activemq-artemis git commit: This closes #383 Added back Timer
intialization
Posted by an...@apache.org.
This closes #383 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/e0f5cb6e
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/e0f5cb6e
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/e0f5cb6e
Branch: refs/heads/master
Commit: e0f5cb6eeeb13c191b825836203cb6568c2ddf4a
Parents: fffd81f 470daad
Author: Andy Taylor <an...@gmail.com>
Authored: Tue Feb 9 13:59:29 2016 +0000
Committer: Andy Taylor <an...@gmail.com>
Committed: Tue Feb 9 13:59:29 2016 +0000
----------------------------------------------------------------------
.../activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------