@@ -187,19 +187,21 @@ async def declare_queues(
187
187
self ._dead_letter_queue_name ,
188
188
** self ._declare_queues_kwargs ,
189
189
)
190
- args : " Dict[str, Any]" = {
190
+ args : Dict [str , Any ] = {
191
191
"x-dead-letter-exchange" : "" ,
192
192
"x-dead-letter-routing-key" : self ._dead_letter_queue_name ,
193
193
}
194
194
if self ._max_priority is not None :
195
195
args ["x-max-priority" ] = self ._max_priority
196
- if "arguments" in self ._declare_queues_kwargs :
197
- args .update (self ._declare_queues_kwargs ["arguments" ])
198
- del self ._declare_queues_kwargs ["arguments" ]
199
196
queue = await channel .declare_queue (
200
197
self ._queue_name ,
201
- arguments = args ,
202
- ** self ._declare_queues_kwargs ,
198
+ ** {
199
+ ** self ._declare_queues_kwargs ,
200
+ "arguments" : {
201
+ ** self ._declare_queues_kwargs .get ("arguments" , {}),
202
+ ** args ,
203
+ },
204
+ },
203
205
)
204
206
if self ._delayed_message_exchange_plugin :
205
207
await queue .bind (
@@ -209,11 +211,14 @@ async def declare_queues(
209
211
else :
210
212
await channel .declare_queue (
211
213
self ._delay_queue_name ,
212
- arguments = {
213
- "x-dead-letter-exchange" : "" ,
214
- "x-dead-letter-routing-key" : self ._queue_name ,
214
+ ** {
215
+ ** self ._declare_queues_kwargs ,
216
+ "arguments" : {
217
+ ** self ._declare_queues_kwargs .get ("arguments" , {}),
218
+ "x-dead-letter-exchange" : "" ,
219
+ "x-dead-letter-routing-key" : self ._queue_name ,
220
+ },
215
221
},
216
- ** self ._declare_queues_kwargs ,
217
222
)
218
223
219
224
await queue .bind (
0 commit comments