Browse Source

Only push binary data to aiopika (Fixes #1513)

pull/1514/head
Miguel Grinberg 8 months ago
parent
commit
967c18455b
Failed to extract signature
  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