feat(publish): Less strictness regarding outgoing message types

amsross · Mar 17, 2020 · 003b83c · 003b83c
1 parent 19c97e3
commit 003b83c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/AmqpConnectionManager.re b/src/AmqpConnectionManager.re
@@ -82,7 +82,7 @@ module ChannelWrapper = {
 
   [@bs.send]
   external publish':
-    (t, Exchange.name, routingKey, Js.Json.t, Js.t('options)) =>
+    (t, Exchange.name, routingKey, 'message, Js.t('options)) =>
     Js.Promise.t(unit) =
     "publish";
 
@@ -91,7 +91,7 @@ module ChannelWrapper = {
 
   [@bs.send]
   external sendToQueue':
-    (t, Queue.name, Js.Json.t, Js.t('options)) => Js.Promise.t(unit) =
+    (t, Queue.name, 'message, Js.t('options)) => Js.Promise.t(unit) =
     "sendToQueue";
 
   let sendToQueue = (t, q, m, o) =>

diff --git a/src/AmqpConnectionManager.rei b/src/AmqpConnectionManager.rei
@@ -63,11 +63,11 @@ module ChannelWrapper: {
     t;
 
   let publish:
-    (t, Exchange.name, routingKey, Js.Json.t, Js.t('options)) =>
-    Js.Promise.t(Js.Json.t);
+    (t, Exchange.name, routingKey, 'message, Js.t('options)) =>
+    Js.Promise.t('message);
 
   let sendToQueue:
-    (t, Queue.name, Js.Json.t, Js.t('options)) => Js.Promise.t(Js.Json.t);
+    (t, Queue.name, 'message, Js.t('options)) => Js.Promise.t('message);
 };
 
 module AmqpConnectionManager: {