Correct parameter ordering

Author: rossdanderson

examples/spring-java/src/main/java/example/StreamsController.java

@@ -47,7 +47,7 @@ public Flux<Payload> userStream(
       @IngressDestinationVariable(token = IngressToken.USER_ID) String userId,
       @DestinationVariable String parameter1,
       @DestinationVariable int parameter2) {
-    return createPayloadFlux(null, userId, parameter1, parameter2);
+    return createPayloadFlux(userId, null, parameter1, parameter2);
   }
 
   /**
@@ -64,7 +64,7 @@ public Flux<Payload> sessionStream(
       @IngressDestinationVariable(token = IngressToken.PERSISTENT_SESSION_ID) String sessionId,
       @DestinationVariable String parameter1,
       @DestinationVariable int parameter2) {
-    return createPayloadFlux(sessionId, userId, parameter1, parameter2);
+    return createPayloadFlux(userId, sessionId, parameter1, parameter2);
   }
 
   /**

examples/spring-kotlin/src/main/kotlin/example/StreamsController.kt

@@ -48,7 +48,7 @@ class StreamsController {
       @IngressDestinationVariable(IngressToken.USER_ID) userId: String,
       @DestinationVariable parameter1: String,
       @DestinationVariable parameter2: Int,
-  ) = createPayloadFlow(null, userId, parameter1, parameter2)
+  ) = createPayloadFlow(userId, null, parameter1, parameter2)
 
   /**
    * Streams an infinite sequence of Payload objects, where each payload contains an incrementing
@@ -65,7 +65,7 @@ class StreamsController {
       @IngressDestinationVariable(IngressToken.PERSISTENT_SESSION_ID) sessionId: String,
       @DestinationVariable parameter1: String,
       @DestinationVariable parameter2: Int,
-  ) = createPayloadFlow(sessionId, userId, parameter1, parameter2)
+  ) = createPayloadFlow(userId, sessionId, parameter1, parameter2)
 
   /**
    * Streams a sequence of [ContainerEvent]s of [Payload] objects.

reactive/core/src/main/kotlin/com/caplin/integration/datasourcex/reactive/core/Binder.kt

@@ -634,7 +634,6 @@ private constructor(val dataSource: ScopedDataSource, private val serviceInfo: S
                                       }
                                     }
                                   }
-
                               publish(containerMessage)
                             }
                       } finally {