Uploaded image for project: 'Qpid'
  1. Qpid
  2. QPID-8075

BrokerAgent not working for me



    • Type: Bug
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: qpid-cpp-1.37.0
    • Fix Version/s: qpid-cpp-1.38.0
    • Component/s: QMF
    • Labels:
    • Environment:


      1. Start qpidd and verify that it starts
      2. Verify it's listening on 5762 using `sudo netstat -planet | grep 5672`
      3. Telnet connect to it with `telnet localhost 5672` observe that it connects

      Try to connect it to with qmf.BrokerAgent

      from qmf.client import BrokerAgent, ReconnectDelays
      conn_opts =

      {'url': 'amqp://localhost:5672'}

      ba = BrokerAgent.connect(**conn_opts)

      I get this exception after 10 seconds:

      File "/home/vagrant/devel/kombu/kombu/transport/qpid.py", line 586, in exchange_declare
      self._broker.addExchange(type, exchange, options)
      File "/home/vagrant/.virtualenvs/pulp/lib64/python3.5/site-packages/qmf/client.py", line 344, in addExchange
      self._method('create', args)
      File "/home/vagrant/.virtualenvs/pulp/lib64/python3.5/site-packages/qmf/client.py", line 233, in _method
      response = self._retry(self._request, '_method_request', content)
      File "/home/vagrant/.virtualenvs/pulp/lib64/python3.5/site-packages/qmf/client.py", line 215, in _retry
      return f(*args, **kwargs)
      File "/home/vagrant/.virtualenvs/pulp/lib64/python3.5/site-packages/qmf/client.py", line 224, in _request
      return self._client.call(Message(body=content, properties=props, subject="broker"))
      File "/home/vagrant/.virtualenvs/pulp/lib64/python3.5/site-packages/qmf/client.py", line 118, in call
      return self.wait(self.send(request))
      File "/home/vagrant/.virtualenvs/pulp/lib64/python3.5/site-packages/qmf/client.py", line 137, in wait
      self.connection.wait(wakeup, msg="Waiting for response")
      File "/home/vagrant/.virtualenvs/pulp/lib64/python3.5/site-packages/proton/utils.py", line 292, in wait
      raise Timeout(txt)
      proton.Timeout: Connection amqp://localhost:5672 timed out: Waiting for response

      What is interesting is that on the same system with simply_send.py (the standard example) it connects and sends with the exact same url. I do that with this:

      (pulp) [vagrant@pulp3 devel]$ python simple_send.py --address 'amqp://localhost:5672' -m 1
      all messages confirmed

      The 'all messages confirmed' suggests that everything went fine and the reactor called on_accepted().

      So I conclude that BrokerAgent is somehow fundamentally not working or my environment is screwed up somehow.

      This same commit checkout was working with Python 2.7. I don't have that environment handy currently, but I suspect this is somehow broken with Python 3.




            • Assignee:
              kpvdr Kim van der Riet
              bmbouter Brian Bouterse
            • Votes:
              0 Vote for this issue
              4 Start watching this issue


              • Created: