Daniele

@andygrunwald Now that we understood what happened in https://github.com/rabbitmq/amqp091-go/issues/18 I think the example you propose can be just like an extension to the example we made in the documentation on...

Sure! good enough! Thanks @andygrunwald

Both cluster operator (v1.14.0) and messaging topology operator (v1.8.0) have been published on operatorhub: https://operatorhub.io/operator/rabbitmq-cluster-operator https://operatorhub.io/operator/rabbitmq-messaging-topology-operator and redhat openshift community ecosystem: https://github.com/redhat-openshift-ecosystem/community-operators-prod/pull/1564 https://github.com/redhat-openshift-ecosystem/community-operators-prod/pull/1565 A github worfklow has been put in...

Also the rabbitmq-single-active-consumer operator got published: https://operatorhub.io/operator/rabbitmq-single-active-consumer-operator https://github.com/redhat-openshift-ecosystem/community-operators-prod/pull/1574 I will close this ticket.

I'll close this issue as at the moment we are not planning this implementation. We are anyway noting this issue in the Performance one so in case in the future...

I made few tests running also the profiler pyroscope on top of it. The tests was quite simple: ``` MESSAGES = 100 list_messages = [] t0 = time.process_time() #print ("Sending...

Hi @qweeze This link when I send 1 milion of AMQPMessage (part commented) https://flamegraph.com/share/a44afb24-a3d2-11ed-b6df-aec0fc79c33f This second link when I send 1 milion of binary messages amqp_message = b'hello' https://flamegraph.com/share/6fb388e7-a3d2-11ed-b6df-aec0fc79c33f This...

@qweeze Thank you for your improvements, I will have a look!

Using the test-encoding-optimization branch with the previous example is generating an exception: ``` Exception in callback BaseClient.start_task..on_task_done(")>) at /Users/dpalaia/projects/rabbitmq-stream-mixing/python/venv/lib/python3.10/site-packages/rstream/client.py:93> Traceback (most recent call last): File "/Users/dpalaia/projects/rabbitmq-stream-mixing/python/venv/lib/python3.10/site-packages/rstream/encoding.py", line 179, in decode_frame...

Hi @qweeze I made a few tests on these new improvements. I was able to gain a few seconds of improvements (like 15%/20% impromevements). On 3 milions of messages sent...