Package org.jgroups.demos

Class Draw

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      protected class  Draw.DrawPanel  

    • Constructor Summary

      Constructors 
      Constructor Description
      Draw​(java.lang.String props, boolean no_channel, boolean jmx, boolean use_state, long state_timeout, boolean use_unicasts, java.lang.String name, boolean send_own_state_on_merge, AddressGenerator gen)  
      Draw​(JChannel channel)  
      Draw​(JChannel channel, boolean use_state, long state_timeout)  

    • Field Detail

      • cluster_name

        protected java.lang.String cluster_name

      • send_own_state_on_merge

        protected boolean send_own_state_on_merge

    • Constructor Detail

      • Draw

        public Draw​(java.lang.String props,
            boolean no_channel,
            boolean jmx,
            boolean use_state,
            long state_timeout,
            boolean use_unicasts,
            java.lang.String name,
            boolean send_own_state_on_merge,
            AddressGenerator gen)
     throws java.lang.Exception
        Throws:
        java.lang.Exception

      • Draw

        public Draw​(JChannel channel)
     throws java.lang.Exception
        Throws:
        java.lang.Exception

      • Draw

        public Draw​(JChannel channel,
            boolean use_state,
            long state_timeout)
     throws java.lang.Exception
        Throws:
        java.lang.Exception

    • Method Detail

      • getClusterName

        public java.lang.String getClusterName()

      • setClusterName

        public void setClusterName​(java.lang.String clustername)

      • main

        public static void main​(java.lang.String[] args)

      • go

        public void go()
        throws java.lang.Exception
        Throws:
        java.lang.Exception

      • viewAccepted

        public void viewAccepted​(View v)
        Description copied from interface: MembershipListener
        Called when a change in membership has occurred. No long running actions, sending of messages or anything that could block should be done in this callback. If some long running action needs to be performed, it should be done in a separate thread.

        Note that on reception of the first view (a new member just joined), the channel will not yet be in the connected state. This only happens when JChannel.connect(String) returns.

        Specified by:
        viewAccepted in interface MembershipListener
        Overrides:
        viewAccepted in class ReceiverAdapter

      • getState

        public void getState​(java.io.OutputStream ostream)
              throws java.lang.Exception
        Description copied from interface: StateListener
        Allows an application to write a state through a provided OutputStream. After the state has been written the OutputStream doesn't need to be closed as stream closing is automatically done when a calling thread returns from this callback.
        Specified by:
        getState in interface StateListener
        Overrides:
        getState in class ReceiverAdapter
        Parameters:
        ostream - the OutputStream
        Throws:
        java.lang.Exception - if the streaming fails, any exceptions should be thrown so that the state requester can re-throw them and let the caller know what happened
        See Also:
        OutputStream.close()

      • setState

        public void setState​(java.io.InputStream istream)
              throws java.lang.Exception
        Description copied from interface: StateListener
        Allows an application to read a state through a provided InputStream. After the state has been read the InputStream doesn't need to be closed as stream closing is automatically done when a calling thread returns from this callback.
        Specified by:
        setState in interface StateListener
        Overrides:
        setState in class ReceiverAdapter
        Parameters:
        istream - the InputStream
        Throws:
        java.lang.Exception - if the streaming fails, any exceptions should be thrown so that the state requester can catch them and thus know what happened
        See Also:
        InputStream.close()

      • clearPanel

        public void clearPanel()

      • sendClearPanelMsg

        public void sendClearPanelMsg()

      • actionPerformed

        public void actionPerformed​(java.awt.event.ActionEvent e)
        Specified by:
        actionPerformed in interface java.awt.event.ActionListener

      • stop

        public void stop()

      • sendOwnState

        protected void sendOwnState​(java.util.Map<java.awt.Point,​java.awt.Color> copy)

      • channelConnected

        public void channelConnected​(JChannel channel)
        Description copied from interface: ChannelListener
        Channel has been connected notification callback
        Specified by:
        channelConnected in interface ChannelListener
        Parameters:
        channel - the channel that has been connected

      • channelDisconnected

        public void channelDisconnected​(JChannel channel)
        Description copied from interface: ChannelListener
        Channel has been disconnected notification callback
        Specified by:
        channelDisconnected in interface ChannelListener
        Parameters:
        channel - the disconnected channel

      • channelClosed

        public void channelClosed​(JChannel channel)
        Description copied from interface: ChannelListener
        Channel has been closed notification callback
        Specified by:
        channelClosed in interface ChannelListener
        Parameters:
        channel - the closed channel