Author: aco
Date: Thu Jun 1 19:40:31 2006
New Revision: 411020
URL: http://svn.apache.org/viewvc?rev=411020&view=rev
Log:
Added overloaded method for createMessageConsumer
Modified:
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsConfigurableClientSupport.java
Modified:
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsConfigurableClientSupport.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsConfigurableClientSupport.java?rev=411020&r1=411019&r2=411020&view=diff
==============================================================================
---
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsConfigurableClientSupport.java
(original)
+++
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsConfigurableClientSupport.java
Thu Jun 1 19:40:31 2006
@@ -145,6 +145,18 @@
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);
@@ -161,6 +173,12 @@
} catch (Exception e) {
return "";
}
+ }
+
+ 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 {
