org.jgroups.demos

Class Draw

java.lang.Object

org.jgroups.ReceiverAdapter

org.jgroups.demos.Draw

All Implemented Interfaces:

ActionListener, EventListener, ChannelListener, MembershipListener, MessageListener, Receiver

public class Draw
extends ReceiverAdapter
implements ActionListener, ChannelListener

Shared whiteboard, each new instance joins the same group. Each instance chooses a random color, mouse moves are broadcast to all group members, which then apply them to their canvas

Author:

Bela Ban, Oct 17 2001

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	Draw.DrawPanel

Field Summary

Fields

Modifier and Type	Field and Description
protected String	cluster_name
protected boolean	send_own_state_on_merge

Constructor Summary

Constructors

Constructor and Description
Draw(JChannel channel)
Draw(JChannel channel, boolean use_state, long state_timeout)
Draw(String props, boolean no_channel, boolean jmx, boolean use_state, long state_timeout, boolean use_unicasts, String name, boolean send_own_state_on_merge, AddressGenerator gen)

Method Summary

Modifier and Type	Method and Description
void	actionPerformed(ActionEvent e)
void	channelClosed(Channel channel) Channel has been closed notification callback
void	channelConnected(Channel channel) Channel has been connected notification callback
void	channelDisconnected(Channel channel) Channel has been disconnected notification callback
void	clearPanel()
String	getClusterName()
void	getState(OutputStream ostream) Allows an application to write a state through a provided OutputStream.
void	go()
static void	main(String[] args)
void	receive(Message msg) Called when a message is received.
void	sendClearPanelMsg()
protected void	sendOwnState(Map<Point,Color> copy)
void	setClusterName(String clustername)
void	setState(InputStream istream) Allows an application to read a state through a provided InputStream.
void	stop()
void	viewAccepted(View v) Called when a change in membership has occurred.

Methods inherited from class org.jgroups.ReceiverAdapter

block, suspect, unblock

Methods inherited from class java.lang.Object

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

Field Detail

cluster_name

protected String cluster_name

send_own_state_on_merge

protected boolean send_own_state_on_merge

Constructor Detail

Draw

public Draw(String props,
            boolean no_channel,
            boolean jmx,
            boolean use_state,
            long state_timeout,
            boolean use_unicasts,
            String name,
            boolean send_own_state_on_merge,
            AddressGenerator gen)
     throws Exception

Throws:

Exception

Draw

public Draw(JChannel channel)
     throws Exception

Throws:

Exception

Draw

public Draw(JChannel channel,
            boolean use_state,
            long state_timeout)
     throws Exception

Throws:

Exception

Method Detail

getClusterName

public String getClusterName()

setClusterName

public void setClusterName(String clustername)

main

public static void main(String[] args)

go

public void go()
        throws Exception

Throws:

Exception

receive

public void receive(Message msg)

Description copied from class: ReceiverAdapter

Called when a message is received.

Specified by:

receive in interface MessageListener

Overrides:

receive in class ReceiverAdapter

viewAccepted

public void viewAccepted(View v)

Description copied from class: ReceiverAdapter

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 Channel.connect(String) returns.

Specified by:

viewAccepted in interface MembershipListener

Overrides:

viewAccepted in class ReceiverAdapter

getState

public void getState(OutputStream ostream)
              throws Exception

Description copied from class: ReceiverAdapter

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 MessageListener

Overrides:

getState in class ReceiverAdapter

Parameters:

ostream - the OutputStream

Throws:

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(InputStream istream)
              throws Exception

Description copied from class: ReceiverAdapter

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 MessageListener

Overrides:

setState in class ReceiverAdapter

Parameters:

istream - the InputStream

Throws:

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(ActionEvent e)

Specified by:

actionPerformed in interface ActionListener

stop

public void stop()

sendOwnState

protected void sendOwnState(Map<Point,Color> copy)

channelConnected

public void channelConnected(Channel 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(Channel 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(Channel channel)

Description copied from interface: ChannelListener

Channel has been closed notification callback

Specified by:

channelClosed in interface ChannelListener

Parameters:

channel - the closed channel