I have slightly modified the example to be much more explicit. See http://cwiki.apache.org/SM/servicemix-wsn2005.html#servicemix-wsn2005-Subscribe
On 8/17/07, gnodet <[EMAIL PROTECTED]> wrote: > > 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. > > -- Cheers, Guillaume Nodet ------------------------ Blog: http://gnodet.blogspot.com/
