I have made a Camel-Webservice-Router
Normally It return correct answer.
Using Jmeter, I had been doing Stress-Test at My Webservice.
Sometimes When Thread Count is reached in 140~150, It returned exception. (
java.net.BindException: Address already in use: connect)
and I had used ServiceHandler in ServiceMix Example,
Also, When Thread Count is reached in 140~150, It returned exception. (
java.net.BindException: Address already in use: connect)
What was problem?
if Camel Consumer Bean Thread was reached,
How can I limite that Thread?
Should I change tag("<camelcxf:cxfEndpoin>") ?
or Should I add parameter to?
Thanks your helps
==============================================================================
camel-router-soap.xml
==============================================================================
<blueprint
xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:jaxws="http://cxf.apache.org/jaxws";
xmlns:cm="
http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0";
xmlns:camelcxf="http://camel.apache.org/schema/blueprint/cxf";
xsi:schemaLocation="
http://www.osgi.org/xmlns/blueprint/v1.0.0
http://www.osgi.org/xmlns/blueprint/v1.0.1/blueprint.xsd";>
<cm:property-placeholder
persistent-id="test.camel.soap.route.bundleInfo" update-strategy="reload">
<cm:default-properties>
<cm:property name="BSOAPserver" value="http://192.168.0.5:8989
"/>
<cm:property name="BSOAPService"
value="/soap/blueprint/BundleTest" />
<cm:property name="DSOAPserver" value="http://192.168.0.5:8181
"/>
<cm:property name="DSOAPService" value="/test/blueprint/Bundle"
/>
</cm:default-properties>
</cm:property-placeholder>
<camelcxf:cxfEndpoint id="bundleInfoProvider"
address="${BSOAPserver}${BSOAPService}"
serviceClass="test.camel.soap.route.BundleInfoSEI" />
<camelcxf:cxfEndpoint id="bundleInfoConsumer"
address="${DSOAPserver}${DSOAPService}"
serviceClass=test.camel.soap.route.BundleInfoSEI"
/>
<camelContext xmlns="http://camel.apache.org/schema/blueprint";>
<route id="camelSoapServiceRoute">
<from uri="cxf:bean:bundleInfoProvider" />
<to uri="cxf:bean:bundleInfoConsumer" />
</route>
</camelContext>
</blueprint>.
==============================================================================
Exception
==============================================================================
org.apache.cxf.interceptor.Fault: Could not send Message.
at
org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:64)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:307)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.endpoint.ClientImpl.doInvoke(ClientImpl.java:514)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:416)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.camel.component.cxf.CxfProducer.process(CxfProducer.java:112)[217:org.apache.camel.camel-cxf:2.14.1]
at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:120)[213:org.apache.camel.camel-core:2.14.1]
at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)[213:org.apache.camel.camel-core:2.14.1]
at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)[213:org.apache.camel.camel-core:2.14.1]
at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:416)[213:org.apache.camel.camel-core:2.14.1]
at
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[213:org.apache.camel.camel-core:2.14.1]
at
org.apache.camel.processor.Pipeline.process(Pipeline.java:118)[213:org.apache.camel.camel-core:2.14.1]
at
org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[213:org.apache.camel.camel-core:2.14.1]
at
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[213:org.apache.camel.camel-core:2.14.1]
at
org.apache.camel.component.cxf.CxfConsumer$1.asyncInvoke(CxfConsumer.java:95)[217:org.apache.camel.camel-cxf:2.14.1]
at
org.apache.camel.component.cxf.CxfConsumer$1.invoke(CxfConsumer.java:75)[217:org.apache.camel.camel-cxf:2.14.1]
at
org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:59)[151:org.apache.cxf.cxf-core:3.0.2]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)[:1.7.0_75]
at java.util.concurrent.FutureTask.run(FutureTask.java:262)[:1.7.0_75]
at
org.apache.cxf.interceptor.ServiceInvokerInterceptor$2.run(ServiceInvokerInterceptor.java:126)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.workqueue.SynchronousExecutor.execute(SynchronousExecutor.java:37)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:131)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:307)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:121)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:243)[159:org.apache.cxf.cxf-rt-transports-http:3.0.2]
at
org.apache.cxf.transport.http_jetty.JettyHTTPDestination.doService(JettyHTTPDestination.java:261)[175:org.apache.cxf.cxf-rt-transports-http-jetty:3.0.2]
at
org.apache.cxf.transport.http_jetty.JettyHTTPHandler.handle(JettyHTTPHandler.java:70)[175:org.apache.cxf.cxf-rt-transports-http-jetty:3.0.2]
at
org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1088)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1024)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:255)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.server.Server.handle(Server.java:370)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:494)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.server.AbstractHttpConnection.content(AbstractHttpConnection.java:982)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.content(AbstractHttpConnection.java:1043)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:865)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:235)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:696)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:53)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at
org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543)[102:org.eclipse.jetty.aggregate.jetty-all-server:8.1.15.v20140411]
at java.lang.Thread.run(Thread.java:745)[:1.7.0_75]
Caused by: java.net.BindException: BindException invoking
http://192.168.0.5:8181/test/blueprint/Bundle: Address already in use:
connect
at sun.reflect.GeneratedConstructorAccessor81.newInstance(Unknown Source)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)[:1.7.0_75]
at
java.lang.reflect.Constructor.newInstance(Constructor.java:526)[:1.7.0_75]
at
org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.mapException(HTTPConduit.java:1359)[159:org.apache.cxf.cxf-rt-transports-http:3.0.2]
at
org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.close(HTTPConduit.java:1343)[159:org.apache.cxf.cxf-rt-transports-http:3.0.2]
at
org.apache.cxf.transport.AbstractConduit.close(AbstractConduit.java:56)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.transport.http.HTTPConduit.close(HTTPConduit.java:638)[159:org.apache.cxf.cxf-rt-transports-http:3.0.2]
at
org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:62)[151:org.apache.cxf.cxf-core:3.0.2]
... 42 more
Caused by: java.net.BindException: Address already in use: connect
at java.net.DualStackPlainSocketImpl.waitForConnect(Native
Method)[:1.7.0_75]
at
java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85)[:1.7.0_75]
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)[:1.7.0_75]
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)[:1.7.0_75]
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)[:1.7.0_75]
at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)[:1.7.0_75]
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)[:1.7.0_75]
at java.net.Socket.connect(Socket.java:579)[:1.7.0_75]
at sun.net.NetworkClient.doConnect(NetworkClient.java:175)[:1.7.0_75]
at sun.net.www.http.HttpClient.openServer(HttpClient.java:432)[:1.7.0_75]
at sun.net.www.http.HttpClient.openServer(HttpClient.java:527)[:1.7.0_75]
at sun.net.www.http.HttpClient.<init>(HttpClient.java:211)[:1.7.0_75]
at sun.net.www.http.HttpClient.New(HttpClient.java:308)[:1.7.0_75]
at sun.net.www.http.HttpClient.New(HttpClient.java:326)[:1.7.0_75]
at
sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:997)[:1.7.0_75]
at
sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:933)[:1.7.0_75]
at
sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:851)[:1.7.0_75]
at
sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1092)[:1.7.0_75]
at
org.apache.cxf.transport.http.URLConnectionHTTPConduit$URLConnectionWrappedOutputStream.setupWrappedStream(URLConnectionHTTPConduit.java:174)[159:org.apache.cxf.cxf-rt-transports-http:3.0.2]
at
org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.handleHeadersTrustCaching(HTTPConduit.java:1302)[159:org.apache.cxf.cxf-rt-transports-http:3.0.2]
at
org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.onFirstWrite(HTTPConduit.java:1258)[159:org.apache.cxf.cxf-rt-transports-http:3.0.2]
at
org.apache.cxf.transport.http.URLConnectionHTTPConduit$URLConnectionWrappedOutputStream.onFirstWrite(URLConnectionHTTPConduit.java:201)[159:org.apache.cxf.cxf-rt-transports-http:3.0.2]
at
org.apache.cxf.io.AbstractWrappedOutputStream.write(AbstractWrappedOutputStream.java:47)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.io.AbstractThresholdOutputStream.write(AbstractThresholdOutputStream.java:69)[151:org.apache.cxf.cxf-core:3.0.2]
at
org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.close(HTTPConduit.java:1315)[159:org.apache.cxf.cxf-rt-transports-http:3.0.2]
... 45 more
