Skip to content

Communication Example

12 Communication Modules

Part of 400+ modules with 12 enterprise messaging modules including Kafka, RabbitMQ, and Redis Pub/Sub. See Communication Documentation.

Python
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
import logging

logger = logging.getLogger(__name__)

from agenticaiframework.communication import CommunicationManager

# Example: Using the CommunicationManager
# ----------------------------------------
# This example demonstrates how to:
# 1. Create a CommunicationManager
# 2. Send and receive messages
#
# Expected Output:
# - Logs showing messages being sent and received

if __name__ == "__main__":
    # Create a communication manager
    comm_manager = CommunicationManager()

    # Define a simple message handler
    def message_handler(message):
        logger.info(f"Received message: {message}")

    # Register the handler
    comm_manager.register_handler(message_handler)

    # Send a message
    comm_manager.send_message("Hello from CommunicationManager!")