At some places I was using send but now I have changed it to sendSync.
The thread configuration I have is like this for all components:
servicemix.corePoolSize = 16
servicemix.maximumPoolSize = 32
servicemix.queueSize = 256
I tried hitting 50 concurrent requests with a total of 300 requests. Still
it hangs. I have attached the whole log file.
The point where it hangs is
]
DEBUG - DeliveryChannelImpl - Notifying exchange
ID:192.168.2.64-11c46037c0f-2:13(4e9d18) in
DeliveryChannel{servicemix-camel} from processInboundSynchronousExchange
DEBUG - DeliveryChannelImpl - Notified:
ID:192.168.2.64-11c46037c0f-2:13(4e9d18) in
DeliveryChannel{servicemix-camel} from sendSync
DEBUG - DeliveryChannelImpl - SendSync
ID:192.168.2.64-11c46037c0f-2:28 in DeliveryChannel{servicemix-camel}
DEBUG - SecuredBroker - send exchange with secure broker
DEBUG - SecuredBroker - service name
:{http://servicemix.in2m.com/operations/updateprofile}ResponseGeneratorService
DEBUG - SecuredBroker - operation name :null
DEBUG - SedaFlow - Called Flow send
DEBUG - DeliveryChannelImpl - Waiting for exchange
ID:192.168.2.64-11c46037c0f-2:28 (14e7b87) to be answered in
DeliveryChannel{servicemix-camel} from sendSync
DEBUG - DeliveryChannelImpl - Send
ID:192.168.2.64-11c46037c0f-2:9 in DeliveryChannel{servicemix-jms}
DEBUG - SecuredBroker - send exchange with secure broker
DEBUG - SedaFlow - Called Flow send
DEBUG - SedaQueue -
[EMAIL PROTECTED] dequeued
exchange: InOnly[
id: ID:192.168.2.64-11c46037c0f-2:9
status: Done
role: consumer
service:
{http://servicemix.in2m.com/operations/updateprofile}JMSProviderService
endpoint: JMSProviderEndpoint
in: <?xml version="1.0" encoding="UTF-8"?><request
xmlns="http://www.finicity.com";>
<updateUserProfile>
<userName>0303user3</userName>
<firstName>pratibhaw</firstName>
<lastName>ghogalew</lastName>
<emailAddress>[EMAIL PROTECTED]</emailAddress>
</updateUserProfile>
</request>
]
DEBUG - DeliveryChannelImpl - Notifying exchange
ID:192.168.2.64-11c46037c0f-2:9(f1d485) in DeliveryChannel{servicemix-camel}
from processInboundSynchronousExchange
DEBUG - DeliveryChannelImpl - Send
ID:192.168.2.64-11c46037c0f-2:12 in DeliveryChannel{servicemix-jms}
DEBUG - DeliveryChannelImpl - Notified:
ID:192.168.2.64-11c46037c0f-2:9(f1d485) in DeliveryChannel{servicemix-camel}
from sendSync
DEBUG - DeliveryChannelImpl - SendSync
ID:192.168.2.64-11c46037c0f-2:29 in DeliveryChannel{servicemix-camel}
DEBUG - SecuredBroker - send exchange with secure broker
DEBUG - SedaFlow - Called Flow send
DEBUG - SedaQueue -
[EMAIL PROTECTED] dequeued
exchange: InOnly[
id: ID:192.168.2.64-11c46037c0f-2:12
status: Done
role: consumer
service:
{http://servicemix.in2m.com/operations/updateprofile}JMSProviderService
endpoint: JMSProviderEndpoint
in: <?xml version="1.0" encoding="UTF-8"?><request
xmlns="http://www.finicity.com";>
<updateUserProfile>
<userName>0303user3</userName>
<firstName>pratibhaw</firstName>
<lastName>ghogalew</lastName>
<emailAddress>[EMAIL PROTECTED]</emailAddress>
</updateUserProfile>
</request>
]
DEBUG - DeliveryChannelImpl - Notifying exchange
ID:192.168.2.64-11c46037c0f-2:12(d652c1) in
DeliveryChannel{servicemix-camel} from processInboundSynchronousExchange
DEBUG - DeliveryChannelImpl - Notified:
ID:192.168.2.64-11c46037c0f-2:12(d652c1) in
DeliveryChannel{servicemix-camel} from sendSync
DEBUG - DeliveryChannelImpl - SendSync
ID:192.168.2.64-11c46037c0f-2:30 in DeliveryChannel{servicemix-camel}
DEBUG - SecuredBroker - send exchange with secure broker
DEBUG - SecuredBroker - service name
:{http://servicemix.in2m.com/operations/updateprofile}ResponseGeneratorService
DEBUG - SecuredBroker - operation name :null
DEBUG - SedaFlow - Called Flow send
DEBUG - DeliveryChannelImpl - Waiting for exchange
ID:192.168.2.64-11c46037c0f-2:30 (175f214) to be answered in
DeliveryChannel{servicemix-camel} from sendSync
DEBUG - SecuredBroker - send exchange with secure broker
DEBUG - SecuredBroker - service name
:{http://servicemix.in2m.com/operations/updateprofile}ResponseGeneratorService
DEBUG - SecuredBroker - operation name :null
DEBUG - SedaFlow - Called Flow send
DEBUG - DeliveryChannelImpl - Waiting for exchange
ID:192.168.2.64-11c46037c0f-2:29 (6828d4) to be answered in
DeliveryChannel{servicemix-camel} from sendSync
DEBUG - DeliveryChannelImpl - Send
ID:192.168.2.64-11c46037c0f-2:14 in DeliveryChannel{servicemix-jms}
DEBUG - SecuredBroker - send exchange with secure broker
DEBUG - SedaFlow - Called Flow send
DEBUG - SedaQueue -
[EMAIL PROTECTED] dequeued
exchange: InOnly[
id: ID:192.168.2.64-11c46037c0f-2:14
status: Done
role: consumer
service:
{http://servicemix.in2m.com/operations/updateprofile}JMSProviderService
endpoint: JMSProviderEndpoint
in: <?xml version="1.0" encoding="UTF-8"?><request
xmlns="http://www.finicity.com";>
<updateUserProfile>
<userName>0303user3</userName>
<firstName>pratibhaw</firstName>
<lastName>ghogalew</lastName>
<emailAddress>[EMAIL PROTECTED]</emailAddress>
</updateUserProfile>
</request>
]
DEBUG - DeliveryChannelImpl - Notifying exchange
ID:192.168.2.64-11c46037c0f-2:14(12bb08f) in
DeliveryChannel{servicemix-camel} from processInboundSynchronousExchange
DEBUG - DeliveryChannelImpl - Notified:
ID:192.168.2.64-11c46037c0f-2:14(12bb08f) in
DeliveryChannel{servicemix-camel} from sendSync
DEBUG - DeliveryChannelImpl - SendSync
ID:192.168.2.64-11c46037c0f-2:31 in DeliveryChannel{servicemix-camel}
DEBUG - SecuredBroker - send exchange with secure broker
DEBUG - SecuredBroker - service name
:{http://servicemix.in2m.com/operations/updateprofile}ResponseGeneratorService
DEBUG - SecuredBroker - operation name :null
DEBUG - SedaFlow - Called Flow send
DEBUG - DeliveryChannelImpl - Waiting for exchange
ID:192.168.2.64-11c46037c0f-2:31 (178fd24) to be answered in
DeliveryChannel{servicemix-camel} from sendSync
After this nothing comes on my servicemix logs for some time and then I get
DEBUG - JettyContextManager - Dispatching job:
[EMAIL PROTECTED],pending,expired
DEBUG - ConsumerProcessor - Receiving HTTP request: POST
/updateUserProfile/ HTTP/1.1
Authorization: Basic cG9ydGFsOnBvcnRhbHBhc3M=
User-Agent: Jakarta Commons-HttpClient/3.1
Host: 192.168.2.64:8193
Content-Length: 260
WARN - jetty - /updateUserProfile/
java.lang.IllegalStateException: Exchange not found
at
org.apache.servicemix.http.processors.ConsumerProcessor.process(ConsumerProcessor.java:190)
at
org.apache.servicemix.http.HttpBridgeServlet.doPost(HttpBridgeServlet.java:71)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:617)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:690)
at
org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:487)
at
org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:362)
at
org.mortbay.jetty.security.SecurityHandler.handle(SecurityHandler.java:216)
at
org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:722)
at
org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:206)
at
org.mortbay.jetty.handler.HandlerCollection.handle(HandlerCollection.java:114)
at
org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:139)
at org.mortbay.jetty.Server.handle(Server.java:324)
at
org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:505)
at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:374)
at
org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:395)
at
org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation.run(SelectChannelConnector.java:506)
at
org.mortbay.thread.BoundedThreadPool$PoolThread.run(BoundedThreadPool.java:450)
DEBUG - JettyContextManager - Dispatching job:
[EMAIL PROTECTED],pending,expired
DEBUG - JettyContextManager - Dispatching job:
[EMAIL PROTECTED],pending,expired
DEBUG - JettyContextManager - Dispatching job:
[EMAIL PROTECTED],pending,expired
DEBUG - ConsumerProcessor - Receiving HTTP request: POST
/updateUserProfile/ HTTP/1.1
Authorization: Basic cG9ydGFsOnBvcnRhbHBhc3M=
User-Agent: Jakarta Commons-HttpClient/3.1
Host: 192.168.2.64:8193
Content-Length: 260
WARN - jetty - /updateUserProfile/
java.lang.IllegalStateException: Exchange not found
at
org.apache.servicemix.http.processors.ConsumerProcessor.process(ConsumerProcessor.java:190)
at
org.apache.servicemix.http.HttpBridgeServlet.doPost(HttpBridgeServlet.java:71)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:617)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:690)
at
org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:487)
at
org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:362)
at
org.mortbay.jetty.security.SecurityHandler.handle(SecurityHandler.java:216)
at
org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:722)
at
org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:206)
at
org.mortbay.jetty.handler.HandlerCollection.handle(HandlerCollection.java:114)
at
org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:139)
at org.mortbay.jetty.Server.handle(Server.java:324)
at
org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:505)
at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:374)
at
org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:395)
at
org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation.run(SelectChannelConnector.java:506)
at
org.mortbay.thread.BoundedThreadPool$PoolThread.run(BoundedThreadPool.java:450)
DEBUG - ConsumerProcessor - Receiving HTTP request: POST
/updateUserProfile/ HTTP/1.1
Authorization: Basic cG9ydGFsOnBvcnRhbHBhc3M=
User-Agent: Jakarta Commons-HttpClient/3.1
Host: 192.168.2.64:8193
Content-Length: 260
WARN - jetty - /updateUserProfile/
java.lang.IllegalStateException: Exchange not found
at
org.apache.servicemix.http.processors.ConsumerProcessor.process(ConsumerProcessor.java:190)
Here it hanged at ResponseGeneratorService, which is a bean service.
This happens either at ResponseGeneratorService or MessageEnricherService
which both are beans. Sometimes it happens at ValidateService which I am
creating in a bean like this
Destination destination = client.createDestination(getValidateService());
// Create New MessageExchange
InOut inOutExchange = destination.createInOutExchange();
// Get object of In Message
NormalizedMessage request =
inOutExchange.getInMessage();
request.setContent(inMessage.getContent());
request.setProperty("userPrincipals",roleString);
// Send the new exchange and wait for the anwer
client.sendSync(inOutExchange);
// Set the out of the inOutExchange into the out of the
current exchange and send back the current exchange
MessageUtil.transferToOut(inOutExchange.getMessage("out"), exchange);
client.done(inOutExchange);
channel.sendSync(exchange);
What is the problem?
Please see the attached log file.
http://www.nabble.com/file/p19387277/beanhang beanhang
I have said "Here it waited for a long time"
please reply
--
View this message in context:
http://www.nabble.com/Can-I-keep-thread-pool-size-200-for-bean-component--tp19386198p19387277.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
