cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bimargul...@apache.org
Subject svn commit: r991036 - in /cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms: pom.xml src/main/java/demo/client/ClientJMS.java src/main/java/demo/server/ServerJMS.java src/main/resources/cxf.xml
Date Mon, 30 Aug 2010 23:56:38 GMT
Author: bimargulies
Date: Mon Aug 30 23:56:38 2010
New Revision: 991036

URL: http://svn.apache.org/viewvc?rev=991036&view=rev
Log:
This version actually works.

Modified:
    cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/pom.xml
    cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/java/demo/client/ClientJMS.java
    cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/java/demo/server/ServerJMS.java
    cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/resources/cxf.xml

Modified: cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/pom.xml
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/pom.xml?rev=991036&r1=991035&r2=991036&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/pom.xml (original)
+++ cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/pom.xml Mon Aug 30
23:56:38 2010
@@ -7,9 +7,9 @@
   to you under the Apache License, Version 2.0 (the
   "License"); you may not use this file except in compliance
   with the License. You may obtain a copy of the License at
- 
+
   http://www.apache.org/licenses/LICENSE-2.0
- 
+
   Unless required by applicable law or agreed to in writing,
   software distributed under the License is distributed on an
   "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@@ -62,6 +62,9 @@
                                 </goals>
                                 <configuration>
                                     <mainClass>demo.server.ServerJMS</mainClass>
+                                    <arguments>
+                                    	<argument>-activemqbroker</argument>
+                                    </arguments>
                                 </configuration>
                             </execution>
                         </executions>

Modified: cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/java/demo/client/ClientJMS.java
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/java/demo/client/ClientJMS.java?rev=991036&r1=991035&r2=991036&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/java/demo/client/ClientJMS.java
(original)
+++ cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/java/demo/client/ClientJMS.java
Mon Aug 30 23:56:38 2010
@@ -19,7 +19,6 @@
 
 package demo.client;
 
-import org.apache.cxf.interceptor.LoggingInInterceptor;
 import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
 
 import demo.service.HelloWorld;
@@ -27,10 +26,7 @@ import demo.service.HelloWorld;
 public final class ClientJMS {
 
 	public static void main(String[] args) throws Exception {
-		//Bus bus = new SpringBusFactory().createBus("jms.xml");
 		JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
-        factory.getInInterceptors().add(new LoggingInInterceptor());
-        factory.getOutInterceptors().add(new LoggingInInterceptor());
     	factory.setServiceClass(HelloWorld.class);
     	factory.setAddress("jms://");
     	HelloWorld client = (HelloWorld) factory.create();

Modified: cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/java/demo/server/ServerJMS.java
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/java/demo/server/ServerJMS.java?rev=991036&r1=991035&r2=991036&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/java/demo/server/ServerJMS.java
(original)
+++ cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/java/demo/server/ServerJMS.java
Mon Aug 30 23:56:38 2010
@@ -19,7 +19,8 @@
 
 package demo.server;
 
-import org.apache.cxf.interceptor.LoggingInInterceptor;
+import java.lang.reflect.Method;
+
 import org.apache.cxf.jaxws.JaxWsServerFactoryBean;
 
 import demo.service.HelloWorld;
@@ -28,15 +29,32 @@ import demo.service.impl.HelloWorldImpl;
 public class ServerJMS {
 
     public static void main(String args[]) throws Exception {
+
+    	boolean amqBroker = args.length > 0 && "-activemqbroker".equals(args[0]);
+    	if (amqBroker) {
+    	    /*
+    	     * The following make it easier to run this against something other than ActiveMQ.
+    	     * You will have to get a JMS broker onto the right port of localhost.
+    	     */
+    		Class<?> brokerClass = ServerJMS.class.getClassLoader().loadClass("org.apache.activemq.broker.BrokerService");
+    		if (brokerClass == null) {
+    		    System.err.println("ActiveMQ is not in the classpath, cannot launch broker.");
+    		    return;
+    		}
+    		Object broker = brokerClass.newInstance();
+    		Method addConnectorMethod = brokerClass.getMethod("addConnector", String.class);
+    		addConnectorMethod.invoke(broker, "tcp://localhost:61616");
+    		Method startMethod = brokerClass.getMethod("start");
+    		startMethod.invoke(broker);
+    	}
+
     	Object implementor = new HelloWorldImpl();
     	JaxWsServerFactoryBean svrFactory = new JaxWsServerFactoryBean();
         svrFactory.setServiceClass(HelloWorld.class);
         svrFactory.setAddress("jms://");
         svrFactory.setServiceBean(implementor);
-        svrFactory.getInInterceptors().add(new LoggingInInterceptor());
-        svrFactory.getOutInterceptors().add(new LoggingInInterceptor());
         svrFactory.create();
-        
+
         System.out.println("Server ready... Press any key to exit");
         System.in.read();
         System.out.println("Server exiting");

Modified: cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/resources/cxf.xml
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/resources/cxf.xml?rev=991036&r1=991035&r2=991036&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/resources/cxf.xml
(original)
+++ cxf/trunk/distribution/src/main/release/samples/java_first_jaxws_jms/src/main/resources/cxf.xml
Mon Aug 30 23:56:38 2010
@@ -17,15 +17,9 @@
 	<import resource="classpath:META-INF/cxf/cxf-extension-http.xml" />
 	<import resource="classpath:META-INF/cxf/cxf-servlet.xml" />
 	<import resource="classpath:META-INF/cxf/cxf-extension-jms.xml" />
-	
-	<cxf:bus>
-        <cxf:features>
-            <cxf:logging/>
-        </cxf:features>
-    </cxf:bus> 
 
 	<jms:conduit
-		name="{http://service.test/}HelloWorldPort.jms-conduit">
+		name="{http://service.demo/}HelloWorldPort.jms-conduit">
 		<!--
 		<jms:clientConfig clientReceiveTimeout="500"
 			messageTimeToLive="500" />
@@ -42,10 +36,10 @@
 				value="tcp://localhost:61616" />
 		</jms:address>
 	</jms:conduit>
-	
+
 	<jms:destination
-		name="{http://service.test/}HelloWorldPort.jms-destination">
-		<!-- 
+		name="{http://service.demo/}HelloWorldPort.jms-destination">
+		<!--
 		<jms:clientConfig clientReceiveTimeout="500"
 			messageTimeToLive="500" />
 		<jms:runtimePolicy messageType="binary" />



Mime
View raw message