# File gofer/messaging/broker.rb, line 49 def connect() if @connection.nil? s = TCPSocket.new(@url.host(), @url.port()) @connection = Qpid::Connection.new(s) @connection.start(10) end return @connection end