[Java] Provide error message in the absence of sessionMessageListener

rbsysnn · Jun 22, 2018 · d79759c · d79759c
1 parent 66268a5
commit d79759c
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/client/AeronCluster.java b/aeron-cluster/src/main/java/io/aeron/cluster/client/AeronCluster.java
@@ -837,6 +837,16 @@ public void conclude()
             {
                 credentialsSupplier = new NullCredentialsSupplier();
             }
+
+            if (null == sessionMessageListener)
+            {
+                sessionMessageListener =
+                    (correlationId, clusterSessionId, timestamp, buffer, offset, length, header) ->
+                    {
+                        throw new IllegalStateException(
+                            "sessionMessageListener must be specified on AeronCluster.Context");
+                    };
+            }
         }
 
         /**