Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added overloaded method for createMessageConsumer 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411020 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Adrian T. Co 2006-06-02 02:40:31 +00:00
parent 29eef80774
commit dfe552d2f9
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsConfigurableClientSupport.java
View File

@ -145,6 +145,18 @@ public class JmsConfigurableClientSupport extends JmsBasicClientSupport {
return jmsMessageProducer;
}
public MessageConsumer createMessageConsumer(Destination dest) throws JMSException {
jmsMessageConsumer = getSession().createConsumer(dest);
configureJmsObject(jmsMessageConsumer, consumerSettings);
return jmsMessageConsumer;
}
public MessageConsumer createMessageConsumer(Destination dest, String selector) throws JMSException {
jmsMessageConsumer = getSession().createConsumer(dest, selector);
configureJmsObject(jmsMessageConsumer, consumerSettings);
return jmsMessageConsumer;
}
public MessageConsumer createMessageConsumer(Destination dest, String selector, boolean noLocal) throws JMSException {
jmsMessageConsumer = getSession().createConsumer(dest, selector, noLocal);
configureJmsObject(jmsMessageConsumer, consumerSettings);
@ -163,6 +175,12 @@ public class JmsConfigurableClientSupport extends JmsBasicClientSupport {
}
}
public TopicSubscriber createDurableSubscriber(Topic dest, String name) throws JMSException {
jmsMessageConsumer = getSession().createDurableSubscriber(dest, name);
configureJmsObject(jmsMessageConsumer, consumerSettings);
return (TopicSubscriber)jmsMessageConsumer;
}
public TopicSubscriber createDurableSubscriber(Topic dest, String name, String selector, boolean noLocal) throws JMSException {
jmsMessageConsumer = getSession().createDurableSubscriber(dest, name, selector, noLocal);
configureJmsObject(jmsMessageConsumer, consumerSettings);