svn commit: r957064 - in /jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client: OnMessageSubscriber.java Publisher.java

[se...@apache.org]

Author: sebb
Date: Tue Jun 22 22:26:10 2010
New Revision: 957064

URL: http://svn.apache.org/viewvc?rev=957064&view=rev
Log:
Rename fields

Modified:
    jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/OnMessageSubscriber.java
    jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/Publisher.java

Modified: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/OnMessageSubscriber.java
URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/OnMessageSubscriber.java?rev=957064&r1=957063&r2=957064&view=diff
==============================================================================
--- jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/OnMessageSubscriber.java (original)
+++ jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/OnMessageSubscriber.java Tue Jun 22 22:26:10 2010
@@ -58,19 +58,19 @@ public class OnMessageSubscriber {
      * @param jndi
      * @param url
      * @param connfactory
-     * @param topic
+     * @param destinationName
      * @param useAuth
      * @param user
      * @param pwd
      * @throws JMSException if could not create context or other problem occurred.
      * @throws NamingException 
      */
-    public OnMessageSubscriber(boolean useProps, String jndi, String url, String connfactory, String topic,
+    public OnMessageSubscriber(boolean useProps, String jndi, String url, String connfactory, String destinationName,
             boolean useAuth, String user, String pwd) throws JMSException, NamingException {
         Context ctx = InitialContextFactory.getContext(useProps, jndi, url, useAuth, user, pwd);
         CONN = Utils.getConnection(ctx, connfactory);
-        Destination dest = Utils.lookupDestination(ctx, topic);
         SESSION = CONN.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Destination dest = Utils.lookupDestination(ctx, destinationName);
         SUBSCRIBER = SESSION.createConsumer(dest);
         log.info("created the topic connection successfully");
     }

Modified: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/Publisher.java
URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/Publisher.java?rev=957064&r1=957063&r2=957064&view=diff
==============================================================================
--- jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/Publisher.java (original)
+++ jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/Publisher.java Tue Jun 22 22:26:10 2010
@@ -49,7 +49,7 @@ public class Publisher {
      * @param initialContextFactory the (ignored if useProps is true)
      * @param providerUrl (ignored if useProps is true)
      * @param connfactory
-     * @param topicName
+     * @param destinationName
      * @param useAuth (ignored if useProps is true)
      * @param securityPrincipal (ignored if useProps is true)
      * @param securityCredentials (ignored if useProps is true)
@@ -57,15 +57,15 @@ public class Publisher {
      * @throws NamingException 
      */
     public Publisher(boolean useProps, String initialContextFactory, String providerUrl, 
-            String connfactory, String topicName, boolean useAuth,
+            String connfactory, String destinationName, boolean useAuth,
             String securityPrincipal, String securityCredentials) throws JMSException, NamingException {
         super();
         Context ctx = InitialContextFactory.getContext(useProps, initialContextFactory, 
                 providerUrl, useAuth, securityPrincipal, securityCredentials);
         connection = Utils.getConnection(ctx, connfactory);
-        Destination topic = Utils.lookupDestination(ctx, topicName);
         session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-        producer = session.createProducer(topic);
+        Destination dest = Utils.lookupDestination(ctx, destinationName);
+        producer = session.createProducer(dest);
         log.info("created the topic connection successfully");
     }
 



---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@jakarta.apache.org
For additional commands, e-mail: notifications-help@jakarta.apache.org