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" />
