Browse Source

Only push binary data to aiopika (Fixes #1513) (#1514)

pull/1515/head
Miguel Grinberg 7 months ago
committed by GitHub
parent
commit
194e1b7f27
No known key found for this signature in database GPG Key ID: B5690EEEBB952194
  1. 2
      src/socketio/async_aiopika_manager.py

2
src/socketio/async_aiopika_manager.py

@ -82,7 +82,7 @@ class AsyncAioPikaManager(AsyncPubSubManager): # pragma: no cover
try: try:
await self.publisher_exchange.publish( await self.publisher_exchange.publish(
aio_pika.Message( aio_pika.Message(
body=json.dumps(data), body=json.dumps(data).encode(),
delivery_mode=aio_pika.DeliveryMode.PERSISTENT delivery_mode=aio_pika.DeliveryMode.PERSISTENT
), routing_key='*', ), routing_key='*',
) )

Loading…
Cancel
Save