package com.j_spaces.examples.continuousquery;

import java.io.IOException;
import java.rmi.RemoteException;
import net.jini.core.entry.*;
import net.jini.core.event.RemoteEvent;
import net.jini.core.event.RemoteEventListener;
import net.jini.core.event.UnknownEventException;
import net.jini.core.lease.Lease;
import net.jini.core.transaction.TransactionException;
import com.j_spaces.core.IJSpace;
import com.j_spaces.core.client.*;

public class Main implements RemoteEventListener {
       static IJSpace space = null;
 
       public static void main(String[] args) {
              try {
                     space = (IJSpace) SpaceFinder.find("jini://localhost/./myCache");
                     if (space == null) {
                            System.out.println("Space not found: " + args[0]);
                            System.exit(-1);
                     }
                     System.out.println("try to Clean Space");
                     space.clean();
                     System.out.println("try to Clean Space - OK!");
           

                     Main cq = new Main();
                     cq.go();
                     System.out.println("try to Write 100 entries to space");
                     for (int i = 0; i < 100; i++) {
                            MyEntry msg = new MyEntry();
                            space.write(msg, null, Lease.FOREVER);
                            MyEntry ret = (MyEntry )space.read(msg, null, Lease.FOREVER);

                            ret.m_long = new Long(i);
                            ret.m_integer = new Integer(i);
                            space.update(ret, null,0, 0);
                            space.take(ret , null,0);
                     }

                     System.out.println("Writing 100 entries to space...Done!");
                     System.out.println("Click Enter to complete demo!");
                     System.in.read();
                     System.out.println("Done demo!");
              } catch (Exception e) {
                     e.printStackTrace();
              }
       }
 
       public void go() throws RemoteException, IOException, TransactionException {
              space.snapshot(new MyEntry());
              // lets define a continuous query that will provide notifications for entries 
              //with fields m_long>10 and m_integer<20

              SQLQuery template1 = new SQLQuery(MyEntry.class.getName() , "m_long>10 and m_integer<20");
              System.out.println ("Register for Notifications for Update operations...");
              NotifyDelegator notifyDelegator1 = new NotifyDelegator(space, template1,
                            null, this, Lease.FOREVER, null, false,
                            NotifyModifiers.NOTIFY_UPDATE);

              System.out.println ("Register for Notifications Update operations - Done!");
              System.out.println ("Register for Notifications for Take operations...");
              // lets define a continues query that will provide notifications for entries than 
              //got fields m_long>15 and m_integer<18
              SQLQuery template2 = new SQLQuery(MyEntry.class.getName() , "m_long>15 and m_integer<18");

              NotifyDelegator notifyDelegator2 = new NotifyDelegator(space, template2,
                            null, this, Lease.FOREVER, null, false,
                            NotifyModifiers.NOTIFY_TAKE);

              System.out.println ("Register for Notifications Take operations - Done!");
       }

       public void notify(RemoteEvent event) throws UnknownEventException, RemoteException {
              try {
                     EntryArrivedRemoteEvent eare=  (EntryArrivedRemoteEvent) event;
                     MyEntry msg= (MyEntry) eare.getEntry();
                     System.out.println("Got event! Notify Type:"  + 
                     getNotifyType(eare.getNotifyType())+ " object:" +msg);
              } catch (UnusableEntryException e) {
                     e.printStackTrace();
              }
       }
       private String getNotifyType(int notifyType)
       {
              String desc = "";
              if (NotifyModifiers.isWrite(notifyType))
                     desc = "Write";
       
              if (NotifyModifiers.isTake(notifyType))
                     desc = "Take";
          
              if (NotifyModifiers.isLeaseExpiration(notifyType))
                     desc = "LeaseExpiration";
 
              if (NotifyModifiers.isUpdate(notifyType))
                     desc = "Update";
 
              if (NotifyModifiers.isALL(notifyType))
                     desc = "ALL";
             
              return desc ;
       }
 
}

package com.j_spaces.examples.continuousquery;

import com.j_spaces.core.client.MetaDataEntry;
 
public class MyEntry extends MetaDataEntry{
 
       public MyEntry(){}
 
           public Long m_long = null;
           public Integer m_integer = null;
 
           public String toString()
           {
                  return "m_long:"+m_long + " m_integer:"+m_integer;
           }
           public static String[] __getSpaceIndexedFields()
           {
                  String[] indexedFields = { "m_long" , "m_integer"};
             
                  return indexedFields;
           }
}

gsInstance