Package org.jgroups.demos

Class NotificationBusDemo

java.lang.Object

org.jgroups.demos.NotificationBusDemo

All Implemented Interfaces:

NotificationBus.Consumer

public class NotificationBusDemo
extends Object
implements NotificationBus.Consumer

Demoes the NotificationBus (without caching). Start a number of members and type in messages. All members will receive the messages. View changes will also be displayed (e.g. member joined, left).

Author:

Bela Ban

Constructor Summary

Constructors

Constructor	Description
NotificationBusDemo()

Method Summary

Modifier and Type	Method	Description
Serializable	getCache()	Called on the coordinator to obtains its cache
void	handleNotification(Serializable n)
static void	main(String[] args)
void	memberJoined(Address mbr)
void	memberLeft(Address mbr)
void	start(String bus_name, String props)

Methods inherited from class java.lang.Object

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

Constructor Details

NotificationBusDemo

public NotificationBusDemo()

Method Details

start

public void start(String bus_name,
 String props)

handleNotification

public void handleNotification(Serializable n)

Specified by:

handleNotification in interface NotificationBus.Consumer

getCache

public Serializable getCache()

Description copied from interface: NotificationBus.Consumer

Called on the coordinator to obtains its cache

Specified by:

getCache in interface NotificationBus.Consumer

memberJoined

public void memberJoined(Address mbr)

Specified by:

memberJoined in interface NotificationBus.Consumer

memberLeft

public void memberLeft(Address mbr)

Specified by:

memberLeft in interface NotificationBus.Consumer

main

public static void main(String[] args)