High-Level Messaging API

def send_message(target, data, auth=None, debug=False):
    """
    Send a single message to AMQP endpoint.

    Parameters:
    - target (str, bytes, or Target): The target AMQP endpoint
    - data (str, bytes, or Message): The contents of the message to send
    - auth (AMQPAuth, optional): Authentication credentials (defaults to SASLAnonymous)
    - debug (bool): Whether to turn on network trace logs

    Returns:
    list[MessageState]: A list of states for each message sent
    """

import uamqp
from uamqp.authentication import SASLPlain

# Send simple string message
target = "amqps://servicebus.example.com/myqueue"
auth = SASLPlain("myuser", "mypassword")
result = uamqp.send_message(target, "Hello World", auth=auth)

# Send custom message object
from uamqp import Message
message = Message("Hello World", properties={'message_id': '123'})
result = uamqp.send_message(target, message, auth=auth)

def receive_message(source, auth=None, timeout=0, debug=False):
    """
    Receive a single message from an AMQP endpoint.

    Parameters:
    - source (str, bytes, or Source): The AMQP source endpoint to receive from
    - auth (AMQPAuth, optional): Authentication credentials (defaults to SASLAnonymous)
    - timeout (int): Timeout in milliseconds (0 = no timeout)
    - debug (bool): Whether to turn on network trace logs

    Returns:
    Message or None: The received message, or None if timeout reached
    """

import uamqp
from uamqp.authentication import SASLPlain

source = "amqps://servicebus.example.com/myqueue"
auth = SASLPlain("myuser", "mypassword")

# Receive with 30 second timeout
message = uamqp.receive_message(source, auth=auth, timeout=30000)
if message:
    print(f"Received: {message.get_data()}")
    message.accept()  # Acknowledge the message
else:
    print("No message received within timeout")

def receive_messages(source, auth=None, max_batch_size=None, timeout=0, debug=False, **kwargs):
    """
    Receive a batch of messages from an AMQP endpoint.

    Parameters:
    - source (str, bytes, or Source): The AMQP source endpoint to receive from
    - auth (AMQPAuth, optional): Authentication credentials (defaults to SASLAnonymous)
    - max_batch_size (int, optional): Maximum number of messages to return
    - timeout (int): Timeout in milliseconds (0 = no timeout)
    - debug (bool): Whether to turn on network trace logs
    - **kwargs: Additional receiver configuration options

    Returns:
    list[Message]: List of received messages (may be empty if timeout reached)
    """

def get_platform_info():
    """
    Get current platform and library information.

    Returns:
    str: Platform information string including library version and platform details
    """

import uamqp
from uamqp.authentication import SASTokenAuth

source = "amqps://servicebus.example.com/myqueue"
token = "SharedAccessSignature sr=..."
auth = SASTokenAuth("servicebus.example.com", token=token)

# Receive up to 10 messages with 5 second timeout
messages = uamqp.receive_messages(
    source, 
    auth=auth, 
    max_batch_size=10, 
    timeout=5000
)

print(f"Received {len(messages)} messages")
for message in messages:
    print(f"Message: {message.get_data()}")
    message.accept()  # Acknowledge each message

import uamqp

# Get platform information
platform_info = uamqp.get_platform_info()
print(f"Platform info: {platform_info}")

# Typical output might include library version, platform, and build info

import uamqp
from uamqp.errors import AMQPConnectionError, AuthenticationException

try:
    message = uamqp.receive_message(source, auth=auth, timeout=10000)
    if message:
        message.accept()
except AMQPConnectionError as e:
    print(f"Connection failed: {e}")
except AuthenticationException as e:
    print(f"Authentication failed: {e}")