You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@servicemix.apache.org by timbo <bi...@ieee.org> on 2007/07/31 00:29:49 UTC
WSN PullPoint getMessages
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#a11885355
Sent from the ServiceMix - User mailing list archive at Nabble.com.
Re: WSN PullPoint getMessages
Posted by Guillaume Nodet <gn...@gmail.com>.
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 <gn...@gmail.com> 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
> > org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
> > 15:28:13,159 | DEBUG | wsn2005-thread-7 | SedaQueue
> > | ix.jbi.nmr.flow.seda.SedaQueue$1 132 |
> > org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1898582 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 |
> > org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@19cee52 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 |
> > org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1c334de 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:
> > HEP@23375256[d=true,io=0,w=true,b=0|0]
> > 15:28:13,284 | DEBUG | btpool0-2 | jetty
> > | .servicemix.http.jetty.JCLLogger 67 | resume continuation
> > org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
> > 15:28:13,284 | DEBUG | ol0-2 - /Broker/ | jetty
> > | .servicemix.http.jetty.JCLLogger 67 | REQUEST /Broker/ on
> > org.mortbay.jetty.HttpConnection@c0fee0
> > 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
> > org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
> > 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 =
> > org.apache.commons.httpclient.DefaultHttpMethodRetryHandler@167d3c4
> > 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 |
> > org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1053693 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/
Re: WSN PullPoint getMessages
Posted by timbo <bi...@ieee.org>.
ok this helps, thx Guillaume. i can now see my notifications posted against
the topic and pullpoint queue.
i'm assuming that the pullpoint can be accessed via http/soap using
WS-Addressing, but getMessages is not working, as shown below.
do i need something beyond this smx config to make this work? i hope smx
does not need additional static configuration to expose pullpoints that are
created dynamically by external clients...
i'll be more than happy to document a complete example for the wiki if we
can get this working.
<?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-binding1"
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>
messaging sequence:
++++++++++++++++++++++++++++++++++++++++++++++
1) createPullPoint:
<!-- sent to http://localhost:8192/CreatePullPoint -->
<env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
<env:Body>
<wsnt:CreatePullPoint
xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2"
xmlns:sm="http://servicemix.apache.org/wsn2005/1.0">
</wsnt:CreatePullPoint>
</env:Body>
</env:Envelope>
<env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
<env:Body>
<ns4: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://servicemix.org/wsnotification/PullPoint/ID-USMKETSBIERNA1-4946-1187638679054-6-0</ns2:Address>
</ns4:PullPoint>
</ns4:CreatePullPointResponse>
</env:Body>
</env:Envelope>
2) take returned address, and subscribe pullpoint as follows:
<!-- sent to http://localhost:8192/Broker -->
<env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
<env:Body>
<wsnt:Subscribe xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2"
xmlns:wsa="http://www.w3.org/2005/08/addressing">
<wsnt:ConsumerReference>
<wsa:Address>
<!-- returned from createPullPoint -->
endpoint:http://servicemix.org/wsnotification/PullPoint/ID-USMKETSBIERNA1-4946-1187638679054-6-0
</wsa:Address>
</wsnt:ConsumerReference>
<!-- <wsnt:UseNotify>false</wsnt:UseNotify> -->
<wsnt:Filter>
<wsnt:TopicExpression
Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple">
myTopic
</wsnt:TopicExpression>
</wsnt:Filter>
</wsnt:Subscribe>
</env:Body>
</env:Envelope>
<env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
<env:Body>
<ns4:SubscribeResponse
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"
xmlns:ns6="http://docs.oasis-open.org/wsn/br-2">
<ns4:SubscriptionReference>
<ns2:Address>http://servicemix.org/wsnotification/Subscription/ID-USMKETSBIERNA1-4946-1187638679054-3-0</ns2:Address>
</ns4:SubscriptionReference>
<ns4:TerminationTime xsi:nil="true"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"/>
</ns4:SubscribeResponse>
</env:Body>
</env:Envelope>
note: at this point myTopic is created in amq, and an endpoint for the
pullpoint is created in smx,.
3) notify
<!-- sent to http://localhost:8192/Broker -->
<soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
<soapenv:Header />
<soapenv:Body>
<wsnt:Notify xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2">
<wsnt:NotificationMessage>
<wsnt:Topic
Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple">
myTopic
</wsnt:Topic>
<wsnt:Message>
<hello>world</hello>
</wsnt:Message>
</wsnt:NotificationMessage>
</wsnt:Notify>
</soapenv:Body>
</soapenv:Envelope>
note: upon first notification, a queue is created for the pullpoint in amq
(queue has same id as smx pullpoint endpoint).
observe that myTopic EnqueueCount attribute increases with each
notification, and pullpoint queue EnqueueCount attribute increases also.
4) now try getMessages against pullpoint, using wsa to route to internal
endpoint:
<!-- sent to http://localhost:8192/Broker -->
<soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
xmlns:b="http://docs.oasis-open.org/wsn/b-2"
xmlns:wsa="http://www.w3.org/2005/08/addressing">
<soapenv:Header>
<wsa:To>
endpoint:http://servicemix.org/wsnotification/PullPoint/ID-USMKETSBIERNA1-4946-1187638679054-6-0
</wsa:To>
</soapenv:Header>
<soapenv:Body>
<b:GetMessages>
</b:GetMessages>
</soapenv:Body>
</soapenv:Envelope>
<<no response>>
<<log output>>
15:43:47,167 | DEBUG | @ localhost:8192 | JettyContextManager |
ContextManager$ThreadPoolWrapper 441 | Dispatching job:
HEP@29269302[d=true,io=1,w=true,b=0|0]
15:43:47,167 | DEBUG | ool0-1 - /Broker | jetty |
.servicemix.http.jetty.JCLLogger 67 | REQUEST /Broker on
org.mortbay.jetty.HttpConnection@1f5acd0
15:43:47,167 | DEBUG | ool0-1 - /Broker | jetty |
.servicemix.http.jetty.JCLLogger 67 | RESPONSE /Broker 302
+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
gnodet 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
>> org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
>> 15:28:13,159 | DEBUG | wsn2005-thread-7 | SedaQueue
>> | ix.jbi.nmr.flow.seda.SedaQueue$1 132 |
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1898582 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 |
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@19cee52 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 |
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1c334de 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:
>> HEP@23375256[d=true,io=0,w=true,b=0|0]
>> 15:28:13,284 | DEBUG | btpool0-2 | jetty
>> | .servicemix.http.jetty.JCLLogger 67 | resume continuation
>> org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
>> 15:28:13,284 | DEBUG | ol0-2 - /Broker/ | jetty
>> | .servicemix.http.jetty.JCLLogger 67 | REQUEST /Broker/ on
>> org.mortbay.jetty.HttpConnection@c0fee0
>> 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
>> org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
>> 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 =
>> org.apache.commons.httpclient.DefaultHttpMethodRetryHandler@167d3c4
>> 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 |
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1053693 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#a12243858
Sent from the ServiceMix - User mailing list archive at Nabble.com.
Re: WSN PullPoint getMessages
Posted by Nodet Guillaume <gn...@gmail.com>.
Sure. I think we could add a child page on servicemix-wsn2005 ?
can you try creating it ? If you can't just tell me and I will give
you karma to edit the wiki.
Cheers,
Guillaume Nodet
On Aug 22, 2007, at 6:07 PM, timbo wrote:
> to" whitepaper describing the scenario, and some wsn
> lessons learned. is there a place for it in smx wi
Re: WSN PullPoint getMessages
Posted by timbo <bi...@ieee.org>.
excellent, now works like a charm.
i have a short "howto" whitepaper describing the scenario, and some wsn
lessons learned. is there a place for it in smx wiki or docs?
Guillaume, thx again for your help.
gnodet wrote:
>
> This is an old problem that has never been fixed: in servicemix-http,
> all urls must end with a "/", else you receive a 302 error (moved
> temporarily). Just send your getMessages request to
> http://localhost:8192/Broker/
> instead of
> http://localhost:8192/Broker
>
> On 8/21/07, timbo <bi...@ieee.org> wrote:
>>
>> ok thx Guillaume, this is helpful. now i see notifications going to the
>> topic
>> & pullpoint.
>>
>> still unable to complete the scenario with pullpoint getMessages. i am
>> attempting to send
>> getMessages request using wsa to route to the internal pullpoint, but no
>> success
>> (messages/log below).
>>
>> in your soapui example you also send the request to the broker's http
>> endpoint using wsa.
>> what am i missing here ?
>
> --snip--
>
>
--
View this message in context: http://www.nabble.com/WSN-PullPoint-getMessages-tf4179625s12049.html#a12277915
Sent from the ServiceMix - User mailing list archive at Nabble.com.
Re: WSN PullPoint getMessages
Posted by Guillaume Nodet <gn...@gmail.com>.
This is an old problem that has never been fixed: in servicemix-http,
all urls must end with a "/", else you receive a 302 error (moved
temporarily). Just send your getMessages request to
http://localhost:8192/Broker/
instead of
http://localhost:8192/Broker
On 8/21/07, timbo <bi...@ieee.org> wrote:
>
> ok thx Guillaume, this is helpful. now i see notifications going to the topic
> & pullpoint.
>
> still unable to complete the scenario with pullpoint getMessages. i am
> attempting to send
> getMessages request using wsa to route to the internal pullpoint, but no
> success
> (messages/log below).
>
> in your soapui example you also send the request to the broker's http
> endpoint using wsa.
> what am i missing here ?
>
> this is my xbean.xml:
>
> <?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-binding1"
> 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>
>
> this is the message sequence and log error:
>
> 1) createPullPoint:
>
> <!-- sent to http://localhost:8192/CreatePullPoint -->
> <env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
> <env:Body>
>
> <wsnt:CreatePullPoint
> xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2"
> xmlns:sm="http://servicemix.apache.org/wsn2005/1.0">
>
> </wsnt:CreatePullPoint>
> </env:Body>
> </env:Envelope>
>
> <env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
> <env:Body>
> <ns4: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://servicemix.org/wsnotification/PullPoint/ID-USMKETSBIERNA1-4946-1187638679054-6-0</ns2:Address>
> </ns4:PullPoint>
> </ns4:CreatePullPointResponse>
> </env:Body>
> </env:Envelope>
>
> 2) take returned address, and subscribe pullpoint as follows:
>
> <!-- sent to http://localhost:8192/Broker -->
> <env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
> <env:Body>
> <wsnt:Subscribe xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2"
> xmlns:wsa="http://www.w3.org/2005/08/addressing">
> <wsnt:ConsumerReference>
> <wsa:Address>
> <!-- returned from createPullPoint -->
>
> endpoint:http://servicemix.org/wsnotification/PullPoint/ID-USMKETSBIERNA1-4946-1187638679054-6-0
> </wsa:Address>
> </wsnt:ConsumerReference>
> <!-- <wsnt:UseNotify>false</wsnt:UseNotify> -->
> <wsnt:Filter>
> <wsnt:TopicExpression
>
> Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple">
> myTopic
>
> </wsnt:TopicExpression>
> </wsnt:Filter>
> </wsnt:Subscribe>
> </env:Body>
> </env:Envelope>
>
> <env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
> <env:Body>
> <ns4:SubscribeResponse
>
> 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"
>
> xmlns:ns6="http://docs.oasis-open.org/wsn/br-2">
> <ns4:SubscriptionReference>
>
> <ns2:Address>http://servicemix.org/wsnotification/Subscription/ID-USMKETSBIERNA1-4946-1187638679054-3-0</ns2:Address>
> </ns4:SubscriptionReference>
> <ns4:TerminationTime xsi:nil="true"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"/>
> </ns4:SubscribeResponse>
> </env:Body>
> </env:Envelope>
>
>
> note: at this point the topic myTopic is created in amq, and an endpoint for
> the pullpoint is created in smx,.
>
> 3) notify
>
> <!-- sent to http://localhost:8192/Broker -->
> <soapenv:Envelope
> xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
>
> <soapenv:Header />
> <soapenv:Body>
> <wsnt:Notify xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2">
> <wsnt:NotificationMessage>
> <wsnt:Topic
>
> Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple">
> myTopic
>
> </wsnt:Topic>
> <wsnt:Message>
> <hello>world</hello>
> </wsnt:Message>
> </wsnt:NotificationMessage>
> </wsnt:Notify>
> </soapenv:Body>
> </soapenv:Envelope>
>
> note: upon first notification, a queue is created for the pullpoint in amq
> (queue has same id as smx pullpoint endpoint).
> observe that myTopic EnqueueCount attribute increases with each
> notification, and pullpoint queue EnqueueCount attribute
> increases also.
>
> 4) now try getMessages against pullpoint, using wsa to route to internal
> endpoint:
>
> <!-- sent to http://localhost:8192/Broker -->
> <soapenv:Envelope
> xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
>
> xmlns:b="http://docs.oasis-open.org/wsn/b-2"
>
> xmlns:wsa="http://www.w3.org/2005/08/addressing">
> <soapenv:Header>
> <wsa:To>
>
> endpoint:http://servicemix.org/wsnotification/PullPoint/ID-USMKETSBIERNA1-4946-1187638679054-6-0
> </wsa:To>
> </soapenv:Header>
> <soapenv:Body>
> <b:GetMessages>
> </b:GetMessages>
> </soapenv:Body>
> </soapenv:Envelope>
>
> <<no response>>
>
> <<log output>>
>
> 15:43:47,167 | DEBUG | @ localhost:8192 | JettyContextManager |
> ContextManager$ThreadPoolWrapper 441 | Dispatching job:
>
> HEP@29269302[d=true,io=1,w=true,b=0|0]
> 15:43:47,167 | DEBUG | ool0-1 - /Broker | jetty |
> .servicemix.http.jetty.JCLLogger 67 | REQUEST /Broker on
>
> org.mortbay.jetty.HttpConnection@1f5acd0
>
> 15:43:47,167 | DEBUG | ool0-1 - /Broker | jetty |
> .servicemix.http.jetty.JCLLogger 67 | RESPONSE /Broker 302
>
>
>
>
> gnodet 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
> >
> >
>
>
> --
> View this message in context: http://www.nabble.com/WSN-PullPoint-getMessages-tf4179625s12049.html#a12257338
>
> Sent from the ServiceMix - User mailing list archive at Nabble.com.
>
>
--
Cheers,
Guillaume Nodet
------------------------
Blog: http://gnodet.blogspot.com/
Re: WSN PullPoint getMessages
Posted by timbo <bi...@ieee.org>.
ok thx Guillaume, this is helpful. now i see notifications going to the topic
& pullpoint.
still unable to complete the scenario with pullpoint getMessages. i am
attempting to send
getMessages request using wsa to route to the internal pullpoint, but no
success
(messages/log below).
in your soapui example you also send the request to the broker's http
endpoint using wsa.
what am i missing here ?
this is my xbean.xml:
<?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-binding1"
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>
this is the message sequence and log error:
1) createPullPoint:
<!-- sent to http://localhost:8192/CreatePullPoint -->
<env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
<env:Body>
<wsnt:CreatePullPoint
xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2"
xmlns:sm="http://servicemix.apache.org/wsn2005/1.0">
</wsnt:CreatePullPoint>
</env:Body>
</env:Envelope>
<env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
<env:Body>
<ns4: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://servicemix.org/wsnotification/PullPoint/ID-USMKETSBIERNA1-4946-1187638679054-6-0</ns2:Address>
</ns4:PullPoint>
</ns4:CreatePullPointResponse>
</env:Body>
</env:Envelope>
2) take returned address, and subscribe pullpoint as follows:
<!-- sent to http://localhost:8192/Broker -->
<env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
<env:Body>
<wsnt:Subscribe xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2"
xmlns:wsa="http://www.w3.org/2005/08/addressing">
<wsnt:ConsumerReference>
<wsa:Address>
<!-- returned from createPullPoint -->
endpoint:http://servicemix.org/wsnotification/PullPoint/ID-USMKETSBIERNA1-4946-1187638679054-6-0
</wsa:Address>
</wsnt:ConsumerReference>
<!-- <wsnt:UseNotify>false</wsnt:UseNotify> -->
<wsnt:Filter>
<wsnt:TopicExpression
Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple">
myTopic
</wsnt:TopicExpression>
</wsnt:Filter>
</wsnt:Subscribe>
</env:Body>
</env:Envelope>
<env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/">
<env:Body>
<ns4:SubscribeResponse
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"
xmlns:ns6="http://docs.oasis-open.org/wsn/br-2">
<ns4:SubscriptionReference>
<ns2:Address>http://servicemix.org/wsnotification/Subscription/ID-USMKETSBIERNA1-4946-1187638679054-3-0</ns2:Address>
</ns4:SubscriptionReference>
<ns4:TerminationTime xsi:nil="true"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"/>
</ns4:SubscribeResponse>
</env:Body>
</env:Envelope>
note: at this point the topic myTopic is created in amq, and an endpoint for
the pullpoint is created in smx,.
3) notify
<!-- sent to http://localhost:8192/Broker -->
<soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
<soapenv:Header />
<soapenv:Body>
<wsnt:Notify xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2">
<wsnt:NotificationMessage>
<wsnt:Topic
Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple">
myTopic
</wsnt:Topic>
<wsnt:Message>
<hello>world</hello>
</wsnt:Message>
</wsnt:NotificationMessage>
</wsnt:Notify>
</soapenv:Body>
</soapenv:Envelope>
note: upon first notification, a queue is created for the pullpoint in amq
(queue has same id as smx pullpoint endpoint).
observe that myTopic EnqueueCount attribute increases with each
notification, and pullpoint queue EnqueueCount attribute
increases also.
4) now try getMessages against pullpoint, using wsa to route to internal
endpoint:
<!-- sent to http://localhost:8192/Broker -->
<soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
xmlns:b="http://docs.oasis-open.org/wsn/b-2"
xmlns:wsa="http://www.w3.org/2005/08/addressing">
<soapenv:Header>
<wsa:To>
endpoint:http://servicemix.org/wsnotification/PullPoint/ID-USMKETSBIERNA1-4946-1187638679054-6-0
</wsa:To>
</soapenv:Header>
<soapenv:Body>
<b:GetMessages>
</b:GetMessages>
</soapenv:Body>
</soapenv:Envelope>
<<no response>>
<<log output>>
15:43:47,167 | DEBUG | @ localhost:8192 | JettyContextManager |
ContextManager$ThreadPoolWrapper 441 | Dispatching job:
HEP@29269302[d=true,io=1,w=true,b=0|0]
15:43:47,167 | DEBUG | ool0-1 - /Broker | jetty |
.servicemix.http.jetty.JCLLogger 67 | REQUEST /Broker on
org.mortbay.jetty.HttpConnection@1f5acd0
15:43:47,167 | DEBUG | ool0-1 - /Broker | jetty |
.servicemix.http.jetty.JCLLogger 67 | RESPONSE /Broker 302
gnodet 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
>
>
--
View this message in context: http://www.nabble.com/WSN-PullPoint-getMessages-tf4179625s12049.html#a12257338
Sent from the ServiceMix - User mailing list archive at Nabble.com.
Re: WSN PullPoint getMessages
Posted by gnodet <gn...@gmail.com>.
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
> org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
> 15:28:13,159 | DEBUG | wsn2005-thread-7 | SedaQueue
> | ix.jbi.nmr.flow.seda.SedaQueue$1 132 |
> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1898582 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 |
> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@19cee52 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 |
> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1c334de 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:
> HEP@23375256[d=true,io=0,w=true,b=0|0]
> 15:28:13,284 | DEBUG | btpool0-2 | jetty
> | .servicemix.http.jetty.JCLLogger 67 | resume continuation
> org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
> 15:28:13,284 | DEBUG | ol0-2 - /Broker/ | jetty
> | .servicemix.http.jetty.JCLLogger 67 | REQUEST /Broker/ on
> org.mortbay.jetty.HttpConnection@c0fee0
> 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
> org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
> 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 =
> org.apache.commons.httpclient.DefaultHttpMethodRetryHandler@167d3c4
> 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 |
> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1053693 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.
Re: WSN PullPoint getMessages
Posted by timbo <bi...@ieee.org>.
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
org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
15:28:13,159 | DEBUG | wsn2005-thread-7 | SedaQueue |
ix.jbi.nmr.flow.seda.SedaQueue$1 132 |
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1898582 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 |
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@19cee52 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 |
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1c334de 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:
HEP@23375256[d=true,io=0,w=true,b=0|0]
15:28:13,284 | DEBUG | btpool0-2 | jetty |
.servicemix.http.jetty.JCLLogger 67 | resume continuation
org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
15:28:13,284 | DEBUG | ol0-2 - /Broker/ | jetty |
.servicemix.http.jetty.JCLLogger 67 | REQUEST /Broker/ on
org.mortbay.jetty.HttpConnection@c0fee0
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
org.mortbay.jetty.nio.SelectChannelConnector$RetryContinuation@19c21c6
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 =
org.apache.commons.httpclient.DefaultHttpMethodRetryHandler@167d3c4
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 |
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1@1053693 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.