From e06769470d1954a9c71a366bbab221e6c4eae0d8 Mon Sep 17 00:00:00 2001
From: Christopher <chris@entropealabs.com>
Date: Thu, 16 Apr 2020 20:40:59 -0500
Subject: [PATCH] remove large messages after processing

---
 lib/router/session.ex | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/lib/router/session.ex b/lib/router/session.ex
index 6a57c1c..dc81df2 100644
--- a/lib/router/session.ex
+++ b/lib/router/session.ex
@@ -162,7 +162,7 @@ defmodule Wampex.Router.Session do
           {data, [{:next_event, :internal, :abort}]}
       end
 
-    {:ok, data, actions}
+    {:ok, %SL{data | data: %Sess{data.data | message: nil}}, actions}
   end
 
   @impl true
@@ -342,7 +342,7 @@ defmodule Wampex.Router.Session do
           end)
 
           case opts do
-            %{acknowledge: true} ->
+            %{"acknowledge" => true} ->
               send_to_peer(Broker.published(%Published{request_id: rid, publication_id: pub_id}), tt, t)
 
             %{} ->
@@ -356,7 +356,7 @@ defmodule Wampex.Router.Session do
           {sl, [{:next_event, :internal, :transition}]}
       end
 
-    {:ok, data, actions}
+    {:ok, %SL{data | data: %Sess{data.data | publish: nil}}, actions}
   end
 
   @impl true
@@ -535,7 +535,7 @@ defmodule Wampex.Router.Session do
         _ -> true
       end)
 
-    {:ok, %SL{data | data: %Sess{data.data | invocations: inv}}, [{:next_event, :internal, :transition}]}
+    {:ok, %SL{data | data: %Sess{data.data | invocations: inv, yield: nil}}, [{:next_event, :internal, :transition}]}
   end
 
   @impl true
-- 
2.45.3