You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@jakarta.apache.org by se...@apache.org on 2010/06/22 18:45:19 UTC
svn commit: r956946 - in
/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client:
OnMessageSubscriber.java Publisher.java
Author: sebb
Date: Tue Jun 22 16:45:18 2010
New Revision: 956946
URL: http://svn.apache.org/viewvc?rev=956946&view=rev
Log:
Simplify getting topic connection
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=956946&r1=956945&r2=956946&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 16:45:18 2010
@@ -70,8 +70,7 @@ public class OnMessageSubscriber {
public OnMessageSubscriber(boolean useProps, String jndi, String url, String connfactory, String topic,
boolean useAuth, String user, String pwd) throws JMSException, NamingException {
Context ctx = InitialContextFactory.getContext(useProps, jndi, url, useAuth, user, pwd);
- ConnectionFactory.getTopicConnectionFactory(ctx, connfactory);
- CONN = ConnectionFactory.getTopicConnection();
+ CONN = ConnectionFactory.getTopicConnection(ctx, connfactory);
TOPIC = Utils.lookupTopic(ctx, topic);
SESSION = this.CONN.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);
SUBSCRIBER = this.SESSION.createSubscriber(this.TOPIC);
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=956946&r1=956945&r2=956946&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 16:45:18 2010
@@ -64,8 +64,7 @@ public class Publisher {
super();
Context ctx = InitialContextFactory.getContext(useProps, initialContextFactory,
providerUrl, useAuth, securityPrincipal, securityCredentials);
- ConnectionFactory.getTopicConnectionFactory(ctx,connfactory);
- connection = ConnectionFactory.getTopicConnection();
+ connection = ConnectionFactory.getTopicConnection(ctx, connfactory);
topic = Utils.lookupTopic(ctx, topicName);
session = connection.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);
publisher = session.createPublisher(topic);
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@jakarta.apache.org
For additional commands, e-mail: notifications-help@jakarta.apache.org