From 42a58e21cd97959900c589d7392829158e6b47af Mon Sep 17 00:00:00 2001
From: Tim Gee <writetotimgee@gmail.com>
Date: Mon, 16 Dec 2019 20:29:29 +0000
Subject: [PATCH] Fix input / output confusion

---
 .../trickl/flux/websocket/stomp/StompFluxClient.java  | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/trickl/flux/websocket/stomp/StompFluxClient.java b/src/main/java/com/trickl/flux/websocket/stomp/StompFluxClient.java
index 8d203e0..08138b2 100644
--- a/src/main/java/com/trickl/flux/websocket/stomp/StompFluxClient.java
+++ b/src/main/java/com/trickl/flux/websocket/stomp/StompFluxClient.java
@@ -19,13 +19,14 @@
 import reactor.core.publisher.FluxSink;
 
 @RequiredArgsConstructor
-public class StompFluxClient<I, O> {
+public class StompFluxClient<O, I> {
   private final WebSocketClient webSocketClient;
   private final URI transportUri;
   private final Supplier<HttpHeaders> webSocketHeadersProvider;
   private final ObjectMapper objectMapper;
-  private final Class<I> requestMessageType;
-  private final Class<O> responseMessageType;
+
+  private final Class<O> requestMessageType;
+  private final Class<I> responseMessageType;
 
   /**
    * Connect to a stomp service.
@@ -36,9 +37,9 @@ public class StompFluxClient<I, O> {
   public Flux<StompFrame> get(Publisher<StompFrame> send) {
     StompInputTransformer<I> stompInputTransformer =
         new StompInputTransformer<>(
-            objectMapper, requestMessageType);
+            objectMapper, responseMessageType);
     StompOutputTransformer<O> stompOutputTransformer =
-        new StompOutputTransformer<>(objectMapper, responseMessageType);
+        new StompOutputTransformer<>(objectMapper, requestMessageType);
 
     EmitterProcessor<StompFrame> frameProcessor = EmitterProcessor.create();    
     FluxSink<StompFrame> frameSink = frameProcessor.sink();