File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -62,8 +62,9 @@ async def kick(self, message: BrokerMessage) -> None:
62
62
63
63
:param message: message to send.
64
64
"""
65
+ queue_name = message .labels .get ("queue_name" ) or self .queue_name
65
66
async with Redis (connection_pool = self .connection_pool ) as redis_conn :
66
- await redis_conn .publish (self . queue_name , message .message )
67
+ await redis_conn .publish (queue_name , message .message )
67
68
68
69
async def listen (self ) -> AsyncGenerator [bytes , None ]:
69
70
"""
@@ -97,8 +98,9 @@ async def kick(self, message: BrokerMessage) -> None:
97
98
98
99
:param message: message to append.
99
100
"""
101
+ queue_name = message .labels .get ("queue_name" ) or self .queue_name
100
102
async with Redis (connection_pool = self .connection_pool ) as redis_conn :
101
- await redis_conn .lpush (self . queue_name , message .message )
103
+ await redis_conn .lpush (queue_name , message .message )
102
104
103
105
async def listen (self ) -> AsyncGenerator [bytes , None ]:
104
106
"""
You can’t perform that action at this time.
0 commit comments