From 6a64f6a3e62e56accfa8391dbe5e468d1c6a84f7 Mon Sep 17 00:00:00 2001 From: Mark Needham Date: Thu, 14 Jul 2016 09:38:50 +0100 Subject: [PATCH] Put raft-messages.log in the logs directory --- .../server/core/EnterpriseCoreEditionModule.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/enterprise/core-edge/src/main/java/org/neo4j/coreedge/server/core/EnterpriseCoreEditionModule.java b/enterprise/core-edge/src/main/java/org/neo4j/coreedge/server/core/EnterpriseCoreEditionModule.java index 638fd07288fc8..253cbcc3d8b10 100644 --- a/enterprise/core-edge/src/main/java/org/neo4j/coreedge/server/core/EnterpriseCoreEditionModule.java +++ b/enterprise/core-edge/src/main/java/org/neo4j/coreedge/server/core/EnterpriseCoreEditionModule.java @@ -269,8 +269,8 @@ public void registerProcedures( Procedures procedures ) final MessageLogger messageLogger; if ( config.get( CoreEdgeClusterSettings.raft_messages_log_enable ) ) { - messageLogger = - life.add( new BetterMessageLogger<>( myself, raftMessagesLog( storeDir ) ) ); + File logsDir = config.get( GraphDatabaseSettings.logs_directory ); + messageLogger = life.add( new BetterMessageLogger<>( myself, raftMessagesLog( logsDir ) ) ); } else { @@ -587,13 +587,14 @@ private File createClusterStateDirectory( File dir, FileSystemAbstraction fileSy } } - private static PrintWriter raftMessagesLog( File storeDir ) + private static PrintWriter raftMessagesLog( File logsDir ) { //noinspection ResultOfMethodCallIgnored - storeDir.mkdirs(); + logsDir.mkdirs(); try { - return new PrintWriter( new FileOutputStream( new File( storeDir, "raft-messages.log" ), true ) ); + + return new PrintWriter( new FileOutputStream( new File( logsDir, "raft-messages.log" ), true ) ); } catch ( FileNotFoundException e ) {