Skip to content

Commit 8f07ab6

Browse files
author
Michael Klishin
committed
Match Pika example in output
This is what test.py expects
1 parent ed8aa9f commit 8f07ab6

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

ruby/rpc_server.rb

+4
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,8 @@ def start(queue_name)
2222
n = payload.to_i
2323
r = self.class.fib(n)
2424

25+
puts " [.] fib(#{n})"
26+
2527
@x.publish(r.to_s, :routing_key => properties.reply_to, :correlation_id => properties.correlation_id)
2628
end
2729
end
@@ -44,4 +46,6 @@ def self.fib(n)
4446
rescue Interrupt => _
4547
ch.close
4648
conn.close
49+
50+
exit(0)
4751
end

0 commit comments

Comments
 (0)