public class TestLauncher extends Object implements ErrorHandler
Modifier and Type | Field and Description |
---|---|
protected String |
address |
protected List<AMQConnection> |
clients |
protected int |
connection_count |
protected AMQConnection |
controlCon |
protected javax.jms.Destination |
controlDest |
protected javax.jms.Session |
controlSession |
protected DateFormat |
df |
protected boolean |
durable |
protected String |
failover |
protected long |
heartbeat |
protected String |
host |
protected NumberFormat |
nf |
protected int |
port |
protected boolean |
receiver |
protected boolean |
sender |
protected int |
sessions_per_con |
protected javax.jms.MessageProducer |
statusSender |
protected String |
testName |
protected String |
url |
protected boolean |
useUniqueDests |
Constructor and Description |
---|
TestLauncher() |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
protected void |
createReceiver(String index,
AMQConnection con,
String addr,
ErrorHandler h) |
protected void |
createSender(String index,
AMQConnection con,
String addr,
ErrorHandler h) |
void |
handleError(String msg,
Exception e) |
static void |
main(String[] args) |
void |
setUpControlChannel() |
void |
start(String addr) |
protected String host
protected int port
protected int sessions_per_con
protected int connection_count
protected long heartbeat
protected boolean sender
protected boolean receiver
protected boolean useUniqueDests
protected String url
protected String address
protected boolean durable
protected String failover
protected AMQConnection controlCon
protected javax.jms.Destination controlDest
protected javax.jms.Session controlSession
protected javax.jms.MessageProducer statusSender
protected List<AMQConnection> clients
protected DateFormat df
protected NumberFormat nf
protected String testName
public void setUpControlChannel()
public void cleanup()
public void start(String addr)
protected void createReceiver(String index, AMQConnection con, String addr, ErrorHandler h)
protected void createSender(String index, AMQConnection con, String addr, ErrorHandler h)
public void handleError(String msg, Exception e)
handleError
in interface ErrorHandler
public static void main(String[] args)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.