[Java] Minor tidy ups.

aeron-archiver/src/main/java/io/aeron/archiver/ArchiveConductor.java

@@ -232,6 +232,7 @@ private void startRecording(final Image image)
             notificationsProxy,
             image,
             recordingContext);
+
         recordingSessionByIdMap.put(recordingId, session);
         recorder.addSession(session);
     }

aeron-archiver/src/main/java/io/aeron/archiver/Catalog.java

@@ -46,17 +46,14 @@ class Catalog implements AutoCloseable
     private static final int PAGE_SIZE = 4096;
 
     private final RecordingDescriptorEncoder recordingDescriptorEncoder = new RecordingDescriptorEncoder();
-
-    private final ByteBuffer byteBuffer;
-    private final UnsafeBuffer unsafeBuffer;
+    private final ByteBuffer byteBuffer = BufferUtil.allocateDirectAligned(RECORD_LENGTH, PAGE_SIZE);
+    private final UnsafeBuffer unsafeBuffer = new UnsafeBuffer(byteBuffer);
     private final FileChannel catalogFileChannel;
+
     private long nextRecordingId = 0;
 
     Catalog(final File archiveDir)
     {
-        byteBuffer = BufferUtil.allocateDirectAligned(RECORD_LENGTH, PAGE_SIZE);
-        unsafeBuffer = new UnsafeBuffer(byteBuffer);
-
         FileChannel channel = null;
         try
         {

aeron-archiver/src/main/java/io/aeron/archiver/ControlSession.java

@@ -25,7 +25,6 @@
 
 class ControlSession implements Session, ControlRequestListener
 {
-
     enum State
     {
         INIT, ACTIVE, INACTIVE, CLOSED

aeron-archiver/src/main/java/io/aeron/archiver/RecordingWriter.java

@@ -51,6 +51,7 @@
 class RecordingWriter implements AutoCloseable, RawBlockHandler
 {
     private static final boolean VALIDATE_POSITION_ASSUMPTIONS = true;
+
     static class Marker
     {
         private final ByteBuffer buffer =
@@ -286,7 +287,6 @@ void writeFragment(final DirectBuffer buffer, final Header header)
         }
     }
 
-
     public void close()
     {
         if (closed)
@@ -446,7 +446,7 @@ private void validateStartTermOffset(final int termOffset)
     {
         if (VALIDATE_POSITION_ASSUMPTIONS)
         {
-            final int expectedStartTermOffset = (int) (joinPosition & (termBufferLength - 1));
+            final int expectedStartTermOffset = (int)(joinPosition & (termBufferLength - 1));
             if (expectedStartTermOffset != termOffset)
             {
                 throw new IllegalStateException();
@@ -462,6 +462,7 @@ private void validateWritePreConditions(final int termId, final int termOffset)
             {
                 throw new IllegalStateException();
             }
+
             final int recordingOffset = recordingOffset(
                 termOffset,
                 termId,
@@ -492,7 +493,7 @@ static class RecordingContext
         private File archiveDir;
         private EpochClock epochClock;
         private boolean forceWrites = true;
-        private int segmentFileLength = 128 * 1024 * 1024;
+        private int segmentFileLength = 1024 * 1024 * 1024;
 
         RecordingContext archiveDir(final File archiveDir)
         {

aeron-archiver/src/main/java/io/aeron/archiver/ReplaySession.java

@@ -46,8 +46,7 @@
  * <li>Stream recorded data into the replayPublication {@link ExclusivePublication}</li>
  * </ul>
  */
-class ReplaySession
-    implements Session, RecordingFragmentReader.SimplifiedControlledPoll
+class ReplaySession implements Session, RecordingFragmentReader.SimplifiedControlledPoll
 {
     enum State
     {

aeron-archiver/src/main/java/io/aeron/archiver/Session.java

@@ -13,7 +13,6 @@
  * limitations under the License.
  *
  */
-
 package io.aeron.archiver;
 
 /**

aeron-archiver/src/main/java/io/aeron/archiver/SessionWorker.java

@@ -13,7 +13,6 @@
  * limitations under the License.
  *
  */
-
 package io.aeron.archiver;
 
 import org.agrona.collections.ArrayListUtil;

aeron-archiver/src/main/java/io/aeron/archiver/SharedModeArchiveConductor.java

@@ -13,7 +13,6 @@
  * limitations under the License.
  *
  */
-
 package io.aeron.archiver;
 
 import io.aeron.Aeron;