diff options
Diffstat (limited to 'src/rabbit_channel.erl')
| -rw-r--r-- | src/rabbit_channel.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index ca2782c7..4bf2f446 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -265,7 +265,7 @@ handle_method(#'basic.publish'{exchange = ExchangeNameBin, %% certain to want to look at delivery-mode and priority. DecodedContent = rabbit_binary_parser:ensure_content_decoded(Content), PersistentKey = case is_message_persistent(DecodedContent) of - true -> rabbit_misc:guid(); + true -> rabbit_guid:guid(); false -> none end, {noreply, publish(Mandatory, Immediate, @@ -338,7 +338,7 @@ handle_method(#'basic.consume'{queue = QueueNameBin, QueueName = expand_queue_name_shortcut(QueueNameBin, State), ActualConsumerTag = case ConsumerTag of - <<>> -> rabbit_misc:binstring_guid("amq.ctag"); + <<>> -> rabbit_guid:binstring_guid("amq.ctag"); Other -> Other end, @@ -550,7 +550,7 @@ handle_method(#'queue.declare'{queue = QueueNameBin, {error, not_found} -> ActualNameBin = case QueueNameBin of - <<>> -> rabbit_misc:binstring_guid("amq.gen"); + <<>> -> rabbit_guid:binstring_guid("amq.gen"); Other -> check_name('queue', Other) end, QueueName = rabbit_misc:r(VHostPath, queue, ActualNameBin), @@ -751,7 +751,7 @@ ack(ProxyPid, TxnKey, UAQ) -> [QPid | L] end, [], UAQ). -make_tx_id() -> rabbit_misc:guid(). +make_tx_id() -> rabbit_guid:guid(). new_tx(State) -> State#ch{transaction_id = make_tx_id(), |