Use Postfix to determine sender/receiver

Author: MarcialRosales

deps/rabbitmq_shovel/src/rabbit_amqp10_shovel.erl

@@ -126,30 +126,21 @@ connect(Name, SndSettleMode, Uri, Postfix, Addr, Map, AttachFun) ->
     % needs to be sync, i.e. awaits the 'attach' event as
     % else we may try to use the link before it is ready
     Durability = maps:get(durability, Map, unsettled_state),
-    AttachArgs = case Postfix of 
-        "sender" -> 
-            SenderCapabilities = maps:get(sender_capabilities, Map, undefined),   
-            #{
-                name => LinkName,
-                role => {sender, #{address => Addr,
-                                    durable => Durability,
-                                    capabilities => SenderCapabilities}},
-                snd_settle_mode => SndSettleMode,
-                rcv_settle_mode => first
-            };
-        "receiver" ->
-            ReceiverCapabilities = maps:get(receiver_capabilities, Map, undefined),
-            #{
-                name => LinkName,
-                role => {receiver, #{address => Addr,
-                                    durable => Durability,
-                                    capabilities => ReceiverCapabilities}, self()},
-                snd_settle_mode => SndSettleMode,
-                rcv_settle_mode => first,
-                filter => #{},
-                properties => #{}
-            }   
-        end,
+    LinkCapabilities = maps:get(
+        case Postfix of 
+            "sender" -> sender_capabilities;
+            "receiver" -> receiver_capabilities
+        end, Map, undefined),   
+    AttachArgs = #{
+        name => LinkName,
+        role => {binary_to_term(list_to_binary(Postfix)), 
+                 #{address => Addr,
+                    durable => Durability,
+                    capabilities => LinkCapabilities}
+                },
+        snd_settle_mode => SndSettleMode,
+        rcv_settle_mode => first
+    },       
     {ok, LinkRef} = AttachFun(Sess, AttachArgs),                                         
     {Conn, Sess, LinkRef}.