Interface ChannelListener

All Known Subinterfaces:
ClusterDeployer
All Known Implementing Classes:
AbstractReplicatedMap, CloudMembershipProvider, ClusterListener, ClusterSessionListener, DNSMembershipProvider, FarmWarDeployer, KubernetesMembershipProvider, LazyReplicatedMap, ReplicatedMap, RpcChannel, SimpleTcpCluster, StaticMembershipProvider

public interface ChannelListener
An interface to listens to incoming messages from a channel.

When a message is received, the Channel will invoke the channel listener in a conditional sequence. if ( listener.accept(msg,sender) ) listener.messageReceived(msg,sender);
A ChannelListener implementation MUST NOT return true on accept(Serializable, Member) if it doesn't intend to process the message. The channel can this way track whether a message was processed by an above application or if it was just received and forgot about, a feature required to support message-response(RPC) calls

  • Method Details

    • messageReceived

      void messageReceived(Serializable msg, Member sender)
      Receive a message from the channel
      Parameters:
      msg - Serializable
      sender - - the source of the message
    • accept

      boolean accept(Serializable msg, Member sender)
      Invoked by the channel to determine if the listener will process this message or not.
      Parameters:
      msg - Serializable
      sender - Member
      Returns:
      boolean
    • equals

      boolean equals(Object listener)
      Overrides:
      equals in class Object
      Parameters:
      listener - Object
      Returns:
      boolean
      See Also:
    • hashCode

      int hashCode()
      Overrides:
      hashCode in class Object
      Returns:
      int
      See Also: