activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbert...@apache.org
Subject [2/2] activemq-artemis git commit: ARTEMIS-1667 init pagingFactory with journalBufferTimeout_NIO
Date Mon, 12 Feb 2018 15:38:27 GMT
ARTEMIS-1667 init pagingFactory with journalBufferTimeout_NIO


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

Branch: refs/heads/master
Commit: 5dc0777f52a4d2e388f569bdedd6a7f0d40697f5
Parents: eada73e
Author: yang wei <wy96fyw@gmail.com>
Authored: Mon Feb 5 16:42:23 2018 +0800
Committer: Justin Bertram <jbertram@apache.org>
Committed: Mon Feb 12 09:37:56 2018 -0600

----------------------------------------------------------------------
 .../activemq/artemis/core/replication/ReplicationEndpoint.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/5dc0777f/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
index 4d81613..f76f796 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
@@ -262,7 +262,7 @@ public final class ReplicationEndpoint implements ChannelHandler, ActiveMQCompon
             journalLoadInformation[jc.typeByte] = journalsHolder.get(jc).loadSyncOnly(JournalState.SYNCING);
          }
 
-         pageManager = new PagingManagerImpl(new PagingStoreFactoryNIO(storageManager, config.getPagingLocation(),
config.getJournalBufferSize_NIO(), server.getScheduledPool(), server.getExecutorFactory(),
config.isJournalSyncNonTransactional(), criticalErrorListener), server.getAddressSettingsRepository());
+         pageManager = new PagingManagerImpl(new PagingStoreFactoryNIO(storageManager, config.getPagingLocation(),
config.getJournalBufferTimeout_NIO(), server.getScheduledPool(), server.getExecutorFactory(),
config.isJournalSyncNonTransactional(), criticalErrorListener), server.getAddressSettingsRepository());
 
          pageManager.start();
 


Mime
View raw message