Author: arnaudsimon
Date: Wed Dec 19 08:49:01 2007
New Revision: 605613
URL: http://svn.apache.org/viewvc?rev=605613&view=rev
Log:
fixed speling issues and pubsub ones
Modified:
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/common/BaseExample.java
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
Modified:
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/common/BaseExample.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/common/BaseExample.java?rev=605613&r1=605612&r2=605613&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/common/BaseExample.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/common/BaseExample.java
Wed Dec 19 08:49:01 2007
@@ -146,7 +146,7 @@
Hashtable<String, String> jndiEnvironment = new Hashtable<String,
String>();
jndiEnvironment.put(Context.INITIAL_CONTEXT_FACTORY,
INITIAL_CONTEXT_FACTORY_NAME);
jndiEnvironment.put("connectionfactory.ConnectionFactory",
-
"qpid:password=guest;username=guest;client_id=clientid;[EMAIL
PROTECTED]:192.168.1.11:5672");
+
"qpid:password=guest;username=guest;client_id=clientid;[EMAIL
PROTECTED]:127.0.0.1:5672");
if (getProviderURL() != null)
{
jndiEnvironment.put(Context.PROVIDER_URL, getProviderURL());
Modified:
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java?rev=605613&r1=605612&r2=605613&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
Wed Dec 19 08:49:01 2007
@@ -95,7 +95,7 @@
// lookup the topics usa
Topic topic = session.createTopic("usa.#");
// Create a Message Subscriber
- System.out.println(CLASS + ": Creating a Message Subscriber fpr
topic usa.#");
+ System.out.println(CLASS + ": Creating a Message Subscriber for
topic usa.#");
TopicSubscriber messageSubscriber =
session.createSubscriber(topic);
// Set a message listener on the messageConsumer
messageSubscriber.setMessageListener(new MyMessageListener("usa"));