i have made some further progress with smx wsn evaluation, primarily with help from this thread:
http://www.nabble.com/Creating-an-External-Pull-Point-Problem---gnodet--tf3303303s12049.html#a9191073 http://www.nabble.com/Creating-an-External-Pull-Point-Problem---gnodet--tf3303303s12049.html#a9191073 using the wsn-http example config, and gnodet's soapui test messages, i can createPullPoint and subscribe to it. but when i send the notify request, it looks like smx tries to send out a notify message to the pullpoint url, producing "java.net.UnknownHostException: test.org" (see full trace below). if i place a servlet at the pullpoint url, it recieves the post from smx (which is not a soap message as expected?!?) so 3 Q's remain: 1) why is smx trying to send messages out to the (external) pullpoint url? 2) why is the notify message sent not a soap message? 3) after notify, why pullpoint getMessages returns nothing? this is an important evaluation of smx for our company, so any help is much appreciated. if i have to walk through source, we may run out of time for the eval. ++++++++++++++++++++++++++++++++++++++ 15:28:13,143 | DEBUG | btpool0-2 | jetty | .servicemix.http.jetty.JCLLogger 67 | continuation [EMAIL PROTECTED] 15:28:13,159 | DEBUG | wsn2005-thread-7 | SedaQueue | ix.jbi.nmr.flow.seda.SedaQueue$1 132 | [EMAIL PROTECTED] dequeued exchange: InOnly[ id: ID:10.90.116.161-1147044ba56-2:3 status: Active role: provider service: {http://servicemix.org/wsnotification}NotificationBroker endpoint: Broker operation: {http://docs.oasis-open.org/wsn/brw-2}Notify in: <?xml version="1.0" encoding="UTF-8"?><b:Notify xmlns:b="http://docs.oasis-open.org/wsn/b-2"; xmlns:add="http://www.w3.org/2005/08/addressing"; xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/";> <b:NotificationMessage> <b:Topic Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple";> myTopic </b:Topic> <b:Message> <hello>world</hello> </b:Message> </b:NotificationMessage> </b:Notify> ] 15:28:13,159 | DEBUG | wsn2005-thread-7 | WSNComponent | icemix.common.AsyncBaseLifeCycle 419 | Received exchange: status: Active, role: provider 15:28:13,159 | DEBUG | wsn2005-thread-7 | WSNComponent | icemix.common.AsyncBaseLifeCycle 487 | Retrieved correlation id: ID:10.90.116.161-1147044ba56-2:3 15:28:13,175 | DEBUG | wsn2005-thread-7 | AbstractNotificationBroker | x.wsn.AbstractNotificationBroker 102 | Notify 15:28:13,237 | DEBUG | eMQ Session Task | DeliveryChannelImpl | bi.messaging.DeliveryChannelImpl 413 | Send ID:10.90.116.161-1147044ba56-3:0 in DeliveryChannel{servicemix-wsn2005} 15:28:13,237 | DEBUG | eMQ Session Task | SedaFlow | icemix.jbi.nmr.flow.AbstractFlow 121 | Called Flow send 15:28:13,268 | DEBUG | ix-http-thread-1 | SedaQueue | ix.jbi.nmr.flow.seda.SedaQueue$1 132 | [EMAIL PROTECTED] dequeued exchange: InOnly[ id: ID:10.90.116.161-1147044ba56-3:0 status: Active role: provider endpoint: http://test.org/service/endpoint in: <?xml version="1.0" encoding="UTF-8"?><ns2:Notify xmlns:ns2="http://docs.oasis-open.org/wsn/b-2"; xmlns="http://www.w3.org/2005/08/addressing"; xmlns:ns3="http://docs.oasis-open.org/wsrf/bf-2"; xmlns:ns4="http://docs.oasis-open.org/wsn/t-1";><ns2:NotificationMessage><ns2:Topic Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple";> myTopic </ns2:Topic><ns2:Message><hello xmlns="" xmlns:ns5="http://www.w3.org/2005/08/addressing";>world</hello></ns2:Message></ns2:NotificationMessage></ns2:Notify> ] 15:28:13,268 | DEBUG | ix-http-thread-1 | HttpComponent | icemix.common.AsyncBaseLifeCycle 419 | Received exchange: status: Active, role: provider 15:28:13,268 | DEBUG | wsn2005-thread-7 | DeliveryChannelImpl | bi.messaging.DeliveryChannelImpl 413 | Send ID:10.90.116.161-1147044ba56-2:3 in DeliveryChannel{servicemix-wsn2005} 15:28:13,284 | DEBUG | wsn2005-thread-7 | SedaFlow | icemix.jbi.nmr.flow.AbstractFlow 121 | Called Flow send 15:28:13,284 | DEBUG | wsn2005-thread-7 | SedaQueue | ix.jbi.nmr.flow.seda.SedaQueue$1 132 | [EMAIL PROTECTED] dequeued exchange: InOnly[ id: ID:10.90.116.161-1147044ba56-2:3 status: Done role: consumer service: {http://servicemix.org/wsnotification}NotificationBroker endpoint: Broker operation: {http://docs.oasis-open.org/wsn/brw-2}Notify in: <?xml version="1.0" encoding="UTF-8"?><b:Notify xmlns:b="http://docs.oasis-open.org/wsn/b-2"; xmlns:add="http://www.w3.org/2005/08/addressing"; xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/";> <b:NotificationMessage> <b:Topic Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple";> myTopic </b:Topic> <b:Message> <hello>world</hello> </b:Message> </b:NotificationMessage> </b:Notify> ] 15:28:13,284 | DEBUG | wsn2005-thread-7 | HttpComponent | icemix.common.AsyncBaseLifeCycle 419 | Received exchange: status: Done, role: consumer 15:28:13,284 | DEBUG | wsn2005-thread-7 | HttpComponent | icemix.common.AsyncBaseLifeCycle 487 | Retrieved correlation id: ID:10.90.116.161-1147044ba56-2:3 15:28:13,284 | DEBUG | wsn2005-thread-7 | ConsumerProcessor | ttp.processors.ConsumerProcessor 96 | Resuming continuation for exchange: ID:10.90.116.161-1147044ba56-2:3 15:28:13,284 | DEBUG | @ localhost:8192 | JettyContextManager | ContextManager$ThreadPoolWrapper 441 | Dispatching job: [EMAIL PROTECTED],io=0,w=true,b=0|0] 15:28:13,284 | DEBUG | btpool0-2 | jetty | .servicemix.http.jetty.JCLLogger 67 | resume continuation [EMAIL PROTECTED] 15:28:13,284 | DEBUG | ol0-2 - /Broker/ | jetty | .servicemix.http.jetty.JCLLogger 67 | REQUEST /Broker/ on [EMAIL PROTECTED] 15:28:13,284 | DEBUG | ol0-2 - /Broker/ | jetty | .servicemix.http.jetty.JCLLogger 67 | servlet=jbiServlet 15:28:13,284 | DEBUG | ol0-2 - /Broker/ | jetty | .servicemix.http.jetty.JCLLogger 67 | chain=null 15:28:13,284 | DEBUG | ol0-2 - /Broker/ | jetty | .servicemix.http.jetty.JCLLogger 67 | servelet holder=jbiServlet 15:28:13,284 | DEBUG | ol0-2 - /Broker/ | ConsumerProcessor | ttp.processors.ConsumerProcessor 120 | Receiving HTTP request: POST /Broker/ HTTP/1.1 Content-Type: text/xml;charset=UTF-8 SOAPAction: "" User-Agent: Jakarta Commons-HttpClient/3.0.1 Host: localhost:8192 Content-Length: 569 15:28:13,284 | DEBUG | ol0-2 - /Broker/ | jetty | .servicemix.http.jetty.JCLLogger 67 | RESPONSE /Broker/ 202 15:28:13,284 | DEBUG | btpool0-2 | jetty | .servicemix.http.jetty.JCLLogger 67 | continuation [EMAIL PROTECTED] 15:28:13,331 | DEBUG | ix-http-thread-1 | HttpComponent | icemix.common.AsyncBaseLifeCycle 487 | Retrieved correlation id: null 15:28:13,471 | DEBUG | ix-http-thread-1 | DefaultHttpParams | pclient.params.DefaultHttpParams 150 | Set parameter http.method.retry-handler = [EMAIL PROTECTED] 15:28:13,534 | DEBUG | ix-http-thread-1 | ltiThreadedHttpConnectionManager | ltiThreadedHttpConnectionManager 390 | HttpConnectionManager.getConnection: config = HostConfiguration[host=http://test.org], timeout = 0 15:28:13,534 | DEBUG | ix-http-thread-1 | ltiThreadedHttpConnectionManager | ConnectionManager$ConnectionPool 739 | Allocating new connection, hostConfig=HostConfiguration[host=http://test.org] 15:28:13,550 | DEBUG | ix-http-thread-1 | HttpConnection | ommons.httpclient.HttpConnection 691 | Open connection to test.org:80 15:28:21,268 | DEBUG | ix-http-thread-1 | HttpMethodDirector | ns.httpclient.HttpMethodDirector 403 | Closing the connection. 15:28:21,268 | DEBUG | ix-http-thread-1 | HttpMethodDirector | ns.httpclient.HttpMethodDirector 433 | Method retry handler returned false. Automatic recovery will not be attempted 15:28:21,268 | DEBUG | ix-http-thread-1 | HttpConnection | ommons.httpclient.HttpConnection 1177 | Releasing connection back to connection manager. 15:28:21,268 | DEBUG | ix-http-thread-1 | ltiThreadedHttpConnectionManager | ConnectionManager$ConnectionPool 943 | Freeing connection, hostConfig=HostConfiguration[host=http://test.org] 15:28:21,268 | DEBUG | ix-http-thread-1 | IdleConnectionHandler | lient.util.IdleConnectionHandler 75 | Adding connection at: 1187296101268 15:28:21,268 | DEBUG | ix-http-thread-1 | ltiThreadedHttpConnectionManager | ConnectionManager$ConnectionPool 926 | Notifying no-one, there are no waiting threads 15:28:21,284 | ERROR | ix-http-thread-1 | HttpComponent | .servicemix.common.BaseLifeCycle 48 | Error processing exchange InOnly[ id: ID:10.90.116.161-1147044ba56-3:0 status: Active role: provider endpoint: http://test.org/service/endpoint in: <?xml version="1.0" encoding="UTF-8"?><ns2:Notify xmlns:ns2="http://docs.oasis-open.org/wsn/b-2"; xmlns="http://www.w3.org/2005/08/addressing"; xmlns:ns3="http://docs.oasis-open.org/wsrf/bf-2"; xmlns:ns4="http://docs.oasis-open.org/wsn/t-1";><ns2:NotificationMessage><ns2:Topic Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple";> myTopic </ns2:Topic><ns2:Message><hello xmlns="" xmlns:ns5="http://www.w3.org/2005/08/addressing";>world</hello></ns2:Message></ns2:NotificationMessage></ns2:Notify> ] java.net.UnknownHostException: test.org at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:177) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366) at java.net.Socket.connect(Socket.java:519) at java.net.Socket.connect(Socket.java:469) at java.net.Socket.<init>(Socket.java:366) at java.net.Socket.<init>(Socket.java:239) at org.apache.commons.httpclient.protocol.DefaultProtocolSocketFactory.createSocket(DefaultProtocolSocketFactory.java:79) at org.apache.commons.httpclient.protocol.DefaultProtocolSocketFactory.createSocket(DefaultProtocolSocketFactory.java:121) at org.apache.commons.httpclient.HttpConnection.open(HttpConnection.java:706) at org.apache.commons.httpclient.MultiThreadedHttpConnectionManager$HttpConnectionAdapter.open(MultiThreadedHttpConnectionManager.java:1321) at org.apache.commons.httpclient.HttpMethodDirector.executeWithRetry(HttpMethodDirector.java:386) at org.apache.commons.httpclient.HttpMethodDirector.executeMethod(HttpMethodDirector.java:170) at org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:396) at org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:346) at org.apache.servicemix.http.processors.ProviderProcessor.process(ProviderProcessor.java:169) at org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:489) at org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:441) at org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLifeCycle.java:46) at org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:595) at org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:174) at org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:176) at org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134) at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:665) at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:690) at java.lang.Thread.run(Thread.java:595) 15:28:21,284 | DEBUG | ix-http-thread-1 | DeliveryChannelImpl | bi.messaging.DeliveryChannelImpl 413 | Send ID:10.90.116.161-1147044ba56-3:0 in DeliveryChannel{servicemix-http} 15:28:21,284 | DEBUG | ix-http-thread-1 | SedaFlow | icemix.jbi.nmr.flow.AbstractFlow 121 | Called Flow send 15:28:21,284 | DEBUG | ix-http-thread-2 | SedaQueue | ix.jbi.nmr.flow.seda.SedaQueue$1 132 | [EMAIL PROTECTED] dequeued exchange: InOnly[ id: ID:10.90.116.161-1147044ba56-3:0 status: Error role: consumer endpoint: http://test.org/service/endpoint in: <?xml version="1.0" encoding="UTF-8"?><ns2:Notify xmlns:ns2="http://docs.oasis-open.org/wsn/b-2"; xmlns="http://www.w3.org/2005/08/addressing"; xmlns:ns3="http://docs.oasis-open.org/wsrf/bf-2"; xmlns:ns4="http://docs.oasis-open.org/wsn/t-1";><ns2:NotificationMessage><ns2:Topic Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple";> myTopic </ns2:Topic><ns2:Message><hello xmlns="" xmlns:ns5="http://www.w3.org/2005/08/addressing";>world</hello></ns2:Message></ns2:NotificationMessage></ns2:Notify> error: java.net.UnknownHostException: test.org ++++++++++++++++++++++++++++++++++++++ timbo wrote: > > have wsn component working with subscribe and notify, topics and messages > can be viewed in the jmx console. now would like to createPullPont and > getMessages. createPullPoint request: > > <wsnt:CreatePullPoint > xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2"; > xmlns:sm="http://servicemix.apache.org/wsn2005/1.0";> > <sm:address> > http://www.consumer.org/service/endpoint > </sm:address> > </wsnt:CreatePullPoint> > > succeeds with this response: > > <CreatePullPointResponse xmlns:ns2="http://www.w3.org/2005/08/addressing"; > xmlns:ns3="http://docs.oasis-open.org/wsrf/bf-2"; > xmlns:ns4="http://docs.oasis-open.org/wsn/b-2"; > xmlns:ns5="http://docs.oasis-open.org/wsn/t-1";> > <ns4:PullPoint> > > <ns2:Address>http://www.consumer.org/service/endpoint</ns2:Address> > </ns4:PullPoint> > </CreatePullPointResponse> > > how do i construct a getMessages request for this example? i believe > was:To address is required. > my servicemix config is per the wsn-http example: > > <?xml version="1.0" encoding="UTF-8"?> > <beans xmlns:http="http://servicemix.apache.org/http/1.0"; > xmlns:wsn="http://servicemix.org/wsnotification";> > > <http:endpoint service="wsn:NotificationBroker" > endpoint="http-binding" > targetService="wsn:NotificationBroker" > targetEndpoint="Broker" > role="consumer" > locationURI="http://localhost:8192/Broker/"; > defaultMep="http://www.w3.org/2004/08/wsdl/in-out"; > soap="true"/> > > <http:endpoint service="wsn:CreatePullPoint" > endpoint="http-binding2" > targetService="wsn:CreatePullPoint" > targetEndpoint="Broker" > role="consumer" > locationURI="http://localhost:8192/CreatePullPoint/"; > defaultMep="http://www.w3.org/2004/08/wsdl/in-out"; > soap="true"/> > > </beans> > > > > > -- View this message in context: http://www.nabble.com/WSN-PullPoint-getMessages-tf4179625s12049.html#a12189225 Sent from the ServiceMix - User mailing list archive at Nabble.com.
