diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-08-31 14:37:26 +0200 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-08-31 14:37:26 +0200 |
commit | e8d27c8f5a01d3a77ff73cade12008d6411ab52b (patch) | |
tree | 6e576533fcada97d4767b2e336a52dc4ff16b8de /java/com/rsyslog/gui | |
parent | 85c654d1ecb3e3705b2004433c01c0735b7642da (diff) | |
download | rsyslog-e8d27c8f5a01d3a77ff73cade12008d6411ab52b.tar.gz rsyslog-e8d27c8f5a01d3a77ff73cade12008d6411ab52b.tar.xz rsyslog-e8d27c8f5a01d3a77ff73cade12008d6411ab52b.zip |
now supports sending UDP messages via multiple threads
Diffstat (limited to 'java/com/rsyslog/gui')
-rw-r--r-- | java/com/rsyslog/gui/msggen/MsgGen.java | 27 |
1 files changed, 17 insertions, 10 deletions
diff --git a/java/com/rsyslog/gui/msggen/MsgGen.java b/java/com/rsyslog/gui/msggen/MsgGen.java index 6591d401..0df22c8d 100644 --- a/java/com/rsyslog/gui/msggen/MsgGen.java +++ b/java/com/rsyslog/gui/msggen/MsgGen.java @@ -37,6 +37,8 @@ import javax.swing.*; public class MsgGen extends Frame { private TextField target; private TextField message; + private TextField nummsgs; + private TextField numthrds; public static void main(String args[]) { new MsgGen(); @@ -66,15 +68,23 @@ public class MsgGen extends Frame { /** creates the main GUI */ private void createGUI() { - target = new TextField("127.0.0.1", 32); + //target = new TextField("127.0.0.1", 32); + target = new TextField("172.19.3.3", 32); message = new TextField(80); - message.setText("<161>Test malformed"); + //message.setText("<161>Test malformed"); + message.setText("<5>iaalog[171652]: AIB|dcu|2009/08/12 14:48:43|mfa challenge|NNNNNNN|XX.XX.XX.XX"); + nummsgs = new TextField("1000", 8); + numthrds = new TextField("10", 5); Panel pCenter = new Panel(); pCenter.setLayout(new FlowLayout()); pCenter.add(new Label("Target Host:")); pCenter.add(target); + pCenter.add(new Label("Number of Msgs:")); + pCenter.add(nummsgs); pCenter.add(new Label("Msg:")); pCenter.add(message); + pCenter.add(new Label("Number of Threads:")); + pCenter.add(numthrds); Button b = new Button("Start Test"); b.addActionListener(new ActionListener() { @@ -96,14 +106,11 @@ public class MsgGen extends Frame { /** perform the test, a potentially complex operation */ private void performTest() { - try { - UDPSyslogSender sender = new UDPSyslogSender(target.getText()); - for(int i = 0 ; i < 100 ; ++i) - sender.sendMSG(message.getText()); - } - catch(Exception e) { - JOptionPane.showMessageDialog(this, e.toString(), "Error", - JOptionPane.ERROR_MESSAGE, null); + for(short i = 0 ; i < Integer.parseInt(numthrds.getText()) ; ++ i) { + SyslogTrafficGenerator gen = + new SyslogTrafficGenerator(target.getText(), message.getText(), + Long.parseLong(nummsgs.getText())); + gen.start(); } } |