[Java] Rename IngressAdapter onFragment to onMessage and remove inter…

…face to provide more appropriate naming.

aeron-cluster/src/main/java/io/aeron/cluster/IngressAdapter.java

@@ -24,7 +24,7 @@
 import org.agrona.DirectBuffer;
 import org.agrona.collections.ArrayUtil;
 
-class IngressAdapter implements ControlledFragmentHandler, AutoCloseable
+class IngressAdapter implements AutoCloseable
 {
     private final int fragmentPollLimit;
     private final MessageHeaderDecoder messageHeaderDecoder = new MessageHeaderDecoder();
@@ -34,7 +34,7 @@ class IngressAdapter implements ControlledFragmentHandler, AutoCloseable
     private final SessionKeepAliveDecoder sessionKeepAliveDecoder = new SessionKeepAliveDecoder();
     private final ChallengeResponseDecoder challengeResponseDecoder = new ChallengeResponseDecoder();
     private final AdminRequestDecoder adminRequestDecoder = new AdminRequestDecoder();
-    private final ControlledFragmentAssembler fragmentAssembler = new ControlledFragmentAssembler(this);
+    private final ControlledFragmentAssembler fragmentAssembler = new ControlledFragmentAssembler(this::onMessage);
     private final ConsensusModuleAgent consensusModuleAgent;
     private Subscription subscription;
     private Subscription ipcSubscription;
@@ -67,7 +67,8 @@ public void close()
     }
 
     @SuppressWarnings("MethodLength")
-    public Action onFragment(final DirectBuffer buffer, final int offset, final int length, final Header header)
+    public ControlledFragmentHandler.Action onMessage(
+        final DirectBuffer buffer, final int offset, final int length, final Header header)
     {
         messageHeaderDecoder.wrap(buffer, offset);
 
@@ -194,7 +195,7 @@ public Action onFragment(final DirectBuffer buffer, final int offset, final int
             }
         }
 
-        return Action.CONTINUE;
+        return ControlledFragmentHandler.Action.CONTINUE;
     }
 
     void connect(final Subscription subscription, final Subscription ipcSubscription)

aeron-cluster/src/test/java/io/aeron/cluster/IngressAdapterTest.java

@@ -62,7 +62,7 @@ void shouldDelegateToConsensusModuleAgent(
 
         final int length = MessageHeaderDecoder.ENCODED_LENGTH + blockLength;
 
-        adapter.onFragment(buffer, 0, length, null);
+        adapter.onMessage(buffer, 0, length, null);
 
         expectation.expect(verify(consensusModuleAgent), buffer);
     }