End‑to‑End Example: Combat + UI + Settings¶

Short intro

A small scenario tying together Untargeted, Targeted, and Broadcast messages with Unity integration, ordering, interceptors, and diagnostics.

Scenario

Global: settings change (Untargeted)
Targeted: heal a specific player (Targeted)
Broadcast: enemies report damage taken (Broadcast)
UI listens globally to update overlays
Analytics listens across all sources/targets

Messages

C#

using DxMessaging.Core.Attributes;

[DxUntargetedMessage][DxAutoConstructor]
public readonly partial struct VideoSettingsChanged { public readonly int width; public readonly int height; }

[DxTargetedMessage][DxAutoConstructor]
public readonly partial struct Heal { public readonly int amount; }

[DxBroadcastMessage][DxAutoConstructor]
public readonly partial struct TookDamage { public readonly int amount; }

Unity: Player component (targeted)

C#

using DxMessaging.Unity;
using DxMessaging.Core.Messages;

public sealed class Player : MessageAwareComponent
{
    private int _hp;

    protected override void RegisterMessageHandlers()
    {
        base.RegisterMessageHandlers();
        _ = Token.RegisterComponentTargeted<Heal>(this, OnHeal);
    }

    private void OnHeal(ref Heal m) => _hp += m.amount;
}

Unity: Enemy component (broadcast)

C#

using DxMessaging.Unity;
using DxMessaging.Core.Extensions;
using DxMessaging.Core.Messages;

[RequireComponent(typeof(MessagingComponent))]
public sealed class Enemy : UnityEngine.MonoBehaviour
{
    public void ApplyDamage(int amount)
    {
        var took = new TookDamage(amount);
        took.EmitGameObjectBroadcast(gameObject);
    }
}

UI overlay (global + all‑sources)

C#

using DxMessaging.Unity;
using DxMessaging.Core;
using DxMessaging.Core.Messages;
using UnityEngine;

public sealed class UIOverlay : MessageAwareComponent
{
    protected override void RegisterMessageHandlers()
    {
        base.RegisterMessageHandlers();
        _ = Token.RegisterUntargeted<VideoSettingsChanged>(OnSettings);
        _ = Token.RegisterBroadcastWithoutSource<TookDamage>(OnAnyDamage);
    }

    private void OnSettings(ref VideoSettingsChanged m) => RebuildUI(m.width, m.height);
    private void OnAnyDamage(ref InstanceId src, ref TookDamage m) => ShowFloatingText(src, $"-{m.amount}");
}

Interceptors and post‑processing (ordering)

C#

using DxMessaging.Core;            // MessageHandler
using DxMessaging.Core.MessageBus; // IMessageBus

var bus = MessageHandler.MessageBus;

// Normalize negatives to zero and clamp max
_ = bus.RegisterTargetedInterceptor<Heal>((ref InstanceId tgt, ref Heal m) =>
{
    var amount = UnityEngine.Mathf.Clamp(m.amount, 0, 999);
    if (amount == 0) return false; // cancel zero heals
    m = new Heal(amount);
    return true;
}, priority: 0);

// Log after handlers
_ = token.RegisterBroadcastWithoutSourcePostProcessor<TookDamage>((InstanceId src, TookDamage m) =>
{
    Analytics.Log("Damage", new { src, m.amount });
});

Settings menu (untargeted)

C#

using DxMessaging.Core.Extensions;

public sealed class SettingsMenu
{
    public void Apply(int width, int height)
    {
        var changed = new VideoSettingsChanged(width, height);
        changed.Emit();
    }
}

Diagnostics (Editor)

On any GameObject with a MessagingComponent:
Enable Global Diagnostics to record emissions.
Inspect Global Buffer for recent messages (type + context). Matching listeners are highlighted.
Inspect Local Buffer per listener and paginated Registrations with priorities and contexts.

Notes

Use component vs gameObject context consistently for targeted/broadcast messages (see Targeting & Context).
For tests/subsystems, use a local MessageBus and pass it to the token factory.