Package me.internalizable.numdrassl.api.messaging

package me.internalizable.numdrassl.api.messaging

Cross-proxy messaging API for distributed Numdrassl deployments.

This package provides a pub/sub messaging system for communication between proxy instances, typically backed by Redis.

Important: This package uses @MessageSubscribe for cross-proxy messages. Do not confuse with @Subscribe from api.event which is for local proxy events.

Core Interfaces

• MessagingService - Main service for publishing and subscribing
• Subscription - Represents an active subscription
• MessageHandler - Callback for received messages
• PluginMessageHandler - Typed callback for plugin messages

Channels

• MessageChannel - Represents a pub/sub channel
• Channels - Predefined system channels
• SystemChannel - Enum of system channel types

Messages

• ChannelMessage - Base interface for all messages
• me.internalizable.numdrassl.api.messaging.message - Concrete message types package

Annotations

• MessageSubscribe - Marks methods as cross-proxy message handlers
• TypeAdapter - Custom serialization for message payloads

Usage Examples

Programmatic API

MessagingService messaging = proxy.getMessagingService();

// Subscribe to system messages
messaging.subscribe(Channels.HEARTBEAT, HeartbeatMessage.class,
    (channel, msg) -> logger.info("Proxy {} alive", msg.sourceProxyId()));

// Subscribe to plugin messages
messaging.subscribePlugin("my-plugin", "events", MyData.class,
    (sourceProxyId, data) -> handleData(data));

// Publish plugin messages
messaging.publishPlugin("my-plugin", "events", new MyData(...));

Annotation API

@Plugin(id = "my-plugin", name = "My Plugin", version = "1.0.0")
public class MyPlugin {

    @MessageSubscribe(channel = "events")
    public void onEvent(MyData data) {
        // Plugin ID inferred from @Plugin annotation
    }

    @MessageSubscribe(SystemChannel.CHAT)
    public void onChat(ChatMessage msg) {
        // System channel subscription
    }
}

// Register
messaging.registerListener(myPlugin);

See Also:

• MessagingService
• MessageSubscribe

Related Packages

Package	Description
me.internalizable.numdrassl.api
me.internalizable.numdrassl.api.messaging.annotation	Annotation-based API for cross-proxy message subscriptions.
me.internalizable.numdrassl.api.messaging.backend	Backend messaging API for proxy-to-backend communication.
me.internalizable.numdrassl.api.messaging.channel	Channel definitions and registry for cross-proxy messaging.
me.internalizable.numdrassl.api.messaging.handler	Handler interfaces for message processing.
me.internalizable.numdrassl.api.messaging.message	Message types for cross-proxy communication.

Interfaces

Class	Description
ChannelMessage	Base interface for all cross-proxy messages.
MessagingService	Service for cross-proxy messaging via pub/sub.
Subscription	Represents an active subscription to a messaging channel.