org.apache.qpid.test.unit.client.forwardall
Class Client

java.lang.Object
  extended by org.apache.qpid.test.unit.client.forwardall.Client
All Implemented Interfaces:
MessageListener

public class Client
extends Object
implements MessageListener

Declare a private temporary response queue, send a message to amq.direct with a well known routing key with the private response queue as the reply-to destination consume responses.


Constructor Summary
Client(org.apache.qpid.client.AMQConnection connection, int expected)
           
Client(String broker, int expected)
           
 
Method Summary
(package private) static org.apache.qpid.client.AMQConnection connect(String broker)
           
static void main(String[] argv)
           
 void onMessage(Message response)
           
static void setQTC(QpidBrokerTestCase qtc)
           
(package private)  void shutdownWhenComplete()
           
(package private)  void waitUntilComplete()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Client

Client(String broker,
       int expected)
 throws Exception
Throws:
Exception

Client

Client(org.apache.qpid.client.AMQConnection connection,
       int expected)
 throws Exception
Throws:
Exception
Method Detail

setQTC

public static void setQTC(QpidBrokerTestCase qtc)

shutdownWhenComplete

void shutdownWhenComplete()
                    throws Exception
Throws:
Exception

onMessage

public void onMessage(Message response)
Specified by:
onMessage in interface MessageListener

waitUntilComplete

void waitUntilComplete()
                 throws Exception
Throws:
Exception

connect

static org.apache.qpid.client.AMQConnection connect(String broker)
                                             throws Exception
Throws:
Exception

main

public static void main(String[] argv)
                 throws Exception
Throws:
Exception


Licensed to the Apache Software Foundation