Class QueuedNetworkChannel

java.lang.Object
eu.cloudnetservice.node.impl.cluster.util.QueuedNetworkChannel
All Implemented Interfaces:
eu.cloudnetservice.driver.network.NetworkChannel, eu.cloudnetservice.driver.network.protocol.PacketSender
public final class QueuedNetworkChannel extends Object implements eu.cloudnetservice.driver.network.NetworkChannel

  • Field Details

    • wrappedChannel

      private final eu.cloudnetservice.driver.network.NetworkChannel wrappedChannel

    • scheduledPackets

      private final Queue<eu.cloudnetservice.driver.network.protocol.Packet> scheduledPackets

  • Constructor Details

    • QueuedNetworkChannel

      public QueuedNetworkChannel(@NonNull @NonNull eu.cloudnetservice.driver.network.NetworkChannel wrappedChannel)

  • Method Details

    • channelId

      public long channelId()
      Specified by:
      channelId in interface eu.cloudnetservice.driver.network.NetworkChannel

    • serverAddress

      @NonNull public @NonNull eu.cloudnetservice.driver.network.HostAndPort serverAddress()
      Specified by:
      serverAddress in interface eu.cloudnetservice.driver.network.NetworkChannel

    • clientAddress

      @NonNull public @NonNull eu.cloudnetservice.driver.network.HostAndPort clientAddress()
      Specified by:
      clientAddress in interface eu.cloudnetservice.driver.network.NetworkChannel

    • handler

      @NonNull public @NonNull eu.cloudnetservice.driver.network.NetworkChannelHandler handler()
      Specified by:
      handler in interface eu.cloudnetservice.driver.network.NetworkChannel

    • packetRegistry

      @NonNull public @NonNull eu.cloudnetservice.driver.network.protocol.PacketListenerRegistry packetRegistry()
      Specified by:
      packetRegistry in interface eu.cloudnetservice.driver.network.NetworkChannel

    • queryPacketManager

      @NonNull public @NonNull eu.cloudnetservice.driver.network.protocol.QueryPacketManager queryPacketManager()
      Specified by:
      queryPacketManager in interface eu.cloudnetservice.driver.network.NetworkChannel

    • clientProvidedChannel

      public boolean clientProvidedChannel()
      Specified by:
      clientProvidedChannel in interface eu.cloudnetservice.driver.network.NetworkChannel

    • sendQueryAsync

      @NonNull public @NonNull CompletableFuture<eu.cloudnetservice.driver.network.protocol.Packet> sendQueryAsync(@NonNull @NonNull eu.cloudnetservice.driver.network.protocol.Packet packet)
      Specified by:
      sendQueryAsync in interface eu.cloudnetservice.driver.network.NetworkChannel

    • writeable

      public boolean writeable()
      Specified by:
      writeable in interface eu.cloudnetservice.driver.network.NetworkChannel

    • active

      public boolean active()
      Specified by:
      active in interface eu.cloudnetservice.driver.network.NetworkChannel

    • closed

      public boolean closed()
      Specified by:
      closed in interface eu.cloudnetservice.driver.network.NetworkChannel

    • close

      public void close()
      Specified by:
      close in interface eu.cloudnetservice.driver.network.NetworkChannel

    • sendPacket

      public void sendPacket(@NonNull @NonNull eu.cloudnetservice.driver.network.protocol.Packet packet)
      Specified by:
      sendPacket in interface eu.cloudnetservice.driver.network.protocol.PacketSender

    • sendPacketSync

      public void sendPacketSync(@NonNull @NonNull eu.cloudnetservice.driver.network.protocol.Packet packet)
      Specified by:
      sendPacketSync in interface eu.cloudnetservice.driver.network.protocol.PacketSender

    • drainPacketQueue

      public void drainPacketQueue(@NonNull @NonNull eu.cloudnetservice.driver.network.NetworkChannel target)