Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Support headers in queue_declare function #174

Open
wants to merge 12 commits into
base: main
Choose a base branch
from
Open

Support headers in queue_declare function #174

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
0d1626e
add arguments
V4UIDev Jul 19, 2024
fc7a10e
Merge branch 'ansible-collections:main' into main
V4UIDev Aug 27, 2024
2d26a62
Uncomment integration test
V4UIDev Oct 18, 2024
5661e38
tweak test
V4UIDev Oct 18, 2024
4e0da3e
tweak
V4UIDev Oct 18, 2024
d8a5835
integration test changes and changelog frag
V4UIDev Oct 18, 2024
114ab6f
change headers
V4UIDev Oct 18, 2024
bb4e154
put change into fragment
V4UIDev Oct 23, 2024
fa36907
lint
V4UIDev Oct 23, 2024
3f2ce68
cloudsmith moved to ppa1 address
V4UIDev Oct 23, 2024
534e1f7
try with community key
V4UIDev Oct 23, 2024
1b4ccd5
revert change to repo
V4UIDev Oct 23, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions changelogs/fragments/174-support-headers-publish.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
bugfixes:
- rabbitmq_publish - fix support for publishing headers as a part of a message (https://github.com/ansible-collections/community.rabbitmq/pull/174/)
6 changes: 4 additions & 2 deletions plugins/module_utils/rabbitmq.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -190,14 +190,16 @@ def basic_publish(self):
result = self.conn_channel.queue_declare(queue='',
durable=self.params.get("durable"),
exclusive=self.params.get("exclusive"),
auto_delete=self.params.get("auto_delete"))
auto_delete=self.params.get("auto_delete"),
arguments=self.params.get("headers"))
self.conn_channel.confirm_delivery()
self.queue = result.method.queue
elif self.queue is not None and self.exchange is None:
self.conn_channel.queue_declare(queue=self.queue,
durable=self.params.get("durable"),
exclusive=self.params.get("exclusive"),
auto_delete=self.params.get("auto_delete"))
auto_delete=self.params.get("auto_delete"),
arguments=self.params.get("headers"))
self.conn_channel.confirm_delivery()
except Exception as e:
self.module.fail_json(msg="Queue declare issue: %s" % to_native(e))
Expand Down
8 changes: 4 additions & 4 deletions tests/integration/targets/rabbitmq_publish/tasks/ubuntu.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -179,10 +179,10 @@
- "'image/gif' in messages[1]['content_type']"
- "'image.gif' in messages[1]['headers']['filename']"
- "'Testing with proto/host/port/username/password/vhost' in messages[2]['msg']"
# - messages[3]['headers']['myHeader'] is defined
# - messages[4]['headers']['filename'] is defined
# - messages[4]['headers']['secondHeader'] is defined
#
- messages[4]['headers']['myHeader'] is defined
- messages[4]['headers']['secondHeader'] is defined
- "'Value2' in messages[4]['headers']['secondHeader']"


- name: Check that queue and exchange are mutually exclusive
rabbitmq_publish:
Expand Down
Loading