Use snake case for message generator

docs/source/rabbitmq-tutorial/examples/7-publisher-confirms/publish_asynchronously.py

@@ -5,7 +5,7 @@
 from aiormq.exceptions import DeliveryError
 
 
-def getMessagesToPublish():
+def get_messages_to_publish():
     for i in range(10000):
         yield f"Hello World {i}!".encode()
 
@@ -38,7 +38,7 @@ async def main() -> None:
 
         async with asyncio.TaskGroup() as tg:
             # Sending the messages
-            for msg in getMessagesToPublish():
+            for msg in get_messages_to_publish():
                 tg.create_task(
                     channel.default_exchange.publish(
                         Message(msg),

docs/source/rabbitmq-tutorial/examples/7-publisher-confirms/publish_batches.py

@@ -3,7 +3,7 @@
 from aio_pika import Message, connect
 
 
-def getMessagesToPublish():
+def get_messages_to_publish():
     for i in range(10000):
         yield f"Hello World {i}!".encode()
 
@@ -23,7 +23,7 @@ async def main() -> None:
         outstanding_messages = []
 
         # Sending the messages
-        for msg in getMessagesToPublish():
+        for msg in get_messages_to_publish():
             outstanding_messages.append(
                 channel.default_exchange.publish(
                     Message(msg),

docs/source/rabbitmq-tutorial/examples/7-publisher-confirms/publish_individually.py

@@ -3,7 +3,7 @@
 from aio_pika import Message, connect
 
 
-def getMessagesToPublish():
+def get_messages_to_publish():
     for i in range(10000):
         yield f"Hello World {i}!".encode()
 
@@ -20,7 +20,7 @@ async def main() -> None:
         queue = await channel.declare_queue("hello")
 
         # Sending the messages
-        for msg in getMessagesToPublish():
+        for msg in get_messages_to_publish():
             # Waiting for publisher confirmation with timeout for every message
             await channel.default_exchange.publish(
                 Message(msg),