Fixed wrong host for ZMQ broker. (#379)

s3rius · web-flow · commit 317c1d92e2ae · 2024-11-20T17:06:44.000+01:00
diff --git a/taskiq/brokers/zmq_broker.py b/taskiq/brokers/zmq_broker.py
@@ -77,7 +77,7 @@ async def kick(self, message: BrokerMessage) -> None:
             ]
             for idx in range(math.ceil(len(message.message) / part_len))
         ]
-        with self.socket.connect(self.sub_host) as sock:
+        with self.socket.connect(self.pub_host) as sock:
             await sock.send_multipart(parts)
 
     async def listen(self) -> AsyncGenerator[bytes, None]:

Original file line number	Diff line number	Diff line change
`@@ -77,7 +77,7 @@ async def kick(self, message: BrokerMessage) -> None:`
`77`	`77`	`]`
`78`	`78`	`for idx in range(math.ceil(len(message.message) / part_len))`
`79`	`79`	`]`
`80`		`- with self.socket.connect(self.sub_host) as sock:`
	`80`	`+ with self.socket.connect(self.pub_host) as sock:`
`81`	`81`	`await sock.send_multipart(parts)`
`82`	`82`
`83`	`83`	`async def listen(self) -> AsyncGenerator[bytes, None]:`