The WS-Notification broker will send a notification message to the address you subscribed. If you have created a PullPoint, you need to create a subscription for it. The URI you give in your subscription must be a recognized URI: see http://incubator.apache.org/servicemix/uris.html.
It means, if you send "http://test.org"; in the URI, it will try to send a notification using http on the given uri. You need to try something like "endpoint:qname[sep]name". For the soap problem, you need to create a soap proxy for your PullPoint, which can be done by deploying a SU on the http component. Hope it helps, Guillaume Nodet timbo wrote: > > 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#a12195185 Sent from the ServiceMix - User mailing list archive at Nabble.com.
