А黑
Size: a a a
А黑
c🦊
PG
string:next_grapheme/1
?SP
<<C/utf8, Tail/binary>>
ИИ
<<C/utf8, Tail/binary>>
А黑
SP
SP
<<C/utf8>>
:)SP
unicode:characters_to_binary([C])
А黑
ИИ
DP
start_consumer( Pid, XName, Consumer, RoutingKey ) ->
{ok, Channel} = amqp_connection:open_channel(Pid),
QName = <<"bp_api", (atom_to_binary(Consumer,latin1))>>,
Queue = #'queue.declare'{
queue = QName,
durable = true,
exclusive = false
},
#'queue.declare_ok'{} = amqp_channel:call(Channel, Queue),
Binding = #'queue.bind'{queue = QName,
exchange = XName,
routing_key = RoutingKey },
#'queue.bind_ok'{} = amqp_channel:call(Channel, Binding),
#'basic.consume_ok'{consumer_tag = _Tag} = amqp_channel:subscribe(Channel, (#'basic.consume'{queue = QName}), Consumer:arbeiten ).
PG
Consumer:arbeiten()
PG
fun Consumer:arbeiten/arity
EK
<<"bp_api", (atom_to_binary(Consumer,latin1))>>
— это badarg выдастEK
<<"bp_api", (atom_to_binary(Consumer,latin1))/binary>>
` надо