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

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

public class Service
extends Object
implements MessageListener

Declare a queue and bind it to amq.direct with a 'well known' routing key, register a consumer for this queue and send a response to every message received.


Constructor Summary
Service(org.apache.qpid.client.AMQConnection connection)
           
Service(String broker)
           
 
Method Summary
 void close()
           
(package private) static org.apache.qpid.client.AMQConnection connect(String broker)
           
 void onMessage(Message request)
           
static void setQTC(QpidBrokerTestCase qtc)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Service

Service(String broker)
  throws Exception
Throws:
Exception

Service

Service(org.apache.qpid.client.AMQConnection connection)
  throws Exception
Throws:
Exception
Method Detail

setQTC

public static void setQTC(QpidBrokerTestCase qtc)

onMessage

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

close

public void close()
           throws JMSException
Throws:
JMSException

connect

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


Licensed to the Apache Software Foundation