Enable message compression for RPC
The message compression was enabled to reduce size of messages, that are send to astute. Change-Id: I94b502c73ac59b14f96eb8cca5a6184af9910b79 Implements: blueprint enable-message-compression
This commit is contained in:
parent
955b3b6c15
commit
1c81dd6896
|
@ -88,9 +88,11 @@ def cast(name, message, service=False):
|
|||
use_queue = naily_queue if not service else naily_service_queue
|
||||
use_exchange = naily_exchange if not service else naily_service_exchange
|
||||
with Connection(conn_str) as conn:
|
||||
with conn.Producer(serializer='json') as producer:
|
||||
publish = functools.partial(producer.publish, message,
|
||||
exchange=use_exchange, routing_key=name, declare=[use_queue])
|
||||
with conn.Producer(serializer='json', compression='gzip') as producer:
|
||||
publish = functools.partial(
|
||||
producer.publish, message,
|
||||
exchange=use_exchange, routing_key=name, declare=[use_queue]
|
||||
)
|
||||
try:
|
||||
publish()
|
||||
except amqp_exceptions.PreconditionFailed as e:
|
||||
|
|
Loading…
Reference in New Issue