Class ChannelMessagePacketListener

java.lang.Object
eu.cloudnetservice.node.impl.network.listener.ChannelMessagePacketListener
All Implemented Interfaces:
eu.cloudnetservice.driver.network.protocol.PacketListener
@Singleton public final class ChannelMessagePacketListener extends Object implements eu.cloudnetservice.driver.network.protocol.PacketListener

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final eu.cloudnetservice.driver.ComponentInfo
    componentInfo
     
    private final eu.cloudnetservice.driver.event.EventManager
    eventManager
     
    private static final org.slf4j.Logger
    LOGGER
     
    private final NodeCloudMessenger
    messenger
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ChannelMessagePacketListener(@NonNull NodeCloudMessenger messenger, @NonNull eu.cloudnetservice.driver.event.EventManager eventManager, @NonNull eu.cloudnetservice.driver.ComponentInfo componentInfo)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    handle(@NonNull eu.cloudnetservice.driver.network.NetworkChannel channel, @NonNull eu.cloudnetservice.driver.network.protocol.Packet packet)
     
    private void
    resumeHandling(@NonNull eu.cloudnetservice.driver.network.protocol.Packet packet, @NonNull eu.cloudnetservice.driver.network.NetworkChannel channel, @NonNull eu.cloudnetservice.driver.channel.ChannelMessage message, @Nullable eu.cloudnetservice.driver.channel.ChannelMessage localResponse, boolean comesFromWrapper)
    Resumes the processing of a channel message, redirecting the message to other targets in the cluster and sending back a response in case the original request was a query.

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • LOGGER

      private static final org.slf4j.Logger LOGGER

    • messenger

      private final NodeCloudMessenger messenger

    • eventManager

      private final eu.cloudnetservice.driver.event.EventManager eventManager

    • componentInfo

      private final eu.cloudnetservice.driver.ComponentInfo componentInfo

  • Constructor Details

  • Method Details

    • handle

      public void handle(@NonNull @NonNull eu.cloudnetservice.driver.network.NetworkChannel channel, @NonNull @NonNull eu.cloudnetservice.driver.network.protocol.Packet packet)
      Specified by:
      handle in interface eu.cloudnetservice.driver.network.protocol.PacketListener

    • resumeHandling

      private void resumeHandling(@NonNull @NonNull eu.cloudnetservice.driver.network.protocol.Packet packet, @NonNull @NonNull eu.cloudnetservice.driver.network.NetworkChannel channel, @NonNull @NonNull eu.cloudnetservice.driver.channel.ChannelMessage message, @Nullable @Nullable eu.cloudnetservice.driver.channel.ChannelMessage localResponse, boolean comesFromWrapper)
      Resumes the processing of a channel message, redirecting the message to other targets in the cluster and sending back a response in case the original request was a query.
      Parameters:
      packet - the packet that contained the initially handled channel message.
      channel - the channel on which the initially handled channel message was received.
      message - the original channel message that was received.
      localResponse - the query response generated by listeners on the current node.
      comesFromWrapper - if the handled channel message was sent by a wrapper.
      Throws:
      NullPointerException - if the given packet, channel or initial channel message is null.