Adding README

Author: DanielePalaia

examples/single_active_consumer/README.md

@@ -0,0 +1,23 @@
+Single active consumer
+---
+
+This is an example to enable single active consumer functionality for superstream:
+https://www.rabbitmq.com/blog/2022/07/05/rabbitmq-3-11-feature-preview-single-active-consumer-for-streams
+https://www.rabbitmq.com/blog/2022/07/13/rabbitmq-3-11-feature-preview-super-streams
+
+This folder contains a super-stream consumer configured to enable it.
+You can use the example in the super-stream folder to produce messages for a super-stream.
+
+You can then run the consumer in this folder.
+Assuming the super-stream is composed by three streams, you can see that the Consumer will consume messages from all the streams part of the superstream.
+
+You can then run another consumer in parallel. 
+now you'll see that one of the two consumers will consume from 2 streams while the other on one stream.
+
+If you run another you'll see that every Consumer will read from a single stream.
+
+If you then stop one of the Consumer you'll notice that the related stream is now read from on the Consumer which is still running.
+
+
+
+

examples/single_active_consumer/single_active_consumer_super_stream.rs

@@ -44,6 +44,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         .super_stream_consumer()
         .offset(OffsetSpecification::First)
         .client_provided_name("my super stream consumer for hello rust")
+        /*We can decide a strategy to manage Offset specification in single active consumer based on is_active flag
+        By default if this clousure is not present the default strategy OffsetSpecification::NEXT will be set.*/
         .consumer_update(move |active, message_context| {
             println!("single active consumer: is active: {} on stream {}", active, message_context.get_stream());
             OffsetSpecification::First