lib/rrj/janus/transactions/transaction.rb in ruby_rabbitmq_janus-2.6.0.pre.247 vs lib/rrj/janus/transactions/transaction.rb in ruby_rabbitmq_janus-2.6.0.pre.258
- old
+ new
@@ -28,21 +28,21 @@
:exclusive
def choose_queue
chan = @rabbit.channel
@publisher = if @exclusive
- Tools::Log.instance.debug \
+ ::Log.debug \
'Choose an queue Exclusive : ampq.gen-xxx'
Rabbit::Publisher::Exclusive.new(chan, '')
else
- Tools::Log.instance.debug \
+ ::Log.debug \
'Choose an queue non Exclusive : to-janus'
Rabbit::Publisher::NonExclusive.new(chan)
end
end
def send_a_message
- Tools::Log.instance.info 'Publish a message ...'
+ ::Log.info 'Publish a message ...'
response = read_response(@publisher.publish(yield))
Janus::Responses::Standard.new(response)
end
def read_response(publish)