Sha256: edbb6a5d8db387d31963b9d85cac7fcaadd8b885b52b9bea91c46a9a4d2cead6
Contents?: true
Size: 332 Bytes
Versions: 24
Compression:
Stored size: 332 Bytes
Contents
#!/usr/bin/env ruby
# encoding: utf-8
# Each connection respond to a TCP connection,
# hence we need to use more client.connect calls.
Thread.new do
AMQ::Client::SocketClient.connect(:port => 5672) do |client|
# ...
end
end
Thread.new do
AMQ::Client::SocketClient.connect(:port => 5672) do |client|
# ...
end
end
Version data entries
24 entries across 24 versions & 1 rubygems