Class ReplicationTransmitter

  • All Implemented Interfaces:
    ChannelSender, Heartbeat

    public class ReplicationTransmitter
    extends java.lang.Object
    implements ChannelSender
    Transmit message to other cluster members Actual senders are created based on the replicationMode type
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void add​(Member member)
      add new cluster member and create sender ( s. replicationMode) transfer current properties to sender
      Channel getChannel()
      Return the channel that is related to this ChannelSender
      MultiPointSender getTransport()  
      void heartbeat()
      Call transmitter to check for sender socket status
      void remove​(Member member)
      remove sender from transmitter. ( deregister mbean and disconnect sender )
      void sendMessage​(ChannelMessage message, Member[] destination)
      Send data to one member
      void setChannel​(Channel channel)
      Set the channel that is related to this ChannelSender
      void setTransport​(MultiPointSender transport)  
      void start()
      start the sender and register transmitter mbean
      void stop()
      stop the sender and deregister mbeans (transmitter, senders)
      • Methods inherited from class java.lang.Object

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