Mercurial > hg > blitz_condensed

comparison examples/helloworld/Writer.java @ 0:3dc0c5604566

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Initial checkin of blitz 2.0 fcs - no installer yet.
author Dan Creswell <dan.creswell@gmail.com>
date Sat, 21 Mar 2009 11:00:06 +0000
parents
children
comparison
equal deleted inserted replaced
-1:000000000000 0:3dc0c5604566
1 package helloworld;
2
3 import java.rmi.RMISecurityManager;
4
5 import net.jini.space.JavaSpace;
6
7 import net.jini.core.entry.Entry;
8
9 import net.jini.core.lease.Lease;
10
11 import java.util.Random;
12
13 /**
14 Writer puts 5 randomly generated Entry's in the space which should
15 hopefully be found by Taker.
16 */
17 public class Writer {
18
19 public void exec() throws Exception {
20 // Locate a JavaSpace - we will only find those registered
21 // BEFORE we were started up - doing it properly requires
22 // ServiceDiscoveryManager - for examples of lookup (including
23 // the use of SDM) see:
24 // http://www.dancres.org/cottage/service_lookup.html
25 //
26 System.out.println("Looking for JavaSpace");
27
28 Lookup myFinder = new Lookup(JavaSpace.class);
29
30 JavaSpace mySpace = (JavaSpace) myFinder.getService();
31
32 System.out.println("Got space - writing Entry's");
33
34 Random myRNG = new Random();
35
36 for (int i = 0; i < 5; i++) {
37 TestEntry myEntry =
38 new TestEntry(Integer.toString(myRNG.nextInt()));
39
40 mySpace.write(myEntry, null, Lease.FOREVER);
41
42 System.out.println("Wrote: " + myEntry);
43 }
44 }
45
46 public static void main(String args[]) {
47 // We must set the RMI security manager to allow downloading of code
48 // which, in this case, is the Blitz proxy amongst other things
49 //
50 try {
51 if (System.getSecurityManager() == null)
52 System.setSecurityManager(new RMISecurityManager());
53
54 new Writer().exec();
55 } catch (Exception anE) {
56 System.err.println("Whoops");
57 anE.printStackTrace(System.err);
58 }
59 }
60 }