1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
/**
* an utility waiting for a message to come, then exiting.
*
* @author Yannick Jestin
* @author <a href="http://www.tls.cena.fr/products/ivy/">http://www.tls.cena.fr/products/ivy/</a>
*
* (c) CENA
*
* Changelog:
* 1.2.14
* - gracefully quits when message is received, by quitting the Ivy
* threads with bus.stop() , instead of invoking system.exit
* 1.2.8: new in the ivy package
*/
package fr.dgac.ivy.tools ;
import fr.dgac.ivy.* ;
import gnu.getopt.Getopt;
public class After extends IvyApplicationAdapter implements IvyMessageListener {
public final static int DEFAULTTIMEOUT = 0 ;
public static final String helpmsg = "usage: java fr.dgac.ivy.After [options] regexp\n\t-b BUS\tspecifies the Ivy bus domain\n\t-t\ttime out in seconds, defaults to "+DEFAULTTIMEOUT+"\n\t-h\thelp\n\n\t regexp is a Perl5 compatible regular expression";
public static void main(String[] args) throws IvyException {
Getopt opt = new Getopt("After",args,"b:t:");
int c;
String domain=Ivy.getDomain(null);
String name="AFTER";
int timeout = DEFAULTTIMEOUT;
while ((c = opt.getopt()) != -1) switch (c) {
case 'b': domain=opt.getOptarg(); break;
case 't': timeout=Integer.parseInt(opt.getOptarg()); break;
case 'h':
default: System.out.println(helpmsg); return;
}
if (opt.getOptind()!=args.length-1) { System.out.println(helpmsg); return; }
String regexp=args[opt.getOptind()];
Ivy bus=new Ivy(name,name+" ready",null);
bus.bindMsgOnce(regexp,new After(bus));
bus.start(domain);
if (timeout>0) {
System.out.println("waiting "+timeout+"s for "+regexp);
try { Thread.sleep(timeout*1000); } catch (InterruptedException ie) { }
System.out.println(regexp+" not received, bailing out");
bus.stop();
} else {
System.out.println("waiting forever for "+regexp);
}
}
private Ivy bus;
public After(Ivy b) {
bus=b;
bus.addApplicationListener(this);
}
public void die( IvyClient client, int id, String msgarg) {
System.out.println("die received, bailing out");
bus.stop();
}
public void receive(IvyClient ic,String[] args) {
bus.stop();
}
}
|
