|
Apache CXF example source code file (EmbeddedJMSBrokerLauncher.java)
The Apache CXF EmbeddedJMSBrokerLauncher.java source code/** * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * 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 * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ package org.apache.cxf.testutil.common; import java.io.File; import java.lang.reflect.Field; import java.util.List; import java.util.Map; import javax.wsdl.Definition; import javax.wsdl.Port; import javax.wsdl.Service; import javax.wsdl.extensions.soap.SOAPAddress; import org.apache.activemq.broker.BrokerService; import org.apache.activemq.store.memory.MemoryPersistenceAdapter; import org.apache.cxf.Bus; import org.apache.cxf.BusFactory; import org.apache.cxf.wsdl.WSDLManager; public class EmbeddedJMSBrokerLauncher extends AbstractBusTestServerBase { public static final String PORT = allocatePort(EmbeddedJMSBrokerLauncher.class); BrokerService broker; final String brokerUrl1 = "tcp://localhost:" + PORT; public static void updateWsdlExtensors(Bus bus, String wsdlLocation) { try { if (bus == null) { bus = BusFactory.getThreadDefaultBus(); } Definition def = bus.getExtension(WSDLManager.class) .getDefinition(wsdlLocation); Map map = def.getAllServices(); for (Object o : map.values()) { Service service = (Service)o; Map ports = service.getPorts(); for (Object p : ports.values()) { Port port = (Port)p; List<?> l = port.getExtensibilityElements(); for (Object e : l) { if (e instanceof SOAPAddress) { String add = ((SOAPAddress)e).getLocationURI(); int idx = add.indexOf("jndiURL="); if (idx != -1) { int idx2 = add.indexOf("&", idx); add = add.substring(0, idx) + "jndiURL=tcp://localhost:" + PORT + (idx2 == -1 ? "" : add.substring(idx2)); ((SOAPAddress)e).setLocationURI(add); } } else { try { Field f = e.getClass().getDeclaredField("jmsNamingProperty"); f.setAccessible(true); List<?> props = (List)f.get(e); for (Object prop : props) { f = prop.getClass().getDeclaredField("name"); f.setAccessible(true); if ("java.naming.provider.url".equals(f.get(prop))) { f = prop.getClass().getDeclaredField("value"); f.setAccessible(true); f.set(prop, "tcp://localhost:" + PORT); } } } catch (Exception ex) { //ignore } } } } } } catch (Exception e) { e.printStackTrace(); } } public void tearDown() throws Exception { if (broker != null) { broker.stop(); } } //START SNIPPET: broker public void run() { try { broker = new BrokerService(); broker.setPersistenceAdapter(new MemoryPersistenceAdapter()); broker.setTmpDataDirectory(new File("./target")); broker.addConnector(brokerUrl1); broker.start(); } catch (Exception e) { e.printStackTrace(); } } //END SNIPPET: broker public static void main(String[] args) { try { EmbeddedJMSBrokerLauncher s = new EmbeddedJMSBrokerLauncher(); s.start(); } catch (Exception ex) { ex.printStackTrace(); System.exit(-1); } finally { System.out.println("done!"); } } } Other Apache CXF examples (source code examples)Here is a short list of links related to this Apache CXF EmbeddedJMSBrokerLauncher.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.