MessageChannelTest - Bukkit

public class MCTestBukkit extends JavaPlugin implements Listener {

    private IPipeline alpha;
    private IPipeline bravo;

    @Override
    public void onEnable() {
        this.alpha = MessageChannelAPI.getPipelineRegistry().register("alpha");
        this.bravo = MessageChannelAPI.getPipelineRegistry().register("bravo");

        alpha.onReceive(bravo::send);

        bravo.onReceive(message -> {
            System.out.println("Target: " + message.getTarget().toString());
            System.out.println("Message: " + message.read(String.class));
        });

        getServer().getPluginManager().registerEvents(this, this);
    }

    @EventHandler
    public void onPlayerChat(AsyncPlayerChatEvent event) {
        Player player = event.getPlayer();

        PipelineMessage message = new PipelineMessage(player.getUniqueId());

        message.write(event.getMessage());

        alpha.send(message);
    }
}