Hi,

Please help. I am having problems resolving consumer endpoint in a wsn
example. I copied the org.apache.servicemix.components.util.TraceComponent
and created a ListenerBean which is behaving as the wsn consumer. The
xbean.xml for this is follows:

<beans xmlns:bean="http://servicemix.apache.org/bean/1.0";
       xmlns:consumer="http://servicemix.apache.org/examples/consumer";>
  <bean:endpoint service="consumer:ListenerService" endpoint="listen"
bean="#listenerBean"/>
  <bean id="listenerBean"
class="org.apache.servicemix.examples.consumer.ListenerBean"/>
</beans>

The notifiaction broker is deployed as shown in the wsn-httpbinding example.
I subscribed the ListenerBean as a consumer to topic "myTopic" by sending
the following message to the broker and got a subscription response.

<?xml version="1.0" encoding="UTF-8"?>
<env:Envelope xmlns:env="http://schemas.xmlsoap.org/soap/envelope/";
  xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2";
  xmlns:wsa="http://www.w3.org/2005/08/addressing";>

<env:Body>
<wsnt:Subscribe>
  <wsnt:ConsumerReference>
   
<wsa:Address>http://servicemix.apache.org/examples/consumer/ListenerService/listen/</wsa:Address>
  </wsnt:ConsumerReference>
  <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>


But when I send a notify message to the broker on "myTopic" it results in
the following error.


WARN  - DeliveryChannelImpl            - Error calling listener: null
java.lang.NullPointerException
        at
org.apache.servicemix.jbi.monitoring.StatisticsService.onExchangeAcce
pted(StatisticsService.java:307)
        at
org.apache.servicemix.jbi.monitoring.StatisticsService$3.exchangeAcce
pted(StatisticsService.java:186)
        at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
d(DeliveryChannelImpl.java:598)
        at
org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
w.java:170)
        at
org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
ava:167)
        at
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
a:134)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec
utor.java:650)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:675)
        at java.lang.Thread.run(Thread.java:595)
ERROR - HttpComponent                  - Error processing exchange InOnly[
  id: ID:128.107.143.159-117f626add0-18:1
  status: Active
  role: provider
  endpoint:
http://servicemix.apache.org/examples/crscon/ListenerService/listen/

  in: <?xml version="1.0" encoding="UTF-8"?><ns2:Notify
xmlns:ns2="http://docs.o
asis-open.org/wsn/b-2" xmlns="http://www.w3.org/2005/08/addressing";
xmlns:ns3="h
ttp://docs.oasis-open.org/wsrf/bf-2"
xmlns:ns4="http://docs.oasis-open.org/wsn/t
-1"><ns2:NotificationMessage><ns2:Topic>myTopic</ns2:Topic><ns2:Message><hello
x
mlns=""
xmlns:ns5="http://www.w3.org/2005/08/addressing";>world</hello></ns2:Mess
age></ns2:NotificationMessage></ns2:Notify>
]
java.lang.Exception: Invalid status response: 404
        at
org.apache.servicemix.http.processors.ProviderProcessor.process(Provi
derProcessor.java:181)
        at
org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLi
feCycle.java:538)
        at
org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(Async
BaseLifeCycle.java:490)
        at
org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLife
Cycle.java:46)
        at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
d(DeliveryChannelImpl.java:610)
        at
org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
w.java:170)
        at
org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
ava:167)
        at
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
a:134)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec
utor.java:650)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:675)
        at java.lang.Thread.run(Thread.java:595)

Nithya
-- 
View this message in context: 
http://www.nabble.com/problem-resolving-endpoint-uri-tp15345958s12049p15345958.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.

Reply via email to