qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Wolgemuth Greg <woo...@eseri.com>
Subject Difficulties with QMFv2 Python bindings
Date Thu, 07 Oct 2010 17:57:02 GMT
I'm working with a build from SVN trunk, and am trying to use the Python
QMFv2 bindings. I've been starting with the example provided (agent.py),
and then moving on to try and get a functional console, but have had
some difficulties.

First, the agent example as provided fails to function correctly, and
outputs the following:

2010-10-07 21:52:22 warning Exception received from broker: not-found:
not-found: Queue not found: qmf.default.direct
(qpid/broker/SessionAdapter.cpp:752) [caused by 2 \x08:\x01]
Traceback (most recent call last):
  File "./example_agent.py", line 145, in <module>
    agent = ExampleAgent("fed1.lab.eseri.net")
  File "./example_agent.py", line 47, in __init__
    self.session.open()
  File "/usr/lib/python2.6/site-packages/qmf2.py", line 229, in open
    self._impl.open()
  File "/usr/lib/python2.6/site-packages/cqmf2.py", line 246, in open
    def open(self): return _cqmf2.AgentSession_open(self)
RuntimeError: Queue qmf.default.direct does not exist
Segmentation fault

I've tried looking through the qmf2.py source to understand how to
create a Console, and came up with this as a simple proof of concept:

import cqpid
from qmf2 import *

connection = cqpid.Connection("fed1.lab.eseri.net")
connection.open()

myconsole = ConsoleSession(connection)
myconsole.open()
print myconsole.getAgents()

When run, it outputs the following:

2010-10-07 21:50:15 warning Exception received from broker: not-found:
not-found: Exchange not found: qmf.default.direct
(qpid/broker/ExchangeRegistry.cpp:90) [caused by 2 \x07:\x01]
Traceback (most recent call last):
  File "./console.py", line 24, in <module>
    myconsole.open()
  File "/usr/lib/python2.6/site-packages/qmf2.py", line 166, in open
    self._impl.open()
  File "/usr/lib/python2.6/site-packages/cqmf2.py", line 314, in open
    def open(self): return _cqmf2.ConsoleSession_open(self)
RuntimeError: Exchange qmf.default.direct does not exist

I found that by using the messaging library, I can create the
"qmf.default.direct" and "qmf.default.topic" exchanges by hand before
opening the console session, and the console appears to work (although
getAgents never returns any values)

However, if I then run the agent example, with the qmf exchanges created
by the console, I get this output instead:

./example_agent.py 
Traceback (most recent call last):
  File "./example_agent.py", line 145, in <module>
    agent = ExampleAgent("broker.example.org")
  File "./example_agent.py", line 47, in __init__
    self.session.open()
  File "/usr/lib/python2.6/site-packages/qmf2.py", line 229, in open
    self._impl.open()
  File "/usr/lib/python2.6/site-packages/cqmf2.py", line 246, in open
    def open(self): return _cqmf2.AgentSession_open(self)
RuntimeError: Ambiguous address, please specify queue or topic as node
type
Segmentation fault

It seems like my difficulties are centred around not having the
qmf.default.* exchanges set up correctly. Am I wrong in thinking that
the QMF libraries ought to be declaring/asserting these exchanges
automatically, the same way the QMF queues are created? If not, I'd
appreciate a couple of lines I could use with the messaging API to
create the exchanges with the correct options/settings.

Greg


---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org


Mime
View raw message