ACKs are now correctly allocated to channels

slightly modify the SampleConsumer to make it easier to use as a base
for these kind of tests

Author: Anthchirp

src/workflows/services/sample_consumer.py

@@ -24,13 +24,13 @@ def consume_message(self, header, message):
         t = (time.time() % 1000) * 1000
 
         if header:
-            header = json.dumps(header, indent=2) + "\n" + "----------------" + "\n"
+            header_str = json.dumps(header, indent=2) + "\n" + "----------------" + "\n"
         else:
-            header = ""
+            header_str = ""
         if isinstance(message, dict):
             message = json.dumps(message, indent=2) + "\n" + "----------------" + "\n"
 
         self.log.info(
-            f"=== Consume ====\n{header}{message}\nReceived message @{t:10.3f} ms"
+            f"=== Consume ====\n{header_str}{message}\nReceived message @{t:10.3f} ms"
         )
         time.sleep(0.1)

src/workflows/transport/pika_transport.py

@@ -826,10 +826,6 @@ def subscribe_queue(
         if not self._connection:
             raise RuntimeError("Cannot subscribe to unstarted connection")
 
-        # Safety: Since our Ack interface doesn't ask consumer ID yet, we can't ack
-        if not auto_ack and prefetch_count != 0:
-            raise ValueError("Cannot turn on manual acknowledgements with prefetch > 0")
-
         new_sub = _PikaSubscription(
             arguments={},
             auto_ack=auto_ack,