QortexMQ.Client 1.3.0

QortexMQ Client

Improved QortexMQ client library with better architecture, error handling, and performance.

Features

• Improved Architecture: Clean separation of concerns with dedicated components
• Better Error Handling: Comprehensive exception handling and recovery
• Automatic Reconnection: Configurable reconnection with exponential backoff
• Thread Safety: Thread-safe operations with proper synchronization
• Performance Optimized: Efficient message processing with configurable concurrency
• Flexible Configuration: Extensive configuration options for different use cases
• Modern C#: Built with .NET 8 and modern C# features
• Comprehensive Logging: Detailed logging with structured logging support

Quick Start

Basic Usage

using QortexMQ;

// Create client
using var client = new QortexMqClient("localhost", 9090);

// Connect to server
await client.ConnectAsync();

// Subscribe to topic
await client.SubscribeAsync<string>("test-topic", async (message) =>
{
    Console.WriteLine($"Received: {message}");
    await Task.Delay(100);
});

// Publish message
await client.PublishAsync<string>("test-topic", "Hello, World!");

Builder Pattern

using var client = QortexMqClientFactory.CreateBuilder()
    .WithServerAddress("localhost")
    .WithServerPort(9090)
    .WithConnectionTimeout(15000)
    .WithReconnectionDelay(3000)
    .WithMaxReconnectionAttempts(10)
    .WithAutoReconnection(true)
    .WithMaxConcurrentHandlers(5)
    .WithMessageSendTimeout(8000)
    .WithKeepAlive(true, 120, 20)
    .WithNoDelay(true)
    .WithBufferSizes(32768, 32768)
    .Build();

Configuration Options

API Reference

Core Methods

• ConnectAsync() - Connect to server
• DisconnectAsync() - Disconnect from server
• PublishAsync<T>() - Publish message to topic
• SubscribeAsync<T>() - Subscribe to topic
• UnsubscribeAsync() - Unsubscribe from topic

Properties

• Connected - Connection status
• SubscriptionCount - Number of active subscriptions
• ConnectionStateChanged - Connection state change event

Events

• ConnectionStateChanged - Fired when connection state changes

Error Handling

The client provides comprehensive error handling:

try
{
    using var client = new QortexMqClient("localhost", 9090);
    await client.ConnectAsync();

    // Subscribe with error handling
    await client.SubscribeAsync<string>("topic", async (message) =>
    {
        try
        {
            // Process message
            await ProcessMessage(message);
        }
        catch (Exception ex)
        {
            // Log error and re-throw to send failed acknowledgment
            _logger.LogError(ex, "Error processing message");
            throw;
        }
    });
}
catch (InvalidOperationException ex)
{
    // Handle connection errors
    Console.WriteLine($"Connection failed: {ex.Message}");
}
catch (Exception ex)
{
    // Handle other errors
    Console.WriteLine($"Unexpected error: {ex.Message}");
}

Performance Considerations

• Use appropriate MaxConcurrentHandlersPerSubscription based on your workload
• Enable TCP optimizations (NoDelay, KeepAlive) for better performance
• Configure buffer sizes based on message sizes
• Use structured logging for better performance monitoring

Requirements

• .NET 8.0 or later
• MessagePack library
• Microsoft.Extensions.Logging (optional)

See LICENSE.txt for license information.