Author: asanka
Date: Fri Jan 2 02:08:27 2009
New Revision: 730687
URL: http://svn.apache.org/viewvc?rev=730687&view=rev
Log:
Fixing the sample 381 to work with pure JMS api
Modified:
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/EventSubscriber.java
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/MDDConsumer.java
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/MDDProducer.java
synapse/trunk/java/repository/conf/sample/synapse_sample_381.xml
synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml
Modified:
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/EventSubscriber.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/EventSubscriber.java?rev=730687&r1=730686&r2=730687&view=diff
==============================================================================
---
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/EventSubscriber.java
(original)
+++
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/EventSubscriber.java
Fri Jan 2 02:08:27 2009
@@ -117,7 +117,7 @@
try {
OMElement response = serviceClient.sendReceive(subscribeOm);
System.out.println("Subscribed to topic " + topic);
- Thread.sleep(1000);
+ Thread.sleep(1000);
System.out.println("Response Received: " +
response.toString());
String subId =
response.getFirstChildWithName(new
QName(nswse.getNamespaceURI(), "SubscriptionManager"))
Modified:
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/MDDConsumer.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/MDDConsumer.java?rev=730687&r1=730686&r2=730687&view=diff
==============================================================================
---
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/MDDConsumer.java
(original)
+++
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/MDDConsumer.java
Fri Jan 2 02:08:27 2009
@@ -43,12 +43,13 @@
}
public void run(String dest) throws Exception {
InitialContext ic = getInitialContext();
- QueueConnectionFactory confac = (QueueConnectionFactory)
ic.lookup("ConnectionFactory");
- QueueConnection connection = confac.createQueueConnection();
- QueueSession session = connection.createQueueSession(false,
QueueSession.AUTO_ACKNOWLEDGE);
+ TopicConnectionFactory confac = (TopicConnectionFactory)
ic.lookup("ConnectionFactory");
+ TopicConnection connection = confac.createTopicConnection();
+ TopicSession session = connection.createTopicSession(false,
Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic(dest);
- MessageConsumer consumer = session.createConsumer(topic);
- consumer.setMessageListener(this);
+ TopicSubscriber topicSubscriber = session.createSubscriber(topic);
+ topicSubscriber.setMessageListener(this);
+ System.out.println("MDD-Consumer listening for topic :
"+topic.getTopicName());
connection.start();
}
public void onMessage(Message message){
@@ -66,7 +67,7 @@
if (System.getProperty("java.naming.factory.initial") == null) {
env.put("java.naming.factory.initial",
"org.apache.activemq.jndi.ActiveMQInitialContextFactory");
- }
+ }
return new InitialContext(env);
}
}
Modified:
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/MDDProducer.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/MDDProducer.java?rev=730687&r1=730686&r2=730687&view=diff
==============================================================================
---
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/MDDProducer.java
(original)
+++
synapse/trunk/java/modules/samples/src/main/java/samples/userguide/MDDProducer.java
Fri Jan 2 02:08:27 2009
@@ -62,7 +62,7 @@
InitialContext ic = getInitialContext();
QueueConnectionFactory confac = (QueueConnectionFactory)
ic.lookup("ConnectionFactory");
QueueConnection connection = confac.createQueueConnection();
- QueueSession session = connection.createQueueSession(false,
QueueSession.AUTO_ACKNOWLEDGE);
+ QueueSession session = connection.createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);
BytesMessage bm = session.createBytesMessage();
bm.writeBytes(buffer);
QueueSender sender = session.createSender((Queue)ic.lookup(destName));
Modified: synapse/trunk/java/repository/conf/sample/synapse_sample_381.xml
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/repository/conf/sample/synapse_sample_381.xml?rev=730687&r1=730686&r2=730687&view=diff
==============================================================================
--- synapse/trunk/java/repository/conf/sample/synapse_sample_381.xml (original)
+++ synapse/trunk/java/repository/conf/sample/synapse_sample_381.xml Fri Jan 2
02:08:27 2009
@@ -39,14 +39,14 @@
<case regex="GOOG">
<send>
<endpoint>
- <address
uri="jms:/mdd.GOOG?transport.jms.ConnectionFactoryJNDIName=TopicConnectionFactory&java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&java.naming.provider.url=tcp://localhost:61616&transport.jms.DestinationType=topic"/>
+ <address
uri="jms:/dynamicTopics/mdd.GOOG?transport.jms.ConnectionFactoryJNDIName=TopicConnectionFactory&java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&java.naming.provider.url=tcp://localhost:61616&transport.jms.DestinationType=topic"/>
</endpoint>
</send>
</case>
<case regex="MSFT">
<send>
<endpoint>
- <address
uri="jms:/mdd.MSFT?transport.jms.ConnectionFactoryJNDIName=TopicConnectionFactory&java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&java.naming.provider.url=tcp://localhost:61616&transport.jms.DestinationType=topic"/>
+ <address
uri="jms:/dynamicTopics/mdd.MSFT?transport.jms.ConnectionFactoryJNDIName=TopicConnectionFactory&java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&java.naming.provider.url=tcp://localhost:61616&transport.jms.DestinationType=topic"/>
</endpoint>
</send>
</case>
Modified: synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml?rev=730687&r1=730686&r2=730687&view=diff
==============================================================================
--- synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml (original)
+++ synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml Fri Jan 2 02:08:27
2009
@@ -3705,7 +3705,7 @@
<send>
<endpoint>
<address
-
uri="jms:/mdd.GOOG?transport.jms.ConnectionFactoryJNDIName=TopicConnectionFactory&amp;java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;java.naming.provider.url=tcp://localhost:61616&amp;transport.jms.DestinationType=topic"
/>
+
uri="jms:/dynamicTopics/mdd.GOOG?transport.jms.ConnectionFactoryJNDIName=TopicConnectionFactory&amp;java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;java.naming.provider.url=tcp://localhost:61616&amp;transport.jms.DestinationType=topic"
/>
</endpoint>
</send>
</case>
@@ -3713,7 +3713,7 @@
<send>
<endpoint>
<address
-
uri="jms:/mdd.MSFT?transport.jms.ConnectionFactoryJNDIName=TopicConnectionFactory&amp;java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;java.naming.provider.url=tcp://localhost:61616&amp;transport.jms.DestinationType=topic"
/>
+
uri="jms:/dynamicTopics/mdd.MSFT?transport.jms.ConnectionFactoryJNDIName=TopicConnectionFactory&amp;java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;java.naming.provider.url=tcp://localhost:61616&amp;transport.jms.DestinationType=topic"
/>
</endpoint>
</send>
</case>
