diff options
Diffstat (limited to 'examples/TestIvySwing.java')
| -rw-r--r-- | examples/TestIvySwing.java | 243 |
1 files changed, 243 insertions, 0 deletions
diff --git a/examples/TestIvySwing.java b/examples/TestIvySwing.java new file mode 100644 index 0000000..ed61741 --- /dev/null +++ b/examples/TestIvySwing.java @@ -0,0 +1,243 @@ +package fr.dgac.ivy ; + +import java.awt.BorderLayout; +import java.awt.event.*; +import javax.swing.* ; +import gnu.getopt.Getopt ; + +/** + * toy tool to probe the Ivy software bus. + * it relies on the Swing toolkit, which is not standard on jdk1.1 platform. + * if you don't have jdk1.2 or swing, consider downloading it. You can also + * use TestIvy + * + * @see fr.dgac.ivy.TestIvy + * @author François-Régis Colin + * @author Yannick Jestin + * @author <a href="http://www.tls.cena.fr/products/ivy/">http://www.tls.cena.fr/products/ivy/</a> + */ +class TestIvySwing extends JPanel implements IvyApplicationListener { + + /** + * help message for the standalone program + */ + public static final String helpmsg = "usage: java fr.dgac.ivy.TestIvySwing [options]\n\t-b BUS\tspecifies the Ivy bus domain\n\t-q\tquiet, no tty output\n\t-d\tdebug\n\t-h\thelp\n"; + public static final int WIDTH=30; + public static final int HEIGHT=30; + + private static int index; + private static int nbTIS=0; + private String localname; + private Ivy bus ; + private String domain; + private String regexp = "(.*)"; + private JLabel laRegex; + private JTextArea ta ; + private JTextField tfRegex, tfSend ; + private JButton buApply, buSend, buClear ; + private JComboBox ports; + private int regexp_id; + private REGCB reg; + private java.text.SimpleDateFormat format = new java.text.SimpleDateFormat("hh:mm:ss"); + private static String[] startDomainList = { + "127.255.255.255:2010", + "10.192.36:3110", + "10.0.0:54321", + "228.1.2.4:4567", + }; + private static java.util.Vector domainList; + + static { + // initialize the domainlist + domainList = new java.util.Vector(); + for (int i = 0; i<startDomainList.length;i++) + domainList.add(startDomainList[i]); + } + + public static void main(String[] args) throws IvyException { + String domain="127.255.255.255:2010"; + Getopt opt = new Getopt("Counter",args,"b:dhq"); + int c; + boolean quiet=false; + while ((c=opt.getopt()) != -1 ) switch(c) { + case 'q': + quiet=true; + break; + case 'b': + domain=opt.getOptarg(); + break; + case 'd': + System.setProperty("IVY_DEBUG","yesla!"); + break; + case 'h': + default: + System.out.println(helpmsg); + System.exit(0); + } + newTestIvy(domain); + } + + private TestIvySwing(String domain) throws IvyException { + super(new BorderLayout()); + this.domain=domain; + nbTIS++; + ta = new JTextArea(WIDTH,HEIGHT); + ta.setEditable(false); + add(new JScrollPane(ta),BorderLayout.CENTER); + JPanel p = new JPanel(new BorderLayout()); + p.add(new JLabel("Regex:"),BorderLayout.WEST); + tfRegex = new JTextField(); + tfRegex.addActionListener(reg=new REGCB()); + p.add(tfRegex,BorderLayout.CENTER); + p.add(laRegex=new JLabel(regexp),BorderLayout.EAST); + add(p,BorderLayout.NORTH); + JPanel p2 = new JPanel(new BorderLayout()); + p2.add(new JLabel("Msg:"),BorderLayout.WEST); + tfSend = new JTextField(""); + tfSend.addActionListener(new SENDCB()); + p2.add(tfSend,BorderLayout.CENTER); + p.add(p2,BorderLayout.SOUTH); + JButton tmpb ; + (p = new JPanel()).add(tmpb=new JButton("spawn")); + tmpb.addActionListener(new SPAWN(domain)); + p.add(tmpb=new JButton("clear")); + tmpb.addActionListener(new ActionListener() { + public void actionPerformed(ActionEvent e) { + ta.setText(""); + } + }); + ports=new JComboBox(); + ports.setEditable(true); + int index=0; + for (java.util.Enumeration e=domainList.elements();e.hasMoreElements();index++) { + String port = (String) e.nextElement(); + ports.addItem(port); + if (port == domain ) { ports.setSelectedIndex(index); } + } + ports.addActionListener(new ComboCB()); + p.add(ports); + add(p,BorderLayout.SOUTH); + tfRegex.setNextFocusableComponent(tfSend); + tfSend.setNextFocusableComponent(tfRegex); + tfSend.setRequestFocusEnabled(true); + localname = "TestIvySwing "+Ivy.libVersion+" ("+index+")"; + index++; + bus = new Ivy(localname,localname+" ready",this); + regexp_id = bus.bindMsg(regexp,reg); + bus.start(domain); + append( "Ivy Domain: "+ bus.getDomain(domain) ); + } + + 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) { + append(client.getApplicationName() + " die "+ id ); + } + + public void directMessage(IvyClient client, int id, String arg) { + append(client.getApplicationName() + " direct Message "+ id + arg ); + } + + private class ComboCB implements ActionListener { + public void actionPerformed(ActionEvent e) { + String newDomain=(String)ports.getSelectedItem(); + if (newDomain == domain) { + // if it's the same domain, don't do anything + return; + } + domain=newDomain; + try { + append( "deconnexion from domain "+ bus.getDomain(null)); + } catch ( IvyException ie ) { + System.err.println("deconnexion failed"); + } + bus.stop(); + try { + bus.start(newDomain); + append( "Ivy Domain: "+ newDomain ); + } catch (IvyException ie ) { + System.err.println("auuuugh "+newDomain); + } + } + } // ComboCB + + private class REGCB implements ActionListener, IvyMessageListener { + public void actionPerformed(ActionEvent e) { + try { + bus.unBindMsg(regexp_id); + } catch (IvyException ie) { + System.out.println("big badaboum"); // this cannot happen + } + regexp=tfRegex.getText(); + regexp.trim(); + regexp_id = bus.bindMsg(regexp,this); + tfRegex.setText(""); + laRegex.setText(regexp); + } + 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 class SENDCB implements ActionListener { + public void actionPerformed(ActionEvent e) { + int count; + String tosend = tfSend.getText(); + tfSend.setText(""); + if ( (count = bus.sendMsg(tosend)) != 0 ) + append("Sending '" + tosend + "' count " + count ); + else + append("not Sending '" + tosend + "' nobody cares"); + } + } + + private void append(String s) { + ta.insert("[" + format.format(new java.util.Date()) + "] "+ s + "\n",0); + } + + private static void newTestIvy(String domain) throws IvyException { + TestIvySwing tb = new TestIvySwing(domain); + JFrame f = new JFrame(tb.localname); + f.addWindowListener( tb.new WCCB(f,tb)) ; + f.getContentPane().add(tb, BorderLayout.CENTER); + f.pack(); + f.setVisible(true); + } + + private class WCCB extends WindowAdapter { + private JFrame f; + public WCCB(JFrame f, TestIvySwing b) { this.f=f; } + public void windowClosing(WindowEvent e) { + bus.stop(); + f.dispose(); + // I leave when the last TestIvySwing exits + if (--nbTIS == 0) System.exit(0); + } + public void windowActivated(WindowEvent e) {tfSend.grabFocus();} + } + + private class SPAWN implements ActionListener { + private String domain; + public SPAWN(String domain) {this.domain=domain;} + public void actionPerformed(ActionEvent e) { + try { + newTestIvy(domain); + } catch (IvyException ie) { + ie.printStackTrace(); + } + } + } + +} // class TestIvySwing +// EOF |