Skip to content
Snippets Groups Projects
Commit 5a847944 authored by Auke Klazema's avatar Auke Klazema
Browse files

SW-658: Fix frombus api call that no longer allows acking on a message

parent d5650621
No related branches found
No related tags found
1 merge request!6Import cobalt2 into lofar4
......@@ -139,7 +139,7 @@ def processMessages(receiver, matchPrefix, execPath, msgSaveDir):
finally:
if msg is not None:
receiver.ack(msg) # optional for topics, needed for queues
receiver.ack() # optional for topics, needed for queues
def run(broker, address, matchPrefix, execPath, msgSaveDir):
# Receiver test: qpid-receive -b broker_hostname -a queue_or_exchange_name -f -m 1
......
......@@ -552,7 +552,7 @@ where mom2object.name = %s"""
logger.info("get_project_details for mom_id: %s", mom_id)
query = """SELECT project_role.name, user.email FROM mom2object as project
join member as member on member.projectid=project.id
join member as member on member.projectid=project.ownerprojectid
join registeredmember as registered_member on registered_member.memberid=member.id
join """ + self.useradministration_db + """.useraccount as useraccount on registered_member.userid=useraccount.id
join """ + self.useradministration_db + """.user as user on user.id=useraccount.id
......
......@@ -85,7 +85,7 @@ try:
otdb_connection.query("select setTreeState(1, %d, %d::INT2,'%s')" % (1099266, 500, False))
msg = frombus.receive(timeout=5) # TreeStateEVent are send every 2 seconds
frombus.ack(msg)
frombus.ack()
msg.show()
try:
ok = (msg.body['treeID'] == 1099266 and msg.body['state'] == 'queued')
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment