Vh$ddlmZmZmZeZdZdZddlZddl Z dZ ddl Z dZ ddlmZmZddlmZdd lmZd Zd Zed k(reyy#e $re jZ dZ YBwxYw) )absolute_importdivisionprint_functiona --- module: rabbitmq_queue author: Manuel Sousa (@manuel-sousa) short_description: Manage rabbitMQ queues description: - This module uses rabbitMQ Rest API to create/delete queues. - Due to limitations in the API, it cannot modify existing queues. requirements: [ "requests >= 1.0.0" ] options: name: description: - Name of the queue. type: str required: true state: description: - Whether the queue should be present or absent. type: str choices: [ "present", "absent" ] default: present durable: description: - whether queue is durable or not. type: bool default: true auto_delete: description: - if the queue should delete itself after all queues/queues unbound from it. type: bool default: false message_ttl: description: - How long a message can live in queue before it is discarded (milliseconds). type: int auto_expires: description: - How long a queue can be unused before it is automatically deleted (milliseconds). type: int max_length: description: - How many messages can the queue contain before it starts rejecting. type: int dead_letter_exchange: description: - Optional name of an exchange to which messages will be republished if they - are rejected or expire. type: str dead_letter_routing_key: description: - Optional replacement routing key to use when a message is dead-lettered. - Original routing key will be used if unset. type: str max_priority: description: - Maximum number of priority levels for the queue to support. - If not set, the queue will not support message priorities. - Larger numbers indicate higher priority. type: int arguments: description: - extra arguments for queue. If defined this argument is a key/value dictionary - Arguments here take precedence over parameters. If both are defined, the argument will be used. type: dict default: {} extends_documentation_fragment: - community.rabbitmq.rabbitmq a - name: Create a queue community.rabbitmq.rabbitmq_queue: name: myQueue - name: Create a queue on remote host community.rabbitmq.rabbitmq_queue: name: myRemoteQueue login_user: user login_password: secret login_host: remote.example.org # You may specify different types of queues using the arguments parameter. - name: Create RabbitMQ stream become: yes community.rabbitmq.rabbitmq_queue: name: test-x arguments: x-queue-type: stream x-max-age: 24h NTF) AnsibleModulemissing_required_lib)parse)rabbitmq_argument_specc ||vr||vr|jd|zyy||vr/||||k7r#|jd|d||d||dyy|jd|d||d y) NzwRabbitMQ RESTAPI doesn't support attribute changes for existing queues.Attempting to set %s which is not currently set.)msgz]RabbitMQ RESTAPI doesn't support attribute changes for existing queues. Attempting to change z from 'z' to ''z[RabbitMQ RESTAPI doesn't support attribute changes for existing queues.Attempting to unset z which is currently set to 'z'.) fail_json)module current_args desired_argsarg_names u/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/rabbitmq/plugins/modules/rabbitmq_queue.pycheck_if_arg_changedrys|# | #   HJRS   $ | #H%h)??  HPR^_gRhjvwkAB!@   QY[ghp[qs  c t}|jttdddgdtddtddtd dtdd tdd tdd tddtddd ttd tdd  t|d}|jdd|jdd|jddt j |jdddt j |jdd }ts |jtdttd |jd}tj||jd|jdf|jd|jd|jd f!}|jd"k(rd}|j}n;|jd#k(rd }|j}n|jd$|j%d&d'd(d)d*d+d,}|j!D]4\}} |j||j||jd-| <6|jd.dk(r } n} | s|jd"k(ru|jd.dk(rct#||jd/t#|||jd0|j%D] } t#||d-|jd-| "|j&r.| |d1<|d2<|jd-|d-<|j(d;i|| r|jd.dk(rtj*||jd|jdfd3d4itj,|jd/|jd0|jd-d5|jd|jd|jd f6}np|jd.dk(r^tj.||jd|jdf|jd|jd|jd f!}|jd7k(s|jd8k(rd|d1<|j(d;i|y|jd9|j|j:y|j)d |jdy)r?zError creating queue)r statusrA)r updater rparams urllib_parsequote HAS_REQUESTSr rREQUESTS_IMP_ERRr5get status_codejsontextitemsrvalues check_mode exit_jsonputdumpsdelete) r,rurlresultr queue_existsresponsearg_mapkvadd_or_delete_requiredargs rmainrcs*,M y9h2GeTt%0F3U8T6d7Du5!%d!?$(E%$P467d7 D QF  &' l# l#6==1266==0"5  C 1*=IYZ %fmmF&; ( G =1 ==  ',2MM!,># aC +)> k@Z\_ ` a2y$y$mmK8{"6" == !Y . mmL16==AQ3RS');<ZZ%}}Y7#)==#?!'{!;! }}Y/mmM2FMM,4OP A]]7 #x /6==+F VfHg*h'-}}Y'?v}}UbGcekerersfAGBCA ==C 1==C#7 $F9  F   &v &   *}}   v&  r__main__) __future__rrrr __metaclass__ DOCUMENTATIONEXAMPLESrP tracebackrMr5rL ImportError format_excansible.module_utils.basicrr%ansible.module_utils.six.moves.urllibrrJDansible_collections.community.rabbitmq.plugins.module_utils.rabbitmqr rrc__name__rGrrrpsA@ F P , L KGg,u p zFo+y++-LsA A%$A%