xan/awips2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

ASM #349 - Workaround for QPID-5569

Browse source 
Change-Id: I1f39f73b899dadc04e9c592de8b087a5545da9ce

Former-commit-id: d7db4bf632 [formerly b8aadf1781] [formerly 103fece7b7] [formerly 103fece7b7 [formerly 2c1a3442d6]] [formerly d7db4bf632 [formerly b8aadf1781] [formerly 103fece7b7] [formerly 103fece7b7 [formerly 2c1a3442d6]] [formerly a58f3cb7df [formerly 103fece7b7 [formerly 2c1a3442d6] [formerly a58f3cb7df [formerly 18d692c17ea11537d0eb832fbe63a04b59b0040c]]]]]
Former-commit-id: a58f3cb7df
Former-commit-id: a1738767f4 [formerly 951bd668ae] [formerly 91b22ff9bb] [formerly f2e81550b0af2068d152eb149f81e903079629fe [formerly 38bf85175bedb3976ea85ab928e8bdea8f6e4a64] [formerly 91b22ff9bb [formerly 2a4a92c223]]]
Former-commit-id: 9085352f659bfa05328334cffbd2b49251e97a23 [formerly e4fe776694b8d4beb5605017347016019fb2ec75] [formerly 2eb0b3dfb0 [formerly ab5f533c72]]
Former-commit-id: 2eb0b3dfb0
Former-commit-id: 87ed26568e
This commit is contained in:
David Friedman 2014-03-07 14:58:09 +00:00
parent a7c3399e93
commit c00bffe1f9
2 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
edexOsgi/com.raytheon.uf.tools.cli/impl/src/qpidNotify/mhsAckNotify.py
View file

@ -8,6 +8,7 @@
# 04/06/2012 10388 D. Friedman Initial version
# 10/09/12 DR 13901 D. Friedman Limit execution time
# 06/13/2013 DR 16242 D. Friedman Add Qpid authentication info
# 03/06/2014 DR 17907 D. Friedman Workaround for issue QPID-5569
##############################################################################
import getopt
@ -53,7 +54,8 @@ def send_message(connection, notif):
props = session.delivery_properties(routing_key=TOPIC_NAME)
head = session.message_properties(application_headers={'sender':notif.sender,
'response':notif.response})
'response':notif.response},
user_id=QPID_USERNAME) # For issue QPID-5569. Fixed in Qpid 0.27
session.message_transfer(destination=DESTINATION, message=Message(props, head, notif.messageId))
session.close(timeout=10)
connection.close()

4
pythonPackages/ufpy/qpidingest.py
View file

@ -58,6 +58,7 @@
# ------------ ---------- ----------- --------------------------
# ....
# 06/13/2013 DR 16242 D. Friedman Add Qpid authentication info
# 03/06/2014 DR 17907 D. Friedman Workaround for issue QPID-5569
#
#===============================================================================
@ -97,7 +98,8 @@ class IngestViaQPID:
@param header: string header used to determine plugin decoder to use
'''
props = self.session.delivery_properties(routing_key='external.dropbox')
head = self.session.message_properties(application_headers={'header':header})
head = self.session.message_properties(application_headers={'header':header},
user_id=QPID_USERNAME) # For issue QPID-5569. Fixed in Qpid 0.27
self.session.message_transfer(destination='amq.direct', message=Message(props, head, filepath))
def close(self):