activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a..@apache.org
Subject svn commit: r411020 - /incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/JmsConfigurableClientSupport.java
Date Fri, 02 Jun 2006 02:40:31 GMT
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 {



Mime
View raw message