<workers>
    <worker-names>MulticastNotifyWorker</worker-names>
           <MulticastNotifyWorker>
                <enabled>true</enabled>
                <class-name>com.j_spaces.worker.multicast.MulticastNotifyWorker</class-name>
                <!--To reduce latency, dispatch intervals should be set to accommodate latency requirements-->
                <interval-dispatch-time>1000</interval-dispatch-time>
                <chunk-event-size>100</chunk-event-size>
                <multicast-group>224.0.0.1</multicast-group>
                <multicast-port>34721</multicast-port>
                <ttl>4</ttl>
                <discovery-interface>localhost</discovery-interface>
                <description>Multicast Notify Manager</description>
           </MulticastNotifyWorker>
</workers>

gsInstance "/./multicastnotifySpace?schema=cache&properties=multicastnotify" ".;..\classes"

space-config.workers.MulticastNotifyWorker.enabled=true

@%JAVACMD% -Dcom.gs.home=%JSHOMEDIR% -classpath %JARS%;classes com.j_spaces.examples.
 	multicast_notify.MulticastNotify
 	rmi://localhost/./multicastnotifySpace -f

@%JAVACMD% -Dcom.gs.home=%JSHOMEDIR%
 	-classpath %JARS%;classes com.j_spaces.examples.multicast_notify.MulticastNotify
 	rmi://localhost/./multicastnotifySpace -a

import com.j_spaces.core.client.MetaDataEntry;
 	 
 	public class Message extends MetaDataEntry
 	{
 	public Integer id;
 	public String content;
 	 
 	public Message()
 	{
 	this.setFifo(true);
 	}
 	 
 	public Message(int id)
 	{
 	this(id, null);
 	}
 	 
 	public Message(int id, String msg)
 	{
 	this.id = new Integer(id);
 	this.content = msg;
 	this.setFifo(true);
 	}
 	 
 	public String toString()
 	{
 	return "Message(" + id +", " + content+")";
 	}
 	}

public class MulticastNotify
 	{
 	/**
 	* MulticastNotifyListener, is invoked each time an event arrives
 	* at the client. The events are numbered as they arrive, and
 	* printed out with relevant information.
 	*/
 	public class MulticastNotifyListener implements RemoteEventListener
 	{
 	volatile int numberOfNotifications;
 	public final int listenerId;
 	private long leaseExpTime;
 	 
 	public MulticastNotifyListener(Integer handback)
 	{
 	this.listenerId = handback.intValue();
 	}
 	 
 	public void setLeaseExpirationTime(long lease)
 	{
 	this.leaseExpTime = lease;
 	}
 	 
 	public long getLeaseExpirationTime()
 	{
 	return this.leaseExpTime - System.currentTimeMillis();
 	}
 	 
 	public void notify(RemoteEvent theEvent) throws UnknownEventException, RemoteException
 	{
 	try
 	{
 	Message message = (Message)((EntryArrivedRemoteEvent)theEvent).getEntry();
 	System.out.println(
 	"\n[" + (++numberOfNotifications) + "]. "
 	+ "Message : " + message
 	+ "\n\tEventId : " + theEvent.getID()
 	+ "\n\tSequenceNumber : " + theEvent.getSequenceNumber()
 	+ "\n\tHandBack : " + theEvent.getRegistrationObject().get()
 	+ "\n\tLease Expires in : " + getLeaseExpirationTime() + " ms");
 	}
 	catch (Exception e)
 	{
 	e.printStackTrace();
 	}
 	}
 	}
 	 
 	/**
 	* MulticastNotifyFilter, is invoked at the server
 	* Excludes odd event-ids from reaching the listener, but allows
 	* even event-ids.
 	*/
 	static public class MulticastNotifyFilter implements INotifyDelegatorFilter
 	{
 	private IJSpace spaceProxy;
 	 
 	//leave this false to exclude PASSED messages from log
 	public final boolean logIncludingPassed = false;
 	 
 	//listener id this filter is attached to
 	private int listenerId;
 	 
 	public MulticastNotifyFilter(Integer listenerId)
 	{
 	this.listenerId = listenerId.intValue();
 	}
 	 
 	 
 	public void init(IJSpace space, Entry notifyTemplate)
 	{
 	spaceProxy = space;
 	Thread.currentThread().setName("MulticastNotifyFilter-"+listenerId);
 	}
 	 
 	/**
 	* process is called on each arrived event at the space.
 	* Excludes odd event ids, allow even event ids.
 	* @return true if this event is valid by this filter, false otherwise
 	**/
 	public boolean process(EntryArrivedRemoteEvent theEvent)
 	{
 	boolean isEven = false;
 	try
 	{
 	Message message = (Message)theEvent.getEntry();
 	 
 	/* filter's process method returns TRUE if and only if
 	* Message Id is even = 2,4,6 ... otherwise FALSE. */
 	isEven = (message.id.intValue() % 2 == 0);
 	}
 	catch (Exception e)
 	{
 	System.err.println("MulticastNotifyFilter - Exception: "+e);
 	e.printStackTrace();
 	}
 	 
 	return isEven;
 	}
 	 
 	public void close()
 	{
 	}
 	}
 	 
 	 
 	private IJSpace spaceProxy;
 	 
 	 
 	public static int globalId = 1;
 	public static int notifyListenerId;
 	private MulticastNotifyDelegator mDelegator;
 	private MulticastNotifyFilter multicastNotifyFilter;
 	private MulticastNotifyListener multicastNotifyListener;
 	 
 	public static final int NUMBER_OF_MESSAGES = 10;
 	 
 	public MulticastNotify(IJSpace space)
 	{
 	spaceProxy = space;
 	}
 	 
 	/**
 	* Register notify delegator for the Message() template
 	*
 	* @throws TransactionException
 	* @throws IOException
 	* @throws ClassNotFoundException
 	*/
 	private void registerNotifyTemplates(boolean filterEnabled) throws TransactionException,
 	IOException, ClassNotFoundException
 	{
 	// Get an instance of the delegator
 	mDelegator = MulticastNotifyDelegator.getInstance(spaceProxy);
 	 
 	//define registration template
 	Message template = new Message();
 	 
 	//prepare notify listener
 	Integer listenerId = new Integer( (++MulticastNotify.notifyListenerId) );
 	MarshalledObject marshObj = new MarshalledObject( listenerId );
 	multicastNotifyListener = new MulticastNotifyListener( listenerId );
 	 
 	EventRegistration eventReg;
 	 
 	if (filterEnabled)
 	{
 	multicastNotifyFilter = new MulticastNotifyFilter(listenerId);
 	eventReg = mDelegator.notify( template,
 	null, //transaction
 	multicastNotifyListener,
 	Lease.FOREVER,
 	marshObj, //could also be null
 	false,
 	//fifo mode - not support
 	NotifyModifiers.NOTIFY_WRITE,
 	multicastNotifyFilter);
 	}
 	else
 	{
 	eventReg = mDelegator.notify( template,
 	null, //transaction
 	multicastNotifyListener,
 	Lease.FOREVER,
 	marshObj, //could also be null
 	false,
 	//fifo mode - not support
 	NotifyModifiers.NOTIFY_WRITE );
 	}
 	 
 	multicastNotifyListener.setLeaseExpirationTime( eventReg.getLease().getExpiration() );
 	 
 	System.out.println(
 	"Template : " + template.getClass()
 	+ "\n\tEvent Registration Id : " + eventReg.getID()
 	+ "\n\tSequenceNumber : " + eventReg.getSequenceNumber()
 	+ "\n\tHandBack : " + marshObj.get()
 	+ "\n\tLease Expires in : "
 	+ new Date( multicastNotifyListener.getLeaseExpirationTime() ) + " ms");
 	 
 	}
 	 
 	 
 	/**
 	* Called by the main application.
 	* Writes NUMBER_OF_MESSAGES to the space, each with an increasing id
 	* and a creation timestamp.
 	*
 	* @throws RemoteException
 	* @throws TransactionException
 	*/
 	private void writeMessages() throws RemoteException, TransactionException
 	{
 	int startId = MulticastNotify.globalId;
 	MulticastNotify.globalId += NUMBER_OF_MESSAGES;
 	int endId = MulticastNotify.globalId;
 	 
 	// global id <= i < global id + NUMBER_OF_MESSAGES
 	for (int i=startId; i < endId; i++)
 	{
 	String messageCreationTime = (new Date( System.currentTimeMillis())).toString();
 	Message message = new Message( i, messageCreationTime );
 	spaceProxy.write( message, null, 30 * 1000);
 	System.out.println("Message :\t" + message +" \tWritten to space");
 	}
 	}
 	 
 	 
 	/**
 	* see usage for help
 	* @param args <URL> <OPTIONS>
 	*/
 	public static void main(String[] args)
 	{
 	if ( args.length != 2 )
 	{
 	printUsage();
 	}
 	 
 	try
 	{
 	IJSpace space = (IJSpace)SpaceFinder.find( args[0] );
 	if ( space == null )
 	{
 	System.out.println("Space not found: " + args[0]);
 	System.exit(-1);
 	}
 	 
 	MulticastNotify mNotify = new MulticastNotify(space);
 	 
 	if ( args[Look And Feel - ServiceGrid].equals("-m") )
 	{
 	Thread.sleep(1000); // sleep interval for load time
 	System.out.println("\nStarted the writer Application... \n\tConnected to space: " + args[0]);
 	System.out.println("\tMake sure listeners (filtered or non-filtered) are started!\n");
 	while(true)
 	{
 	System.out.println("\nPress <Enter> to Write "
 	+ NUMBER_OF_MESSAGES
 	+ " Message entries");
 	System.in.read();
 	mNotify.writeMessages();
 	}
 	}
 	else
 	if ( args[Look And Feel - ServiceGrid].equals("-f") )
 	{
 	System.out.println("\nRegistering filtered listener...");
 	mNotify.registerNotifyTemplates(true);
 	System.out.println("\nPress Enter to end Demo!");
 	System.in.read();
 	}
 	else
 	if ( args[Look And Feel - ServiceGrid].equals("-a") )
 	{
 	System.out.println("\nRegistering non-filtered listener...");
 	mNotify.registerNotifyTemplates(false);
 	System.out.println("\nPress Enter to end Demo!");
 	System.in.read();
 	}
 	else
 	{
 	printUsage();
 	}
 	}
 	catch( FinderException ex )
 	{
 	ex.printStackTrace();
 	System.out.println("Could not find space: " + args[0]);
 	System.out.println("Please check that GigaSpaces Server is running.");
 	}
 	catch (Exception e)
 	{
 	e.printStackTrace();
 	}
 	}
 	 
 	 
 	public static void printUsage()
 	{
 	System.out.println("Usage: MulticastNotify <URL> <OPTION>");
 	System.out.println("Load the main application and then load as many listeners as you wish.");
 	System.out.println("\nOptions are:");
 	System.out.println("\t-m\tMain application");
 	System.out.println("\t-f\tFiltered notification listeners");
 	System.out.println("\t-a\tAll notifications, non-filtered listeners");
 	System.out.println("\tURL in the form of rmi://lookup host/container name/space name");
 	System.exit(-1);
 	}
 	 
 	}