Class PluginMessenger

java.lang.Object
net.william278.huskhomes.messenger.NetworkMessenger
net.william278.huskhomes.messenger.PluginMessenger
All Implemented Interfaces:
org.bukkit.plugin.messaging.PluginMessageListener
Direct Known Subclasses:
RedisMessenger

public class PluginMessenger extends net.william278.huskhomes.messenger.NetworkMessenger implements org.bukkit.plugin.messaging.PluginMessageListener
Plugin Messaging channel messenger implementation
  • Field Summary

    Fields inherited from class net.william278.huskhomes.messenger.NetworkMessenger

    clusterId, NETWORK_MESSAGE_CHANNEL, onlinePlayerNamesRequests, onlineServersRequests, plugin, processingMessages, serverNameRequests
  • Constructor Summary

    Constructors
    Constructor
    Description
     
  • Method Summary

    Modifier and Type
    Method
    Description
    CompletableFuture<net.william278.huskhomes.messenger.Message>
    dispatchMessage​(@NotNull net.william278.huskhomes.player.OnlineUser sender, @NotNull net.william278.huskhomes.messenger.Message message)
     
    fetchOnlineServerList​(@NotNull net.william278.huskhomes.player.OnlineUser requester)
     
    fetchServerName​(@NotNull net.william278.huskhomes.player.OnlineUser requester)
     
    getOnlinePlayerNames​(@NotNull net.william278.huskhomes.player.OnlineUser requester)
     
    void
    initialize​(@NotNull net.william278.huskhomes.HuskHomes implementor)
     
    void
    onPluginMessageReceived​(@NotNull String channel, org.bukkit.entity.Player player, byte[] messageBytes)
     
    sendPlayer​(@NotNull net.william278.huskhomes.player.OnlineUser onlineUser, @NotNull net.william278.huskhomes.position.Server server)
     
    protected void
    sendReply​(@NotNull net.william278.huskhomes.player.OnlineUser replier, @NotNull net.william278.huskhomes.messenger.Message reply)
     
    void
     

    Methods inherited from class net.william278.huskhomes.messenger.NetworkMessenger

    findPlayer, handleMessage, sendMessage

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • PluginMessenger

      public PluginMessenger()
  • Method Details

    • initialize

      public void initialize(@NotNull @NotNull net.william278.huskhomes.HuskHomes implementor)
      Overrides:
      initialize in class net.william278.huskhomes.messenger.NetworkMessenger
    • getOnlinePlayerNames

      public CompletableFuture<String[]> getOnlinePlayerNames(@NotNull @NotNull net.william278.huskhomes.player.OnlineUser requester)
      Specified by:
      getOnlinePlayerNames in class net.william278.huskhomes.messenger.NetworkMessenger
    • fetchServerName

      public CompletableFuture<String> fetchServerName(@NotNull @NotNull net.william278.huskhomes.player.OnlineUser requester)
      Specified by:
      fetchServerName in class net.william278.huskhomes.messenger.NetworkMessenger
    • fetchOnlineServerList

      public CompletableFuture<String[]> fetchOnlineServerList(@NotNull @NotNull net.william278.huskhomes.player.OnlineUser requester)
      Specified by:
      fetchOnlineServerList in class net.william278.huskhomes.messenger.NetworkMessenger
    • sendPlayer

      public CompletableFuture<Boolean> sendPlayer(@NotNull @NotNull net.william278.huskhomes.player.OnlineUser onlineUser, @NotNull @NotNull net.william278.huskhomes.position.Server server)
      Specified by:
      sendPlayer in class net.william278.huskhomes.messenger.NetworkMessenger
    • dispatchMessage

      public CompletableFuture<net.william278.huskhomes.messenger.Message> dispatchMessage(@NotNull @NotNull net.william278.huskhomes.player.OnlineUser sender, @NotNull @NotNull net.william278.huskhomes.messenger.Message message)
      Specified by:
      dispatchMessage in class net.william278.huskhomes.messenger.NetworkMessenger
    • sendReply

      protected void sendReply(@NotNull @NotNull net.william278.huskhomes.player.OnlineUser replier, @NotNull @NotNull net.william278.huskhomes.messenger.Message reply)
      Specified by:
      sendReply in class net.william278.huskhomes.messenger.NetworkMessenger
    • terminate

      public void terminate()
      Specified by:
      terminate in class net.william278.huskhomes.messenger.NetworkMessenger
    • onPluginMessageReceived

      public void onPluginMessageReceived(@NotNull @NotNull String channel, @NotNull org.bukkit.entity.Player player, byte[] messageBytes)
      Specified by:
      onPluginMessageReceived in interface org.bukkit.plugin.messaging.PluginMessageListener