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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
/**
* TestIvy, an AWT Ivy Java program example.
*
* toy tool to probe the Ivy software bus it relies on the AWT, and is less useable than
* TestIvySwing, which should be preferred if swing is on your JDK.
*
* @author Yannick Jestin
* @author <a href="http://www.tls.cena.fr/products/ivy/">http://www.tls.cena.fr/products/ivy/</a>
* @see fr.dgac.ivy.TestIvySwing
*
* (c) CENA
*
*/
import java.awt.* ;
import java.awt.event.* ;
import fr.dgac.ivy.*;
class TestIvy extends Frame implements IvyApplicationListener,IvyMessageListener {
public static String DEFAULTREGEXP = "(.*)";
private Ivy bus ;
private String regexp="";
private Label tfBound;
private TextField tfRegex, tfSend ;
private TextArea ta ;
private Button buApply, buSend, buClear ;
private java.text.SimpleDateFormat format = new java.text.SimpleDateFormat("hh:mm:ss");
private int regexp_id;
public TestIvy() throws IvyException {
addWindowListener( new WindowAdapter() { public void windowClosing(WindowEvent e) { System.exit(0); } });
setLayout(new BorderLayout());
ta = new TextArea();
ta.setEditable(false);
add(ta,BorderLayout.CENTER);
Panel p = new Panel(new BorderLayout());
add(p,BorderLayout.NORTH);
p.add(tfBound=new Label("Boung to: "+DEFAULTREGEXP),BorderLayout.WEST);
tfRegex = new TextField(regexp);
tfRegex.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
try { bus.unBindMsg(regexp_id); } catch (IvyException ie) {
System.out.println("Big badaboum"); // this should not happen
System.exit(0);
}
regexp=tfRegex.getText();
tfBound.setText("Bound to: " +regexp);
regexp.trim();
regexp_id = bus.bindMsg(regexp,TestIvy.this);
tfRegex.setText("");
pack();
}
});
p.add(tfRegex,BorderLayout.CENTER);
p = new Panel(new BorderLayout());
p.add(new Label("Msg:"),BorderLayout.WEST);
tfSend = new TextField("");
tfSend.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
int count;
String tosend = tfSend.getText();
tfSend.setText("");
count = bus.sendMsg(tosend);
append("Sending '" + tosend + "' count " + count );
}
});
p.add(tfSend,BorderLayout.CENTER);
add(p,BorderLayout.SOUTH);
bus = new Ivy("JAVATESTBUS","Testbus is ready",this);
regexp_id = bus.bindMsg(DEFAULTREGEXP,this);
bus.start(Ivy.getDomain(null));
append( "Ivy Domain: "+ bus.getDomain(null) );
}
public static void main(String[] args) throws IvyException {
TestIvy tb = new TestIvy();
tb.pack();
tb.setVisible(true);
}
public void connect(IvyClient client) { append(client.getApplicationName() + " connected " ); }
public void disconnect(IvyClient client) { append(client.getApplicationName() + " disconnected " ); }
public void die(IvyClient client, int id) { System.exit(0); }
public void directMessage(IvyClient client, int id, String arg) {
append(client.getApplicationName() + " direct Message "+ id + arg );
}
public void receive(IvyClient client, String[] args) {
String out="client " + client.getApplicationName() + " envoie: [ ";
for (int i=0;i<args.length;i++) out+=args[i]+ ((i<args.length-1)?" , ":"");
out+= " ]";
append(out);
}
private void append(String s) { ta.append("[" + format.format(new java.util.Date()) + "] "+ s + "\n"); }
}
|
