From: Christopher <chris@entropealabs.com>
Date: Fri, 17 Apr 2020 01:40:59 +0000 (-0500)
Subject: remove large messages after processing
X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=e06769470d1954a9c71a366bbab221e6c4eae0d8;p=wampex_router.git

remove large messages after processing
---

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