Merge "Fix case error in qpid exchange name. s/Direct/direct/"
This commit is contained in:
commit
e2ecb42786
@ -285,7 +285,7 @@ class DirectPublisher(Publisher):
|
||||
def __init__(self, conf, session, msg_id):
|
||||
"""Init a 'direct' publisher."""
|
||||
super(DirectPublisher, self).__init__(session, msg_id,
|
||||
{"type": "Direct"})
|
||||
{"type": "direct"})
|
||||
|
||||
|
||||
class TopicPublisher(Publisher):
|
||||
|
Loading…
Reference in New Issue
Block a user