Transport my own data types form wsn-producer to wsn-consumer

[ciel]

Hello,sir,
I want to Transport my own data types  form wsn-producer to wsn-consumer, such as follows:

package org.apache.ws.muse.test.wsrf;

class WsnTestDateType {
        WsnTestDateType (){};
        WsnTestDateType (int ID, String name){
                this.ID = ID;
                this.name = name;
        }
        public int getID() {
                return ID;
        }
        public void setID(int id) {
                ID = id;
        }
        public String getName() {
                return name;
        }
        public void setName(String name) {
                WsnTestDateType.name = name;
        }
        private static int ID;
        private static String name;
}
If I have done this

WsnTestDateType studentMessage = new WsnTestDateType (int ID, String name)(int ID, String name);

How could I use wsn.publish(_TOPIC_NAME, payload) to set studentMessage to wsn-consumer and receive it? Any examples?

Besides, if I replace WsnTestDateType  with a xml document as follows, how should I do?

//stuService.xml
<?xml version="1.0" encoding="UTF-8"?>
<ns:stuInfo xmlns:ns="http://localhost:8080/stuService.xsd"><ns:shipmentID>1</ns:shipmentID>
   <ns:stuID>25</ns:stuID>
   <ns:stuName>Joe</ns:stuName>
</ns:stuInfo>

//stuService.xsd
<?xml version="1.0" encoding="UTF-8"?>
<xsd:schema xmlns="http://localhost:8080/stuService.xsd" xmlns:xsd="http://www.w3.org/2001/XMLSchema" targetNamespace="http://localhost:8080/stuService.xsd" elementFormDefault="qualified" attributeFormDefault="unqualified">
        <xsd:element name="stuInfo">
                <xsd:complexType>
                        <xsd:sequence>
                                <xsd:element name="stuID" type="xsd:int"/>
                                <xsd:element name="stuName" type="xsd:string"/>
                        </xsd:sequence>
                </xsd:complexType>
        </xsd:element>
</xsd:schema>

Thanks very much. I am looking forward to your reply.

[Lenni Madsen]

here's a bit of code that I introduced in my test case.

public Element runtimeEventOperation() throws Exception{
      WefFactory factory = new SimpleWefFactory();
      ManagementEvent event = factory.createEvent();
     
      Component reporter = factory.createComponent();
      ComponentAddress reporterAddress =  
factory
.createComponentAddress(getResource().getEndpointReference().toXML());
      reporter.setAddress(reporterAddress);
      reporter.setName(WefConstants.REPORTER_COMP_QNAME);
     
      Component source = factory.createComponent();
      ComponentAddress sourceAddress =  
factory
.createComponentAddress(getResource().getEndpointReference().toXML());
      source.setAddress(sourceAddress);
      source.setName(WefConstants.SOURCE_COMP_QNAME);
     
      Situation situation = factory.createSituation();
     
situation.setCategoryType(WefConstants.AVAILABILITY_SITUATION_QNAME);
      situation.setPriority(Situation.HIGH_PRIORITY);
      situation.setMessage("Something important has happened in the  
"+getServerName()+"!"); // this is your string only message
      event.setReporter(reporter);
      event.setSource(source);
      event.setSituation(situation);
     
      event.addExtendedElement(MessageExtension()); // this is where  
you can put your XML, the standard allows for a xml extension
     
      try{
                        runtimeNotification.publish(_TOPIC_NAME, event); // the actual  
request to send the notification
                }catch (Throwable error){
                        error.printStackTrace();
                }
      return event.toXML();
     }

/////// an example that should give the rough idea of how to build a  
wsn-producer

//
// MyCapability.java
// Thu Apr 05 11:59:12 BST 2007
// Generated by the Apache Muse Code Generation Tool
//
import javax.xml.namespace.QName;

import org.apache.muse.core.Resource;
import org.apache.muse.core.ResourceManager;
import org.apache.muse.util.xml.XmlUtils;
import org.apache.muse.ws.addressing.EndpointReference;
import org.apache.muse.ws.addressing.soap.SoapFault;
import org.apache.muse.ws.dm.muws.events.Component;
import org.apache.muse.ws.dm.muws.events.ComponentAddress;
import org.apache.muse.ws.dm.muws.events.ManagementEvent;
import org.apache.muse.ws.dm.muws.events.Situation;
import org.apache.muse.ws.dm.muws.events.WefConstants;
import org.apache.muse.ws.dm.muws.events.WefFactory;
import org.apache.muse.ws.dm.muws.events.impl.SimpleWefFactory;
import org.apache.muse.ws.notification.NotificationProducer;
import org.apache.muse.ws.notification.WsnConstants;
import org.apache.muse.ws.resource.impl.AbstractWsResourceCapability;
import org.w3c.dom.Element;

public class MyCapability extends AbstractWsResourceCapability  
implements IMyCapability
{
        private NotificationProducer runtimeNotification;
       
        private static final QName _TOPIC_NAME = new QName(NAMESPACE_URI,  
"RuntimeEvent", PREFIX);
        /**
         * Only internal objects are guarentied to be instantiated, do not  
depend on objects/Capabilities outside this Capability
         */
     public void initialize() throws SoapFault
     {
         super.initialize();
     }
     /**
         * External capabilities are instantiated and can be used
         */
     public void initializeCompleted()throws SoapFault{
      super.initializeCompleted();
      runtimeNotification =  
(NotificationProducer
)getResource().getCapability(WsnConstants.PRODUCER_URI);
                // add list of Topics if needed
                runtimeNotification.addTopic(_TOPIC_NAME);
     }

     /**
         * External capabilities are instantiated and can be used (last chance)
         */
        public void prepareShutdown() throws SoapFault{
                super.prepareShutdown();
        }
        /**
         * Only internal objects are guaranteed to be instantiated, do not  
depend on objects/Capabilities outside this Capability
         */
        public void shutdown() throws SoapFault{
                super.shutdown();
        }
       
     private static final QName[] _PROPERTIES = new QName[]
     {
      new QName(NAMESPACE_URI, "ServerName", PREFIX),
         new QName(NAMESPACE_URI, "TestProperty", PREFIX),
         new QName(NAMESPACE_URI, "MessageInterval", PREFIX)
     };

     public QName[] getPropertyNames()
     {
         return _PROPERTIES;
     }

     private String _ServerName = "WsSomething";

     private String[] _TestProperty;

     private int _MessageInterval = 0;

     public String getServerName()
     {
         return _ServerName;
     }

     public void setServerName(String param0)
     {
         _ServerName = param0;
     }

     public String[] getTestProperty()
     {
         return _TestProperty;
     }

     public void setTestProperty(String[] param0)
     {
         _TestProperty = param0;
     }

     public int getMessageInterval()
     {
         return _MessageInterval;
     }

     public void setMessageInterval(int param0)
     {
         _MessageInterval = param0;
     }

     public Element runtimeEventOperation() throws Exception{
      WefFactory factory = new SimpleWefFactory();
      ManagementEvent event = factory.createEvent();
     
      Component reporter = factory.createComponent();
      ComponentAddress reporterAddress =  
factory
.createComponentAddress(getResource().getEndpointReference().toXML());
      reporter.setAddress(reporterAddress);
      reporter.setName(WefConstants.REPORTER_COMP_QNAME);
     
      Component source = factory.createComponent();
      ComponentAddress sourceAddress =  
factory
.createComponentAddress(getResource().getEndpointReference().toXML());
      source.setAddress(sourceAddress);
      source.setName(WefConstants.SOURCE_COMP_QNAME);
     
      Situation situation = factory.createSituation();
     
situation.setCategoryType(WefConstants.AVAILABILITY_SITUATION_QNAME);
      situation.setPriority(Situation.HIGH_PRIORITY);
      situation.setMessage("Something important has happened in the  
"+getServerName()+"!");
      event.setReporter(reporter);
      event.setSource(source);
      event.setSituation(situation);
     
      event.addExtendedElement(MessageExtension());
     
      try{
                        getLog().info("Sending message to consumers...");
                        runtimeNotification.publish(_TOPIC_NAME, event);
                }catch (Throwable error){
                        error.printStackTrace();
                }
      return event.toXML();
     }

     private Element MessageExtension(){
      // create your XML message
     }
}

/Lenni

On May 20, 2009, at 10:47 GMT+02:00, ciel wrote:

>
> Hello,sir,
> I want to Transport my own data types  form wsn-producer to wsn-
> consumer,
> such as follows:
>
> package org.apache.ws.muse.test.wsrf;
>
> class WsnTestDateType {
> WsnTestDateType (){};
> WsnTestDateType (int ID, String name){
> this.ID = ID;
> this.name = name;
> }
> public int getID() {
> return ID;
> }
> public void setID(int id) {
> ID = id;
> }
> public String getName() {
> return name;
> }
> public void setName(String name) {
> WsnTestDateType.name = name;
> }
> private static int ID;
> private static String name;
> }
> If I have done this
>
> WsnTestDateType studentMessage = new WsnTestDateType (int ID, String
> name)(int ID, String name);
>
> How could I use wsn.publish(_TOPIC_NAME, payload) to set  
> studentMessage to
> wsn-consumer and receive it? Any examples?
>
> Besides, if I replace WsnTestDateType  with a xml document as  
> follows, how
> should I do?
>
> //stuService.xml
> <?xml version="1.0" encoding="UTF-8"?>
> <ns:stuInfo
> xmlns:ns="http://localhost:8080/stuService.xsd"><ns:shipmentID>1</
> ns:shipmentID>
>   <ns:stuID>25</ns:stuID>
>   <ns:stuName>Joe</ns:stuName>
> </ns:stuInfo>
>
> //stuService.xsd
> <?xml version="1.0" encoding="UTF-8"?>
> <xsd:schema xmlns="http://localhost:8080/stuService.xsd"
> xmlns:xsd="http://www.w3.org/2001/XMLSchema"
> targetNamespace="http://localhost:8080/stuService.xsd"
> elementFormDefault="qualified" attributeFormDefault="unqualified">
> <xsd:element name="stuInfo">
> <xsd:complexType>
> <xsd:sequence>
> <xsd:element name="stuID" type="xsd:int"/>
> <xsd:element name="stuName" type="xsd:string"/>
> </xsd:sequence>
> </xsd:complexType>
> </xsd:element>
> </xsd:schema>
>
> Thanks very much. I am looking forward to your reply.
> --
> View this message in context: http://www.nabble.com/Transport-my-own-data-types--form-wsn-producer-to-wsn-consumer-tp23631392p23631392.html
> Sent from the Muse User mailing list archive at Nabble.com.
>

[ciel]

ok,thanks very much.
when I indroduced your code in wsn-producer, it produced:

*******************************************************
2009-5-21 15:27:50 org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1 run
信息: Sending message to consumers...
[CLIENT TRACE] SOAP envelope contents (outgoing):

<soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope">
    <soap:Header>
        <wsa:To xmlns:wsa="http://www.w3.org/2005/08/addressing">http://192.168.
6.251:8080/wsn-consumer/services/consumer</wsa:To>
        <wsa:Action xmlns:wsa="http://www.w3.org/2005/08/addressing">http://docs
.oasis-open.org/wsn/bw-2/NotificationConsumer/NotifyRequest</wsa:Action>
        <wsa:MessageID xmlns:wsa="http://www.w3.org/2005/08/addressing">uuid:a6a
c392c-e6b8-2cbc-895d-c04201eba23a</wsa:MessageID>
        <wsa:From xmlns:wsa="http://www.w3.org/2005/08/addressing">
            <wsa:ReferenceParameters xmlns:wsa="http://www.w3.org/2005/08/addres
sing"/>
            <wsa:Address>http://localhost:8080/wsn-producer/services/WsResource<
/wsa:Address>
        </wsa:From>
    </soap:Header>
    <soap:Body>
        <wsnt:Notify xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2">
            <wsnt:NotificationMessage xmlns:=""
                xmlns:muse-wsa="http://ws.apache.org/muse/addressing"
                xmlns:muws1="http://docs.oasis-open.org/wsdm/muws1-2.xsd"
                xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd"
                xmlns:wsa="http://www.w3.org/2005/08/addressing" xmlns:wsnt="htt
p://docs.oasis-open.org/wsn/b-2">
                <wsnt:SubscriptionReference>
                    <wsa:Address xmlns:wsa="http://www.w3.org/2005/08/addressing
">http://localhost:8080/wsn-producer/services/SubscriptionManager</wsa:Address>
                    <wsa:ReferenceParameters xmlns:wsa="http://www.w3.org/2005/0
8/addressing">
                        <muse-wsa:ResourceId xmlns:muse-wsa="http://ws.apache.or
g/muse/addressing">MuseResource-1</muse-wsa:ResourceId>
                    </wsa:ReferenceParameters>
                </wsnt:SubscriptionReference>
                <wsnt:Topic
                    Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/
Concrete" xmlns:tns="http://ws.apache.org/muse/test/wsrf">tns:MyTopic</wsnt:Topi
c>
                <wsnt:ProducerReference>
                    <wsa:ReferenceParameters xmlns:wsa="http://www.w3.org/2005/0
8/addressing"/>
                    <wsa:Address xmlns:wsa="http://www.w3.org/2005/08/addressing
">http://localhost:8080/wsn-producer/services/WsResource</wsa:Address>
                </wsnt:ProducerReference>
                <wsnt:Message>
                    <muws1:ManagementEvent
                        xmlns:muws1="http://docs.oasis-open.org/wsdm/muws1-2.xsd
" ReportTime="2009-05-21T15:27:04+08:00">
                        <muws1:EventId>uuid:ddeac1a5-5dcf-67fc-e17f-d71afce0fa5b
</muws1:EventId>
                        <muws1:SourceComponent>
                            <muws1:ComponentAddress>
                                <wsa:EndpointReference xmlns:wsa="http://www.w3.
org/2005/08/addressing">
                                    <wsa:ReferenceParameters xmlns:wsa="http://w
ww.w3.org/2005/08/addressing"/>
                                    <wsa:Address>http://localhost:8080/wsn-produ
cer/services/WsResource</wsa:Address>
                                </wsa:EndpointReference>
                            </muws1:ComponentAddress>
                        </muws1:SourceComponent>
                        <muws1:ReporterComponent>
                            <muws1:ComponentAddress>
                                <wsa:EndpointReference xmlns:wsa="http://www.w3.
org/2005/08/addressing">
                                    <wsa:ReferenceParameters xmlns:wsa="http://w
ww.w3.org/2005/08/addressing"/>
                                    <wsa:Address>http://localhost:8080/wsn-produ
cer/services/WsResource</wsa:Address>
                                </wsa:EndpointReference>
                            </muws1:ComponentAddress>
                        </muws1:ReporterComponent>
                        <muws2:Situation xmlns:muws2="http://docs.oasis-open.org
/wsdm/muws2-2.xsd">
                            <muws2:SituationCategory>
                                <muws2:AvailabilitySituation/>
                            </muws2:SituationCategory>
                            <muws2:SituationTime>2009-05-21T15:27:04+08:00</muws
2:SituationTime>
                            <muws2:Priority>70</muws2:Priority>
                            <muws2:Message>Something important has happened in t
he muse-test.apache.org!</muws2:Message>
                        </muws2:Situation>
                        <shipmentCheckResultInfo
                            xmlns="http://localhost:8080/ShipmentTrackService.xs
d"
                            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance
" xsi:schemaLocation="http://localhost:8080/ShipmentTrackService.xsd ShipmentTra
                        <muws1:ReporterComponent>
                            <muws1:ComponentAddress>
                                <wsa:EndpointReference xmlns:wsa="http://www.w3.
org/2005/08/addressing">
                                    <wsa:Address>http://localhost:8080/wsn-produ
cer/services/WsResource</wsa:Address>
                                </wsa:EndpointReference>
                            </muws1:ComponentAddress>
                        </muws1:ReporterComponent>
                        <muws2:Situation xmlns:muws2="http://docs.oasis-open.org
/wsdm/muws2-2.xsd">
                            <muws2:SituationCategory>
                                <muws2:AvailabilitySituation/>
                            </muws2:SituationCategory>
                            <muws2:SituationTime>2009-05-21T15:27:04+08:00</muws
2:SituationTime>
                            <muws2:Priority>70</muws2:Priority>
                            <muws2:Message>Something important has happened in t
he muse-test.apache.org!</muws2:Message>
                        </muws2:Situation>
                        <shipmentCheckResultInfo
                            xmlns="http://localhost:8080/ShipmentTrackService.xs
d"
                            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance
" xsi:schemaLocation="http://localhost:8080/ShipmentTrackService.xsd ShipmentTra
ckService.xsd">
                            <shipmentID>123</shipmentID>
                            <shipmentOwner>bincan</shipmentOwner>
                            <shipmentCheckResult>true</shipmentCheckResult>
                        </shipmentCheckResultInfo>
                    </muws1:ManagementEvent>
                </wsnt:Message>
            </wsnt:NotificationMessage>
        </wsnt:Notify>
    </soap:Body>
</soap:Envelope>

[Fatal Error] :5:184: The element type "HR" must be terminated by the matching e
nd-tag "</HR>".
2009-5-21 15:31:06 org.apache.muse.util.LoggingUtils logError
信息: There was an error while processing a request:

The element type "HR" must be terminated by the matching end-tag "</HR>".

        org.apache.muse.core.AbstractResourceClient.invoke(AbstractResourceClien
t.java:298)
        org.apache.muse.core.AbstractResourceClient.invoke(AbstractResourceClien
t.java:254)
        org.apache.muse.ws.notification.remote.NotificationConsumerClient.notify
(NotificationConsumerClient.java:99)
        org.apache.muse.ws.notification.impl.SimpleSubscriptionManager.publish(S
impleSubscriptionManager.java:267)
        org.apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(
SimpleNotificationProducer.java:445)
        org.apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(
SimpleNotificationProducer.java:473)
        org.apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(
SimpleNotificationProducer.java:462)
        org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1.run(Unknown Source)

------------------------------------------

2009-5-21 15:31:21 org.apache.muse.ws.notification.impl.SimpleSubscriptionManage
r publish
信息: [ID = 'LastPublishFailed'] The last notification published via wsnt:Notify
 failed to reach its destination. The consumer may be unavailable. The original
error was: The element type "HR" must be terminated by the matching end-tag "</H
R>".
2009-5-21 15:31:21 org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1 run
信息: Waiting 10 seconds before sending message...
******************************************************************

and at wsn-consumer, it produced

*******************************************************************
[Fatal Error] :14:45: Element or attribute do not match QName production: QName:
:=(NCName':')?NCName.
*******************************************************************

What should I do? Modify wsn-consumer's code? And if,

[Lenni Madsen]

sounds like one or more of your EndPointReferences are broken, I would  
suggest that you double check all your EPRs.

For references a broken HR fault means you're trying to invoke an  
endpoint, that does not exist.

On 21/05/2009, at 09.59, ciel <370334232@...> wrote:

>
> ok,thanks very much.
> when I indroduced your code in wsn-producer, it produced:
>
> *******************************************************
> 2009-5-21 15:27:50 org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1 run
> 信息: Sending message to consumers...
> [CLIENT TRACE] SOAP envelope contents (outgoing):
>
> <soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope">
>    <soap:Header>
>        <wsa:To
> xmlns:wsa="http://www.w3.org/2005/08/addressing">http://192.168.
> 6.251:8080/wsn-consumer/services/consumer</wsa:To>
>        <wsa:Action
> xmlns:wsa="http://www.w3.org/2005/08/addressing">http://docs
> .oasis-open.org/wsn/bw-2/NotificationConsumer/NotifyRequest</
> wsa:Action>
>        <wsa:MessageID
> xmlns:wsa="http://www.w3.org/2005/08/addressing">uuid:a6a
> c392c-e6b8-2cbc-895d-c04201eba23a</wsa:MessageID>
>        <wsa:From xmlns:wsa="http://www.w3.org/2005/08/addressing">
>            <wsa:ReferenceParameters
> xmlns:wsa="http://www.w3.org/2005/08/addres
> sing"/>
>
> <wsa:Address>http://localhost:8080/wsn-producer/services/WsResource<
> /wsa:Address>
>        </wsa:From>
>    </soap:Header>
>    <soap:Body>
>        <wsnt:Notify xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2">
>            <wsnt:NotificationMessage xmlns:=""
>                xmlns:muse-wsa="http://ws.apache.org/muse/addressing"
>                xmlns:muws1="http://docs.oasis-open.org/wsdm/muws1-2.xsd 
> "
>                xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd 
> "
>                xmlns:wsa="http://www.w3.org/2005/08/addressing"
> xmlns:wsnt="htt
> p://docs.oasis-open.org/wsn/b-2">
>                <wsnt:SubscriptionReference>
>                    <wsa:Address
> xmlns:wsa="http://www.w3.org/2005/08/addressing
> ">http://localhost:8080/wsn-producer/services/SubscriptionManager</
> wsa:Address>
>                    <wsa:ReferenceParameters
> xmlns:wsa="http://www.w3.org/2005/0
> 8/addressing">
>                        <muse-wsa:ResourceId
> xmlns:muse-wsa="http://ws.apache.or
> g/muse/addressing">MuseResource-1</muse-wsa:ResourceId>
>                    </wsa:ReferenceParameters>
>                </wsnt:SubscriptionReference>
>                <wsnt:Topic
>
> Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/
> Concrete"
> xmlns:tns="http://ws.apache.org/muse/test/wsrf">tns:MyTopic</wsnt:Topi
> c>
>                <wsnt:ProducerReference>
>                    <wsa:ReferenceParameters
> xmlns:wsa="http://www.w3.org/2005/0
> 8/addressing"/>
>                    <wsa:Address
> xmlns:wsa="http://www.w3.org/2005/08/addressing
> ">http://localhost:8080/wsn-producer/services/WsResource</wsa:Address>
>                </wsnt:ProducerReference>
>                <wsnt:Message>
>                    <muws1:ManagementEvent
>
> xmlns:muws1="http://docs.oasis-open.org/wsdm/muws1-2.xsd
> " ReportTime="2009-05-21T15:27:04+08:00">
>
> <muws1:EventId>uuid:ddeac1a5-5dcf-67fc-e17f-d71afce0fa5b
> </muws1:EventId>
>                        <muws1:SourceComponent>
>                            <muws1:ComponentAddress>
>                                <wsa:EndpointReference
> xmlns:wsa="http://www.w3.
> org/2005/08/addressing">
>                                    <wsa:ReferenceParameters
> xmlns:wsa="http://w
> ww.w3.org/2005/08/addressing"/>
>
> <wsa:Address>http://localhost:8080/wsn-produ
> cer/services/WsResource</wsa:Address>
>                                </wsa:EndpointReference>
>                            </muws1:ComponentAddress>
>                        </muws1:SourceComponent>
>                        <muws1:ReporterComponent>
>                            <muws1:ComponentAddress>
>                                <wsa:EndpointReference
> xmlns:wsa="http://www.w3.
> org/2005/08/addressing">
>                                    <wsa:ReferenceParameters
> xmlns:wsa="http://w
> ww.w3.org/2005/08/addressing"/>
>
> <wsa:Address>http://localhost:8080/wsn-produ
> cer/services/WsResource</wsa:Address>
>                                </wsa:EndpointReference>
>                            </muws1:ComponentAddress>
>                        </muws1:ReporterComponent>
>                        <muws2:Situation
> xmlns:muws2="http://docs.oasis-open.org
> /wsdm/muws2-2.xsd">
>                            <muws2:SituationCategory>
>                                <muws2:AvailabilitySituation/>
>                            </muws2:SituationCategory>
>
> <muws2:SituationTime>2009-05-21T15:27:04+08:00</muws
> 2:SituationTime>
>                            <muws2:Priority>70</muws2:Priority>
>                            <muws2:Message>Something important has  
> happened
> in t
> he muse-test.apache.org!</muws2:Message>
>                        </muws2:Situation>
>                        <shipmentCheckResultInfo
>
> xmlns="http://localhost:8080/ShipmentTrackService.xs
> d"
>
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance
> " xsi:schemaLocation="http://localhost:8080/ShipmentTrackService.xsd
> ShipmentTra
>                        <muws1:ReporterComponent>
>                            <muws1:ComponentAddress>
>                                <wsa:EndpointReference
> xmlns:wsa="http://www.w3.
> org/2005/08/addressing">
>
> <wsa:Address>http://localhost:8080/wsn-produ
> cer/services/WsResource</wsa:Address>
>                                </wsa:EndpointReference>
>                            </muws1:ComponentAddress>
>                        </muws1:ReporterComponent>
>                        <muws2:Situation
> xmlns:muws2="http://docs.oasis-open.org
> /wsdm/muws2-2.xsd">
>                            <muws2:SituationCategory>
>                                <muws2:AvailabilitySituation/>
>                            </muws2:SituationCategory>
>
> <muws2:SituationTime>2009-05-21T15:27:04+08:00</muws
> 2:SituationTime>
>                            <muws2:Priority>70</muws2:Priority>
>                            <muws2:Message>Something important has  
> happened
> in t
> he muse-test.apache.org!</muws2:Message>
>                        </muws2:Situation>
>                        <shipmentCheckResultInfo
>
> xmlns="http://localhost:8080/ShipmentTrackService.xs
> d"
>
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance
> " xsi:schemaLocation="http://localhost:8080/ShipmentTrackService.xsd
> ShipmentTra
> ckService.xsd">
>                            <shipmentID>123</shipmentID>
>                            <shipmentOwner>bincan</shipmentOwner>
>                            <shipmentCheckResult>true</
> shipmentCheckResult>
>                        </shipmentCheckResultInfo>
>                    </muws1:ManagementEvent>
>                </wsnt:Message>
>            </wsnt:NotificationMessage>
>        </wsnt:Notify>
>    </soap:Body>
> </soap:Envelope>
>
> [Fatal Error] :5:184: The element type "HR" must be terminated by the
> matching e
> nd-tag "</HR>".
> 2009-5-21 15:31:06 org.apache.muse.util.LoggingUtils logError
> 信息: There was an error while processing a request:
>
> The element type "HR" must be terminated by the matching end-tag "</
> HR>".
>
>
> org.
> apache.muse.core.AbstractResourceClient.invoke(AbstractResourceClien
> t.java:298)
>
> org.
> apache.muse.core.AbstractResourceClient.invoke(AbstractResourceClien
> t.java:254)
>
> org.
> apache.muse.ws.notification.remote.NotificationConsumerClient.notify
> (NotificationConsumerClient.java:99)
>
> org.
> apache.muse.ws.notification.impl.SimpleSubscriptionManager.publish(S
> impleSubscriptionManager.java:267)
>
> org.
> apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(
> SimpleNotificationProducer.java:445)
>
> org.
> apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(
> SimpleNotificationProducer.java:473)
>
> org.
> apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(
> SimpleNotificationProducer.java:462)
>        org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1.run(Unknown  
> Source)
>
> ------------------------------------------
>
> 2009-5-21 15:31:21
> org.apache.muse.ws.notification.impl.SimpleSubscriptionManage
> r publish
> 信息: [ID = 'LastPublishFailed'] The last notification published via
> wsnt:Notify
> failed to reach its destination. The consumer may be unavailable. The
> original
> error was: The element type "HR" must be terminated by the matching  
> end-tag
> "</H
> R>".
> 2009-5-21 15:31:21 org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1 run
> 信息: Waiting 10 seconds before sending message...
> ******************************************************************
>
> and at wsn-consumer, it produced
>
> *******************************************************************
> [Fatal Error] :14:45: Element or attribute do not match QName  
> production:
> QName:
> :=(NCName':')?NCName.
> *******************************************************************
>
> What should I do? Modify wsn-consumer's code? And if,
> --
> View this message in context: http://www.nabble.com/Transport-my-own-data-types--form-wsn-producer-to-wsn-consumer-tp23631392p23649285.html
> Sent from the Muse User mailing list archive at Nabble.com.
>

[Lenni Madsen]

just for references sake did you remember to subscribe the consumer to  
the producer?

On 21/05/2009, at 09.59, ciel <370334232@...> wrote:

>
> ok,thanks very much.
> when I indroduced your code in wsn-producer, it produced:
>
> *******************************************************
> 2009-5-21 15:27:50 org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1 run
> 信息: Sending message to consumers...
> [CLIENT TRACE] SOAP envelope contents (outgoing):
>
> <soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope">
>    <soap:Header>
>        <wsa:To
> xmlns:wsa="http://www.w3.org/2005/08/addressing">http://192.168.
> 6.251:8080/wsn-consumer/services/consumer</wsa:To>
>        <wsa:Action
> xmlns:wsa="http://www.w3.org/2005/08/addressing">http://docs
> .oasis-open.org/wsn/bw-2/NotificationConsumer/NotifyRequest</
> wsa:Action>
>        <wsa:MessageID
> xmlns:wsa="http://www.w3.org/2005/08/addressing">uuid:a6a
> c392c-e6b8-2cbc-895d-c04201eba23a</wsa:MessageID>
>        <wsa:From xmlns:wsa="http://www.w3.org/2005/08/addressing">
>            <wsa:ReferenceParameters
> xmlns:wsa="http://www.w3.org/2005/08/addres
> sing"/>
>
> <wsa:Address>http://localhost:8080/wsn-producer/services/WsResource<
> /wsa:Address>
>        </wsa:From>
>    </soap:Header>
>    <soap:Body>
>        <wsnt:Notify xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2">
>            <wsnt:NotificationMessage xmlns:=""
>                xmlns:muse-wsa="http://ws.apache.org/muse/addressing"
>                xmlns:muws1="http://docs.oasis-open.org/wsdm/muws1-2.xsd 
> "
>                xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd 
> "
>                xmlns:wsa="http://www.w3.org/2005/08/addressing"
> xmlns:wsnt="htt
> p://docs.oasis-open.org/wsn/b-2">
>                <wsnt:SubscriptionReference>
>                    <wsa:Address
> xmlns:wsa="http://www.w3.org/2005/08/addressing
> ">http://localhost:8080/wsn-producer/services/SubscriptionManager</
> wsa:Address>
>                    <wsa:ReferenceParameters
> xmlns:wsa="http://www.w3.org/2005/0
> 8/addressing">
>                        <muse-wsa:ResourceId
> xmlns:muse-wsa="http://ws.apache.or
> g/muse/addressing">MuseResource-1</muse-wsa:ResourceId>
>                    </wsa:ReferenceParameters>
>                </wsnt:SubscriptionReference>
>                <wsnt:Topic
>
> Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/
> Concrete"
> xmlns:tns="http://ws.apache.org/muse/test/wsrf">tns:MyTopic</wsnt:Topi
> c>
>                <wsnt:ProducerReference>
>                    <wsa:ReferenceParameters
> xmlns:wsa="http://www.w3.org/2005/0
> 8/addressing"/>
>                    <wsa:Address
> xmlns:wsa="http://www.w3.org/2005/08/addressing
> ">http://localhost:8080/wsn-producer/services/WsResource</wsa:Address>
>                </wsnt:ProducerReference>
>                <wsnt:Message>
>                    <muws1:ManagementEvent
>
> xmlns:muws1="http://docs.oasis-open.org/wsdm/muws1-2.xsd
> " ReportTime="2009-05-21T15:27:04+08:00">
>
> <muws1:EventId>uuid:ddeac1a5-5dcf-67fc-e17f-d71afce0fa5b
> </muws1:EventId>
>                        <muws1:SourceComponent>
>                            <muws1:ComponentAddress>
>                                <wsa:EndpointReference
> xmlns:wsa="http://www.w3.
> org/2005/08/addressing">
>                                    <wsa:ReferenceParameters
> xmlns:wsa="http://w
> ww.w3.org/2005/08/addressing"/>
>
> <wsa:Address>http://localhost:8080/wsn-produ
> cer/services/WsResource</wsa:Address>
>                                </wsa:EndpointReference>
>                            </muws1:ComponentAddress>
>                        </muws1:SourceComponent>
>                        <muws1:ReporterComponent>
>                            <muws1:ComponentAddress>
>                                <wsa:EndpointReference
> xmlns:wsa="http://www.w3.
> org/2005/08/addressing">
>                                    <wsa:ReferenceParameters
> xmlns:wsa="http://w
> ww.w3.org/2005/08/addressing"/>
>
> <wsa:Address>http://localhost:8080/wsn-produ
> cer/services/WsResource</wsa:Address>
>                                </wsa:EndpointReference>
>                            </muws1:ComponentAddress>
>                        </muws1:ReporterComponent>
>                        <muws2:Situation
> xmlns:muws2="http://docs.oasis-open.org
> /wsdm/muws2-2.xsd">
>                            <muws2:SituationCategory>
>                                <muws2:AvailabilitySituation/>
>                            </muws2:SituationCategory>
>
> <muws2:SituationTime>2009-05-21T15:27:04+08:00</muws
> 2:SituationTime>
>                            <muws2:Priority>70</muws2:Priority>
>                            <muws2:Message>Something important has  
> happened
> in t
> he muse-test.apache.org!</muws2:Message>
>                        </muws2:Situation>
>                        <shipmentCheckResultInfo
>
> xmlns="http://localhost:8080/ShipmentTrackService.xs
> d"
>
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance
> " xsi:schemaLocation="http://localhost:8080/ShipmentTrackService.xsd
> ShipmentTra
>                        <muws1:ReporterComponent>
>                            <muws1:ComponentAddress>
>                                <wsa:EndpointReference
> xmlns:wsa="http://www.w3.
> org/2005/08/addressing">
>
> <wsa:Address>http://localhost:8080/wsn-produ
> cer/services/WsResource</wsa:Address>
>                                </wsa:EndpointReference>
>                            </muws1:ComponentAddress>
>                        </muws1:ReporterComponent>
>                        <muws2:Situation
> xmlns:muws2="http://docs.oasis-open.org
> /wsdm/muws2-2.xsd">
>                            <muws2:SituationCategory>
>                                <muws2:AvailabilitySituation/>
>                            </muws2:SituationCategory>
>
> <muws2:SituationTime>2009-05-21T15:27:04+08:00</muws
> 2:SituationTime>
>                            <muws2:Priority>70</muws2:Priority>
>                            <muws2:Message>Something important has  
> happened
> in t
> he muse-test.apache.org!</muws2:Message>
>                        </muws2:Situation>
>                        <shipmentCheckResultInfo
>
> xmlns="http://localhost:8080/ShipmentTrackService.xs
> d"
>
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance
> " xsi:schemaLocation="http://localhost:8080/ShipmentTrackService.xsd
> ShipmentTra
> ckService.xsd">
>                            <shipmentID>123</shipmentID>
>                            <shipmentOwner>bincan</shipmentOwner>
>                            <shipmentCheckResult>true</
> shipmentCheckResult>
>                        </shipmentCheckResultInfo>
>                    </muws1:ManagementEvent>
>                </wsnt:Message>
>            </wsnt:NotificationMessage>
>        </wsnt:Notify>
>    </soap:Body>
> </soap:Envelope>
>
> [Fatal Error] :5:184: The element type "HR" must be terminated by the
> matching e
> nd-tag "</HR>".
> 2009-5-21 15:31:06 org.apache.muse.util.LoggingUtils logError
> 信息: There was an error while processing a request:
>
> The element type "HR" must be terminated by the matching end-tag "</
> HR>".
>
>
> org.
> apache.muse.core.AbstractResourceClient.invoke(AbstractResourceClien
> t.java:298)
>
> org.
> apache.muse.core.AbstractResourceClient.invoke(AbstractResourceClien
> t.java:254)
>
> org.
> apache.muse.ws.notification.remote.NotificationConsumerClient.notify
> (NotificationConsumerClient.java:99)
>
> org.
> apache.muse.ws.notification.impl.SimpleSubscriptionManager.publish(S
> impleSubscriptionManager.java:267)
>
> org.
> apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(
> SimpleNotificationProducer.java:445)
>
> org.
> apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(
> SimpleNotificationProducer.java:473)
>
> org.
> apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(
> SimpleNotificationProducer.java:462)
>        org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1.run(Unknown  
> Source)
>
> ------------------------------------------
>
> 2009-5-21 15:31:21
> org.apache.muse.ws.notification.impl.SimpleSubscriptionManage
> r publish
> 信息: [ID = 'LastPublishFailed'] The last notification published via
> wsnt:Notify
> failed to reach its destination. The consumer may be unavailable. The
> original
> error was: The element type "HR" must be terminated by the matching  
> end-tag
> "</H
> R>".
> 2009-5-21 15:31:21 org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1 run
> 信息: Waiting 10 seconds before sending message...
> ******************************************************************
>
> and at wsn-consumer, it produced
>
> *******************************************************************
> [Fatal Error] :14:45: Element or attribute do not match QName  
> production:
> QName:
> :=(NCName':')?NCName.
> *******************************************************************
>
> What should I do? Modify wsn-consumer's code? And if,
> --
> View this message in context: http://www.nabble.com/Transport-my-own-data-types--form-wsn-producer-to-wsn-consumer-tp23631392p23649285.html
> Sent from the Muse User mailing list archive at Nabble.com.
>

[ciel]

I have not solved the problem yet.
my MyCapability's is as follows and I didn't change wsn-consumer' code

package org.apache.ws.muse.test.wsrf;

import java.io.File;
import java.io.IOException;

import javax.xml.namespace.QName;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;

import org.apache.muse.ws.addressing.soap.SoapFault;
import org.apache.muse.ws.dm.muws.events.Component;
import org.apache.muse.ws.dm.muws.events.ComponentAddress;
import org.apache.muse.ws.dm.muws.events.ManagementEvent;
import org.apache.muse.ws.dm.muws.events.Situation;
import org.apache.muse.ws.dm.muws.events.WefConstants;
import org.apache.muse.ws.dm.muws.events.WefFactory;
import org.apache.muse.ws.dm.muws.events.impl.SimpleWefFactory;
import org.apache.muse.ws.notification.NotificationProducer;
import org.apache.muse.ws.notification.WsnConstants;
import org.apache.muse.ws.resource.impl.AbstractWsResourceCapability;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.xml.sax.SAXException;

public class MyCapabilityImpl extends AbstractWsResourceCapability implements MyCapability
{
    private static final QName[] _PROPERTIES = new QName[] {
            new QName(NAMESPACE_URI, "MessageInterval", PREFIX),
            new QName(NAMESPACE_URI, "ServerName", PREFIX)
    };

    private static final QName _TOPIC_NAME = new QName(NAMESPACE_URI, "MyTopic", PREFIX);
   
    public QName[] getPropertyNames()
    {
        return _PROPERTIES;
    }

    private int _MessageInterval = 10;

    private String _ServerName = "muse-test.apache.org";

    public int getMessageInterval()
    {
        return _MessageInterval;
    }

    public void setMessageInterval(int param0)
    {
        _MessageInterval = param0;
    }

    public String getServerName()
    {
        return _ServerName;
    }

    public void setServerName(String param0)
    {
        _ServerName = param0;
    }
   
    public void initializeCompleted()
        throws SoapFault
    {
        super.initializeCompleted();
       
        //
        // access resource's WSN capability and create a new topic
        //
        final NotificationProducer wsn = (NotificationProducer)getResource().getCapability(WsnConstants.PRODUCER_URI);
        wsn.addTopic(_TOPIC_NAME);

        Thread producer = new Thread() {
            public void run()
            {
                //
                // for this example, reuse one payload for every notification
                //
                QName messageName = new QName(NAMESPACE_URI, "MyMessage", PREFIX);
                try
                {
                payload = runtimeEventOperation();
                }
                catch (Exception e)
                {
                e.printStackTrace();
                }
               
                while (true)
                {
                    try
                    {
                        //
                        // read current value - property is mutable
                        //
                        int currentInterval = getMessageInterval();
//                        System.out.println(payload);

                        getLog().info("Waiting " + currentInterval + " seconds before sending message...");
                        Thread.currentThread().sleep(currentInterval * 1000);
                       
                        //
                        // use WSN capability to send message to any subscribers
                        //
                        getLog().info("Sending message to consumers...");
                        wsn.publish(_TOPIC_NAME, payload);
                    }

                    catch (Throwable error)
                    {
                        error.printStackTrace();
                    }
                }
            }
        };
        producer.start();
    }
    private static ManagementEvent payload;
    public ManagementEvent runtimeEventOperation() throws Exception{
        WefFactory factory = new SimpleWefFactory();
        ManagementEvent event = factory.createEvent();
       
        Component reporter = factory.createComponent();
        ComponentAddress reporterAddress =  factory.createComponentAddress(getResource().getEndpointReference().toXML());
        reporter.setAddress(reporterAddress);
        reporter.setName(WefConstants.REPORTER_COMP_QNAME);
       
        Component source = factory.createComponent();
        ComponentAddress sourceAddress =  factory.createComponentAddress(getResource().getEndpointReference().toXML());
        source.setAddress(sourceAddress);
        source.setName(WefConstants.SOURCE_COMP_QNAME);
       
        Situation situation = factory.createSituation();
        situation.setCategoryType(WefConstants.AVAILABILITY_SITUATION_QNAME);
        situation.setPriority(Situation.HIGH_PRIORITY);
        situation.setMessage("Something important has happened in the "+getServerName()+"!");
        event.setReporter(reporter);
        event.setSource(source);
        event.setSituation(situation);
       
        event.addExtendedElement(MessageExtension());
        return event;
//        try{
//        getLog().info("Sending message to consumers...");
//        runtimeNotification.publish(_TOPIC_NAME, event);
//        }
//        catch (Throwable error){
//        error.printStackTrace();
//        }
//        return event.toXML();
       }

       private Element MessageExtension()throws ParserConfigurationException, SAXException, IOException{
        // create your XML message
     
      File file = new File("E:/Awork/java/jakarta-tomcat-5.0.28/temp","test.xml");
           DocumentBuilderFactory   dbf   =   DocumentBuilderFactory.newInstance();    
           DocumentBuilder   db   =   dbf.newDocumentBuilder();  
           Document   doc   =   db.parse(file);  
           doc.normalize();
           Element   root   =   doc.getDocumentElement();  
           return root;
       }
}

[Chris Twiner]

Sorry, but could you please give more details of what doesn't work?
For example, log files, stack traces, messages sent etc.

On Mon, May 25, 2009 at 5:16 AM, ciel <370334232@...> wrote:

>
> I have not solved the problem yet.
> my MyCapability's is as follows and I didn't change wsn-consumer' code
>
> package org.apache.ws.muse.test.wsrf;
>
> import java.io.File;
> import java.io.IOException;
>
> import javax.xml.namespace.QName;
> import javax.xml.parsers.DocumentBuilder;
> import javax.xml.parsers.DocumentBuilderFactory;
> import javax.xml.parsers.ParserConfigurationException;
>
> import org.apache.muse.ws.addressing.soap.SoapFault;
> import org.apache.muse.ws.dm.muws.events.Component;
> import org.apache.muse.ws.dm.muws.events.ComponentAddress;
> import org.apache.muse.ws.dm.muws.events.ManagementEvent;
> import org.apache.muse.ws.dm.muws.events.Situation;
> import org.apache.muse.ws.dm.muws.events.WefConstants;
> import org.apache.muse.ws.dm.muws.events.WefFactory;
> import org.apache.muse.ws.dm.muws.events.impl.SimpleWefFactory;
> import org.apache.muse.ws.notification.NotificationProducer;
> import org.apache.muse.ws.notification.WsnConstants;
> import org.apache.muse.ws.resource.impl.AbstractWsResourceCapability;
> import org.w3c.dom.Document;
> import org.w3c.dom.Element;
> import org.xml.sax.SAXException;
>
> public class MyCapabilityImpl extends AbstractWsResourceCapability
> implements MyCapability
> {
>    private static final QName[] _PROPERTIES = new QName[] {
>            new QName(NAMESPACE_URI, "MessageInterval", PREFIX),
>            new QName(NAMESPACE_URI, "ServerName", PREFIX)
>    };
>
>    private static final QName _TOPIC_NAME = new QName(NAMESPACE_URI,
> "MyTopic", PREFIX);
>
>    public QName[] getPropertyNames()
>    {
>        return _PROPERTIES;
>    }
>
>    private int _MessageInterval = 10;
>
>    private String _ServerName = "muse-test.apache.org";
>
>    public int getMessageInterval()
>    {
>        return _MessageInterval;
>    }
>
>    public void setMessageInterval(int param0)
>    {
>        _MessageInterval = param0;
>    }
>
>    public String getServerName()
>    {
>        return _ServerName;
>    }
>
>    public void setServerName(String param0)
>    {
>        _ServerName = param0;
>    }
>
>    public void initializeCompleted()
>        throws SoapFault
>    {
>        super.initializeCompleted();
>
>        //
>        // access resource's WSN capability and create a new topic
>        //
>        final NotificationProducer wsn =
> (NotificationProducer)getResource().getCapability(WsnConstants.PRODUCER_URI);
>        wsn.addTopic(_TOPIC_NAME);
>
>        Thread producer = new Thread() {
>            public void run()
>            {
>                //
>                // for this example, reuse one payload for every
> notification
>                //
>                QName messageName = new QName(NAMESPACE_URI, "MyMessage",
> PREFIX);
>                try
>                {
>                        payload = runtimeEventOperation();
>                }
>                catch (Exception e)
>                {
>                        e.printStackTrace();
>                }
>
>                while (true)
>                {
>                    try
>                    {
>                        //
>                        // read current value - property is mutable
>                        //
>                        int currentInterval = getMessageInterval();
> //                        System.out.println(payload);
>
>                        getLog().info("Waiting " + currentInterval + "
> seconds before sending message...");
>                        Thread.currentThread().sleep(currentInterval *
> 1000);
>
>                        //
>                        // use WSN capability to send message to any
> subscribers
>                        //
>                        getLog().info("Sending message to consumers...");
>                        wsn.publish(_TOPIC_NAME, payload);
>                    }
>
>                    catch (Throwable error)
>                    {
>                        error.printStackTrace();
>                    }
>                }
>            }
>        };
>        producer.start();
>    }
>    private static ManagementEvent payload;
>    public ManagementEvent runtimeEventOperation() throws Exception{
>        WefFactory factory = new SimpleWefFactory();
>        ManagementEvent event = factory.createEvent();
>
>        Component reporter = factory.createComponent();
>        ComponentAddress reporterAddress =
> factory.createComponentAddress(getResource().getEndpointReference().toXML());
>        reporter.setAddress(reporterAddress);
>        reporter.setName(WefConstants.REPORTER_COMP_QNAME);
>
>        Component source = factory.createComponent();
>        ComponentAddress sourceAddress =
> factory.createComponentAddress(getResource().getEndpointReference().toXML());
>        source.setAddress(sourceAddress);
>        source.setName(WefConstants.SOURCE_COMP_QNAME);
>
>        Situation situation = factory.createSituation();
>
> situation.setCategoryType(WefConstants.AVAILABILITY_SITUATION_QNAME);
>        situation.setPriority(Situation.HIGH_PRIORITY);
>        situation.setMessage("Something important has happened in the
> "+getServerName()+"!");
>        event.setReporter(reporter);
>        event.setSource(source);
>        event.setSituation(situation);
>
>        event.addExtendedElement(MessageExtension());
>        return event;
> //        try{
> //                getLog().info("Sending message to consumers...");
> //                runtimeNotification.publish(_TOPIC_NAME, event);
> //                }
> //        catch (Throwable error){
> //                        error.printStackTrace();
> //                        }
> //        return event.toXML();
>       }
>
>       private Element MessageExtension()throws
> ParserConfigurationException, SAXException, IOException{
>        // create your XML message
>
>         File file = new
> File("E:/Awork/java/jakarta-tomcat-5.0.28/temp","test.xml");
>           DocumentBuilderFactory   dbf   =
> DocumentBuilderFactory.newInstance();
>           DocumentBuilder   db   =   dbf.newDocumentBuilder();
>           Document   doc   =   db.parse(file);
>           doc.normalize();
>           Element   root   =   doc.getDocumentElement();
>           return root;
>       }
> }
>
> --
> View this message in context: http://www.nabble.com/Transport-my-own-data-types--form-wsn-producer-to-wsn-consumer-tp23631392p23700618.html
> Sent from the Muse User mailing list archive at Nabble.com.
>
>

[Lenni Madsen]

I'll bet it's related to that thread, could we once and for all agree  
that the current wsn-producer example is providing more issues than it  
helps remove.

Guys, in the wsn-producer example from Muse there's a thread used,  
this is used ONLY to make the example run continuesly. The thread is  
not needed for a production version and is not in all the examples  
I've posted last week.

I'll see if I can't cook up something

On 25/05/2009, at 06.36, Chris Twiner <chris.twiner@...> wrote:

> Sorry, but could you please give more details of what doesn't work?
> For example, log files, stack traces, messages sent etc.
>
> On Mon, May 25, 2009 at 5:16 AM, ciel <370334232@...> wrote:
>>
>> I have not solved the problem yet.
>> my MyCapability's is as follows and I didn't change wsn-consumer'  
>> code
>>
>> package org.apache.ws.muse.test.wsrf;
>>
>> import java.io.File;
>> import java.io.IOException;
>>
>> import javax.xml.namespace.QName;
>> import javax.xml.parsers.DocumentBuilder;
>> import javax.xml.parsers.DocumentBuilderFactory;
>> import javax.xml.parsers.ParserConfigurationException;
>>
>> import org.apache.muse.ws.addressing.soap.SoapFault;
>> import org.apache.muse.ws.dm.muws.events.Component;
>> import org.apache.muse.ws.dm.muws.events.ComponentAddress;
>> import org.apache.muse.ws.dm.muws.events.ManagementEvent;
>> import org.apache.muse.ws.dm.muws.events.Situation;
>> import org.apache.muse.ws.dm.muws.events.WefConstants;
>> import org.apache.muse.ws.dm.muws.events.WefFactory;
>> import org.apache.muse.ws.dm.muws.events.impl.SimpleWefFactory;
>> import org.apache.muse.ws.notification.NotificationProducer;
>> import org.apache.muse.ws.notification.WsnConstants;
>> import org.apache.muse.ws.resource.impl.AbstractWsResourceCapability;
>> import org.w3c.dom.Document;
>> import org.w3c.dom.Element;
>> import org.xml.sax.SAXException;
>>
>> public class MyCapabilityImpl extends AbstractWsResourceCapability
>> implements MyCapability
>> {
>>    private static final QName[] _PROPERTIES = new QName[] {
>>            new QName(NAMESPACE_URI, "MessageInterval", PREFIX),
>>            new QName(NAMESPACE_URI, "ServerName", PREFIX)
>>    };
>>
>>    private static final QName _TOPIC_NAME = new QName(NAMESPACE_URI,
>> "MyTopic", PREFIX);
>>
>>    public QName[] getPropertyNames()
>>    {
>>        return _PROPERTIES;
>>    }
>>
>>    private int _MessageInterval = 10;
>>
>>    private String _ServerName = "muse-test.apache.org";
>>
>>    public int getMessageInterval()
>>    {
>>        return _MessageInterval;
>>    }
>>
>>    public void setMessageInterval(int param0)
>>    {
>>        _MessageInterval = param0;
>>    }
>>
>>    public String getServerName()
>>    {
>>        return _ServerName;
>>    }
>>
>>    public void setServerName(String param0)
>>    {
>>        _ServerName = param0;
>>    }
>>
>>    public void initializeCompleted()
>>        throws SoapFault
>>    {
>>        super.initializeCompleted();
>>
>>        //
>>        // access resource's WSN capability and create a new topic
>>        //
>>        final NotificationProducer wsn =
>> (NotificationProducer)
>> getResource().getCapability(WsnConstants.PRODUCER_URI);
>>        wsn.addTopic(_TOPIC_NAME);
>>
>>        Thread producer = new Thread() {
>>            public void run()
>>            {
>>                //
>>                // for this example, reuse one payload for every
>> notification
>>                //
>>                QName messageName = new QName(NAMESPACE_URI,  
>> "MyMessage",
>> PREFIX);
>>                try
>>                {
>>                        payload = runtimeEventOperation();
>>                }
>>                catch (Exception e)
>>                {
>>                        e.printStackTrace();
>>                }
>>
>>                while (true)
>>                {
>>                    try
>>                    {
>>                        //
>>                        // read current value - property is mutable
>>                        //
>>                        int currentInterval = getMessageInterval();
>> //                        System.out.println(payload);
>>
>>                        getLog().info("Waiting " + currentInterval + "
>> seconds before sending message...");
>>                        Thread.currentThread().sleep(currentInterval *
>> 1000);
>>
>>                        //
>>                        // use WSN capability to send message to any
>> subscribers
>>                        //
>>                        getLog().info("Sending message to  
>> consumers...");
>>                        wsn.publish(_TOPIC_NAME, payload);
>>                    }
>>
>>                    catch (Throwable error)
>>                    {
>>                        error.printStackTrace();
>>                    }
>>                }
>>            }
>>        };
>>        producer.start();
>>    }
>>    private static ManagementEvent payload;
>>    public ManagementEvent runtimeEventOperation() throws Exception{
>>        WefFactory factory = new SimpleWefFactory();
>>        ManagementEvent event = factory.createEvent();
>>
>>        Component reporter = factory.createComponent();
>>        ComponentAddress reporterAddress =
>> factory.
>> createComponentAddress(getResource().getEndpointReference().toXML());
>>        reporter.setAddress(reporterAddress);
>>        reporter.setName(WefConstants.REPORTER_COMP_QNAME);
>>
>>        Component source = factory.createComponent();
>>        ComponentAddress sourceAddress =
>> factory.
>> createComponentAddress(getResource().getEndpointReference().toXML());
>>        source.setAddress(sourceAddress);
>>        source.setName(WefConstants.SOURCE_COMP_QNAME);
>>
>>        Situation situation = factory.createSituation();
>>
>> situation.setCategoryType(WefConstants.AVAILABILITY_SITUATION_QNAME);
>>        situation.setPriority(Situation.HIGH_PRIORITY);
>>        situation.setMessage("Something important has happened in the
>> "+getServerName()+"!");
>>        event.setReporter(reporter);
>>        event.setSource(source);
>>        event.setSituation(situation);
>>
>>        event.addExtendedElement(MessageExtension());
>>        return event;
>> //        try{
>> //                getLog().info("Sending message to consumers...");
>> //                runtimeNotification.publish(_TOPIC_NAME, event);
>> //                }
>> //        catch (Throwable error){
>> //                        error.printStackTrace();
>> //                        }
>> //        return event.toXML();
>>       }
>>
>>       private Element MessageExtension()throws
>> ParserConfigurationException, SAXException, IOException{
>>        // create your XML message
>>
>>         File file = new
>> File("E:/Awork/java/jakarta-tomcat-5.0.28/temp","test.xml");
>>           DocumentBuilderFactory   dbf   =
>> DocumentBuilderFactory.newInstance();
>>           DocumentBuilder   db   =   dbf.newDocumentBuilder();
>>           Document   doc   =   db.parse(file);
>>           doc.normalize();
>>           Element   root   =   doc.getDocumentElement();
>>           return root;
>>       }
>> }
>>
>> --
>> View this message in context: http://www.nabble.com/Transport-my-own-data-types--form-wsn-producer-to-wsn-consumer-tp23631392p23700618.html
>> Sent from the Muse User mailing list archive at Nabble.com.
>>
>>

[Chris Twiner]

+1, although I have no idea what that should look like.

On Mon, May 25, 2009 at 7:14 AM, Lenni Madsen <l.madsen@...> wrote:

> I'll bet it's related to that thread, could we once and for all agree that
> the current wsn-producer example is providing more issues than it helps
> remove.
>
> Guys, in the wsn-producer example from Muse there's a thread used, this is
> used ONLY to make the example run continuesly. The thread is not needed for
> a production version and is not in all the examples I've posted last week.
>
> I'll see if I can't cook up something
>
> On 25/05/2009, at 06.36, Chris Twiner <chris.twiner@...> wrote:
>
>> Sorry, but could you please give more details of what doesn't work?
>> For example, log files, stack traces, messages sent etc.
>>
>> On Mon, May 25, 2009 at 5:16 AM, ciel <370334232@...> wrote:
>>>
>>> I have not solved the problem yet.
>>> my MyCapability's is as follows and I didn't change wsn-consumer' code
>>>
>>> package org.apache.ws.muse.test.wsrf;
>>>
>>> import java.io.File;
>>> import java.io.IOException;
>>>
>>> import javax.xml.namespace.QName;
>>> import javax.xml.parsers.DocumentBuilder;
>>> import javax.xml.parsers.DocumentBuilderFactory;
>>> import javax.xml.parsers.ParserConfigurationException;
>>>
>>> import org.apache.muse.ws.addressing.soap.SoapFault;
>>> import org.apache.muse.ws.dm.muws.events.Component;
>>> import org.apache.muse.ws.dm.muws.events.ComponentAddress;
>>> import org.apache.muse.ws.dm.muws.events.ManagementEvent;
>>> import org.apache.muse.ws.dm.muws.events.Situation;
>>> import org.apache.muse.ws.dm.muws.events.WefConstants;
>>> import org.apache.muse.ws.dm.muws.events.WefFactory;
>>> import org.apache.muse.ws.dm.muws.events.impl.SimpleWefFactory;
>>> import org.apache.muse.ws.notification.NotificationProducer;
>>> import org.apache.muse.ws.notification.WsnConstants;
>>> import org.apache.muse.ws.resource.impl.AbstractWsResourceCapability;
>>> import org.w3c.dom.Document;
>>> import org.w3c.dom.Element;
>>> import org.xml.sax.SAXException;
>>>
>>> public class MyCapabilityImpl extends AbstractWsResourceCapability
>>> implements MyCapability
>>> {
>>>   private static final QName[] _PROPERTIES = new QName[] {
>>>           new QName(NAMESPACE_URI, "MessageInterval", PREFIX),
>>>           new QName(NAMESPACE_URI, "ServerName", PREFIX)
>>>   };
>>>
>>>   private static final QName _TOPIC_NAME = new QName(NAMESPACE_URI,
>>> "MyTopic", PREFIX);
>>>
>>>   public QName[] getPropertyNames()
>>>   {
>>>       return _PROPERTIES;
>>>   }
>>>
>>>   private int _MessageInterval = 10;
>>>
>>>   private String _ServerName = "muse-test.apache.org";
>>>
>>>   public int getMessageInterval()
>>>   {
>>>       return _MessageInterval;
>>>   }
>>>
>>>   public void setMessageInterval(int param0)
>>>   {
>>>       _MessageInterval = param0;
>>>   }
>>>
>>>   public String getServerName()
>>>   {
>>>       return _ServerName;
>>>   }
>>>
>>>   public void setServerName(String param0)
>>>   {
>>>       _ServerName = param0;
>>>   }
>>>
>>>   public void initializeCompleted()
>>>       throws SoapFault
>>>   {
>>>       super.initializeCompleted();
>>>
>>>       //
>>>       // access resource's WSN capability and create a new topic
>>>       //
>>>       final NotificationProducer wsn =
>>>
>>> (NotificationProducer)getResource().getCapability(WsnConstants.PRODUCER_URI);
>>>       wsn.addTopic(_TOPIC_NAME);
>>>
>>>       Thread producer = new Thread() {
>>>           public void run()
>>>           {
>>>               //
>>>               // for this example, reuse one payload for every
>>> notification
>>>               //
>>>               QName messageName = new QName(NAMESPACE_URI, "MyMessage",
>>> PREFIX);
>>>               try
>>>               {
>>>                       payload = runtimeEventOperation();
>>>               }
>>>               catch (Exception e)
>>>               {
>>>                       e.printStackTrace();
>>>               }
>>>
>>>               while (true)
>>>               {
>>>                   try
>>>                   {
>>>                       //
>>>                       // read current value - property is mutable
>>>                       //
>>>                       int currentInterval = getMessageInterval();
>>> //                        System.out.println(payload);
>>>
>>>                       getLog().info("Waiting " + currentInterval + "
>>> seconds before sending message...");
>>>                       Thread.currentThread().sleep(currentInterval *
>>> 1000);
>>>
>>>                       //
>>>                       // use WSN capability to send message to any
>>> subscribers
>>>                       //
>>>                       getLog().info("Sending message to consumers...");
>>>                       wsn.publish(_TOPIC_NAME, payload);
>>>                   }
>>>
>>>                   catch (Throwable error)
>>>                   {
>>>                       error.printStackTrace();
>>>                   }
>>>               }
>>>           }
>>>       };
>>>       producer.start();
>>>   }
>>>   private static ManagementEvent payload;
>>>   public ManagementEvent runtimeEventOperation() throws Exception{
>>>       WefFactory factory = new SimpleWefFactory();
>>>       ManagementEvent event = factory.createEvent();
>>>
>>>       Component reporter = factory.createComponent();
>>>       ComponentAddress reporterAddress =
>>>
>>> factory.createComponentAddress(getResource().getEndpointReference().toXML());
>>>       reporter.setAddress(reporterAddress);
>>>       reporter.setName(WefConstants.REPORTER_COMP_QNAME);
>>>
>>>       Component source = factory.createComponent();
>>>       ComponentAddress sourceAddress =
>>>
>>> factory.createComponentAddress(getResource().getEndpointReference().toXML());
>>>       source.setAddress(sourceAddress);
>>>       source.setName(WefConstants.SOURCE_COMP_QNAME);
>>>
>>>       Situation situation = factory.createSituation();
>>>
>>> situation.setCategoryType(WefConstants.AVAILABILITY_SITUATION_QNAME);
>>>       situation.setPriority(Situation.HIGH_PRIORITY);
>>>       situation.setMessage("Something important has happened in the
>>> "+getServerName()+"!");
>>>       event.setReporter(reporter);
>>>       event.setSource(source);
>>>       event.setSituation(situation);
>>>
>>>       event.addExtendedElement(MessageExtension());
>>>       return event;
>>> //        try{
>>> //                getLog().info("Sending message to consumers...");
>>> //                runtimeNotification.publish(_TOPIC_NAME, event);
>>> //                }
>>> //        catch (Throwable error){
>>> //                        error.printStackTrace();
>>> //                        }
>>> //        return event.toXML();
>>>      }
>>>
>>>      private Element MessageExtension()throws
>>> ParserConfigurationException, SAXException, IOException{
>>>       // create your XML message
>>>
>>>        File file = new
>>> File("E:/Awork/java/jakarta-tomcat-5.0.28/temp","test.xml");
>>>          DocumentBuilderFactory   dbf   =
>>> DocumentBuilderFactory.newInstance();
>>>          DocumentBuilder   db   =   dbf.newDocumentBuilder();
>>>          Document   doc   =   db.parse(file);
>>>          doc.normalize();
>>>          Element   root   =   doc.getDocumentElement();
>>>          return root;
>>>      }
>>> }
>>>
>>> --
>>> View this message in context:
>>> http://www.nabble.com/Transport-my-own-data-types--form-wsn-producer-to-wsn-consumer-tp23631392p23700618.html
>>> Sent from the Muse User mailing list archive at Nabble.com.
>>>
>>>
>

[ciel]

some errors are showed above and
1) tomcat's logs localhost_log.2009-05-25.txt (wsn-producer):

2009-05-25 14:15:07 StandardContext[/balancer]org.apache.webapp.balancer.BalancerFilter: init(): ruleChain: [org.apache.webapp.balancer.RuleChain: [org.apache.webapp.balancer.rules.URLStringMatchRule: Target string: News / Redirect URL: http://www.cnn.com], [org.apache.webapp.balancer.rules.RequestParameterRule: Target param name: paramName / Target param value: paramValue / Redirect URL: http://www.yahoo.com], [org.apache.webapp.balancer.rules.AcceptEverythingRule: Redirect URL: http://jakarta.apache.org]]
2009-05-25 14:15:07 StandardContext[/jsp-examples]ContextListener: contextInitialized()
2009-05-25 14:15:07 StandardContext[/jsp-examples]SessionListener: contextInitialized()
2009-05-25 14:15:07 StandardContext[/servlets-examples]ContextListener: contextInitialized()
2009-05-25 14:15:07 StandardContext[/servlets-examples]SessionListener: contextInitialized()
2009-05-25 14:16:03 StandardContext[/servlets-examples]ContextListener: attributeReplaced('org.apache.catalina.WELCOME_FILES', '[Ljava.lang.String;@42a818')

2) wsn-producer's log:
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://schemas.xmlsoap.org/ws/2004/09/mex/GetMetadata'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://docs.oasis-open.org/wsrf/rlw-2/ImmediateResourceTermination'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://docs.oasis-open.org/wsrf/rlw-2/ScheduledResourceTermination'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://docs.oasis-open.org/wsrf/rpw-2/Get'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://docs.oasis-open.org/wsrf/rpw-2/Query'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://docs.oasis-open.org/wsrf/rpw-2/Set'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://docs.oasis-open.org/wsn/bw-2/NotificationProducer'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://docs.oasis-open.org/wsdm/muws/capabilities/Identity'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://docs.oasis-open.org/wsdm/muws/capabilities/ManageabilityCharacteristics'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://docs.oasis-open.org/wsdm/muws/capabilities/Description'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://docs.oasis-open.org/wsdm/muws/capabilities/OperationalStatus'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'WsResource' has started initialization of capability 'http://ws.apache.org/muse/test/wsrf/MyCapability'.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://schemas.xmlsoap.org/ws/2004/09/mex/GetMetadata.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://docs.oasis-open.org/wsrf/rlw-2/ImmediateResourceTermination.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://docs.oasis-open.org/wsrf/rlw-2/ScheduledResourceTermination.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://docs.oasis-open.org/wsrf/rpw-2/Get.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://docs.oasis-open.org/wsrf/rpw-2/Query.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://docs.oasis-open.org/wsrf/rpw-2/Set.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://docs.oasis-open.org/wsn/bw-2/NotificationProducer.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://docs.oasis-open.org/wsdm/muws/capabilities/Identity.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://docs.oasis-open.org/wsdm/muws/capabilities/ManageabilityCharacteristics.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://docs.oasis-open.org/wsdm/muws/capabilities/Description.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://docs.oasis-open.org/wsdm/muws/capabilities/OperationalStatus.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'WsResource' has completed initialization of capability 'http://ws.apache.org/muse/test/wsrf/MyCapability.
2009-5-25 14:15:29 org.apache.muse.core.SimpleResource initialize
信息: [ID = 'ResourceInitialized'] The resource at 'WsResource' has been initialized.
2009-5-25 14:15:29 org.apache.muse.core.routing.SimpleResourceRouter initialize
信息: [ID = 'RouterIsInitialized'] The resource router has been initialized.
2009-5-25 14:15:29 org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1 run
信息: Waiting 10 seconds before sending message...
2009-5-25 14:15:29 org.apache.muse.util.LoggingUtils logMessage
良好: [SERVER TRACE] SOAP envelope contents (incoming):

<soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope">
    <soap:Header>
        <wsa:To xmlns:wsa="http://www.w3.org/2005/08/addressing">http://localhost:8080/wsn-producer/services/WsResource</wsa:To>
        <wsa:Action xmlns:wsa="http://www.w3.org/2005/08/addressing">http://docs.oasis-open.org/wsrf/rpw-2/GetResourceProperty/GetResourcePropertyRequest</wsa:Action>
        <wsa:MessageID xmlns:wsa="http://www.w3.org/2005/08/addressing">uuid:5b0123cb-9fc9-b924-82b9-374e4d664be5</wsa:MessageID>
        <wsa:From xmlns:wsa="http://www.w3.org/2005/08/addressing">
            <wsa:Address>http://www.w3.org/2005/08/addressing/role/anonymous</wsa:Address>
        </wsa:From>
    </soap:Header>
    <soap:Body>
        <wsrf-rp:GetResourceProperty
            xmlns:pfx1="http://ws.apache.org/muse/test/wsrf" xmlns:wsrf-rp="http://docs.oasis-open.org/wsrf/rp-2">pfx1:ServerName</wsrf-rp:GetResourceProperty>
    </soap:Body>
</soap:Envelope>


2009-5-25 14:15:29 org.apache.muse.util.LoggingUtils logMessage
良好: [SERVER TRACE] SOAP envelope contents (outgoing):

<soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope">
    <soap:Header>
        <wsa:To xmlns:wsa="http://www.w3.org/2005/08/addressing">http://www.w3.org/2005/08/addressing/role/anonymous</wsa:To>
        <wsa:Action xmlns:wsa="http://www.w3.org/2005/08/addressing">http://docs.oasis-open.org/wsrf/rpw-2/GetResourceProperty/GetResourcePropertyResponse</wsa:Action>
        <wsa:MessageID xmlns:wsa="http://www.w3.org/2005/08/addressing">uuid:f511d309-7855-5402-4df6-272ebb23d57c</wsa:MessageID>
        <wsa:RelatesTo xmlns:wsa="http://www.w3.org/2005/08/addressing" RelationshipType="wsa:Reply">uuid:5b0123cb-9fc9-b924-82b9-374e4d664be5</wsa:RelatesTo>
        <wsa:From xmlns:wsa="http://www.w3.org/2005/08/addressing">
            <wsa:Address>http://localhost:8080/wsn-producer/services/WsResource</wsa:Address>
        </wsa:From>
    </soap:Header>
    <soap:Body>
        <wsrf-rp:GetResourcePropertyResponse xmlns:wsrf-rp="http://docs.oasis-open.org/wsrf/rp-2">
            <pfx1:ServerName xmlns:pfx1="http://ws.apache.org/muse/test/wsrf">muse-test.apache.org</pfx1:ServerName>
        </wsrf-rp:GetResourcePropertyResponse>
    </soap:Body>
</soap:Envelope>


2009-5-25 14:15:30 org.apache.muse.util.LoggingUtils logMessage
良好: [SERVER TRACE] SOAP envelope contents (incoming):

<soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope">
    <soap:Header>
        <wsa:To xmlns:wsa="http://www.w3.org/2005/08/addressing">http://localhost:8080/wsn-producer/services/WsResource</wsa:To>
        <wsa:Action xmlns:wsa="http://www.w3.org/2005/08/addressing">http://docs.oasis-open.org/wsn/bw-2/NotificationProducer/SubscribeRequest</wsa:Action>
        <wsa:MessageID xmlns:wsa="http://www.w3.org/2005/08/addressing">uuid:60819b9b-cf02-6168-3c69-f2f8d0a0ee71</wsa:MessageID>
        <wsa:From xmlns:wsa="http://www.w3.org/2005/08/addressing">
            <wsa:Address>http://www.w3.org/2005/08/addressing/role/anonymous</wsa:Address>
        </wsa:From>
    </soap:Header>
    <soap:Body>
        <wsnt:Subscribe xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2">
            <wsnt:ConsumerReference>
                <wsa:Address xmlns:wsa="http://www.w3.org/2005/08/addressing">http://192.168.6.251:8080/wsn-consumer/services/consumer</wsa:Address>
            </wsnt:ConsumerReference>
        </wsnt:Subscribe>
    </soap:Body>
</soap:Envelope>


2009-5-25 14:15:30 org.apache.muse.ws.notification.impl.SimpleSubscriptionManager setSubscriptionPolicy
警告: [ID = 'PolicyNotSupported'] WS-N SubscriptionPolicy is not supported. The policy value was: null
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'SubscriptionManager' has started initialization of capability 'http://schemas.xmlsoap.org/ws/2004/09/mex/GetMetadata'.
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'SubscriptionManager' has started initialization of capability 'http://docs.oasis-open.org/wsrf/rpw-2/Get'.
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'SubscriptionManager' has started initialization of capability 'http://docs.oasis-open.org/wsn/bw-2/SubscriptionManager'.
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'SubscriptionManager' has started initialization of capability 'http://docs.oasis-open.org/wsrf/rlw-2/ImmediateResourceTermination'.
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'SubscriptionManager' has started initialization of capability 'http://docs.oasis-open.org/wsrf/rlw-2/ScheduledResourceTermination'.
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'SubscriptionManager' has completed initialization of capability 'http://schemas.xmlsoap.org/ws/2004/09/mex/GetMetadata.
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'SubscriptionManager' has completed initialization of capability 'http://docs.oasis-open.org/wsrf/rpw-2/Get.
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'SubscriptionManager' has completed initialization of capability 'http://docs.oasis-open.org/wsn/bw-2/SubscriptionManager.
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'SubscriptionManager' has completed initialization of capability 'http://docs.oasis-open.org/wsrf/rlw-2/ImmediateResourceTermination.
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'SubscriptionManager' has completed initialization of capability 'http://docs.oasis-open.org/wsrf/rlw-2/ScheduledResourceTermination.
2009-5-25 14:15:30 org.apache.muse.core.SimpleResource initialize
信息: [ID = 'ResourceInitialized'] The resource at 'SubscriptionManager' has been initialized.
2009-5-25 14:15:30 org.apache.muse.util.LoggingUtils logMessage
良好: [SERVER TRACE] SOAP envelope contents (outgoing):

<soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope">
    <soap:Header>
        <wsa:To xmlns:wsa="http://www.w3.org/2005/08/addressing">http://www.w3.org/2005/08/addressing/role/anonymous</wsa:To>
        <wsa:Action xmlns:wsa="http://www.w3.org/2005/08/addressing">http://docs.oasis-open.org/wsn/bw-2/NotificationProducer/SubscribeResponse</wsa:Action>
        <wsa:MessageID xmlns:wsa="http://www.w3.org/2005/08/addressing">uuid:77358c3e-1a0c-f364-f0d1-afe2c1ee7d89</wsa:MessageID>
        <wsa:RelatesTo xmlns:wsa="http://www.w3.org/2005/08/addressing" RelationshipType="wsa:Reply">uuid:60819b9b-cf02-6168-3c69-f2f8d0a0ee71</wsa:RelatesTo>
        <wsa:From xmlns:wsa="http://www.w3.org/2005/08/addressing">
            <wsa:Address>http://localhost:8080/wsn-producer/services/WsResource</wsa:Address>
        </wsa:From>
    </soap:Header>
    <soap:Body>
        <wsnt:SubscribeResponse xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2">
            <wsnt:SubscriptionReference>
                <wsa:Address xmlns:wsa="http://www.w3.org/2005/08/addressing">http://localhost:8080/wsn-producer/services/SubscriptionManager</wsa:Address>
                <wsa:ReferenceParameters xmlns:wsa="http://www.w3.org/2005/08/addressing">
                    <muse-wsa:ResourceId xmlns:muse-wsa="http://ws.apache.org/muse/addressing">MuseResource-1</muse-wsa:ResourceId>
                </wsa:ReferenceParameters>
            </wsnt:SubscriptionReference>
            <wsnt:CurrentTime>2009-05-25T14:15:30+08:00</wsnt:CurrentTime>
        </wsnt:SubscribeResponse>
    </soap:Body>
</soap:Envelope>


2009-5-25 14:15:39 org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1 run
信息: Sending message to consumers...
2009-5-25 14:15:41 org.apache.muse.util.LoggingUtils logError
信息: There was an error while processing a request:

The element type "HR" must be terminated by the matching end-tag "</HR>".

        org.apache.muse.core.AbstractResourceClient.invoke(AbstractResourceClient.java:298)
        org.apache.muse.core.AbstractResourceClient.invoke(AbstractResourceClient.java:254)
        org.apache.muse.ws.notification.remote.NotificationConsumerClient.notify(NotificationConsumerClient.java:99)
        org.apache.muse.ws.notification.impl.SimpleSubscriptionManager.publish(SimpleSubscriptionManager.java:267)
        org.apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(SimpleNotificationProducer.java:445)
        org.apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(SimpleNotificationProducer.java:473)
        org.apache.muse.ws.notification.impl.SimpleNotificationProducer.publish(SimpleNotificationProducer.java:462)
        org.apache.ws.muse.test.wsrf.MyCapabilityImpl$1.run(Unknown Source)
       
------------------------------------------

3) tomcat's logs localhost_log.2009-05-25.txt (wsn-consumer):
2009-05-25 14:15:07 StandardContext[/balancer]org.apache.webapp.balancer.BalancerFilter: init(): ruleChain: [org.apache.webapp.balancer.RuleChain: [org.apache.webapp.balancer.rules.URLStringMatchRule: Target string: News / Redirect URL: http://www.cnn.com], [org.apache.webapp.balancer.rules.RequestParameterRule: Target param name: paramName / Target param value: paramValue / Redirect URL: http://www.yahoo.com], [org.apache.webapp.balancer.rules.AcceptEverythingRule: Redirect URL: http://jakarta.apache.org]]
2009-05-25 14:15:10 StandardContext[/jsp-examples]ContextListener: contextInitialized()
2009-05-25 14:15:10 StandardContext[/jsp-examples]SessionListener: contextInitialized()
2009-05-25 14:15:10 StandardContext[/servlets-examples]ContextListener: contextInitialized()
2009-05-25 14:15:10 StandardContext[/servlets-examples]SessionListener: contextInitialized()
2009-05-25 14:15:41 StandardWrapperValve[ApacheMuseServlet]: Servlet.service() for servlet ApacheMuseServlet threw exception
java.io.IOException: Element or attribute do not match QName production: QName::=(NCName':')?NCName.
        at org.apache.muse.core.platform.mini.MiniServlet.doPost(MiniServlet.java:81)
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:709)
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:802)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:237)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:157)
        at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:214)
        at org.apache.catalina.core.StandardValveContext.invokeNext(StandardValveContext.java:104)
        at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:520)
        at org.apache.catalina.core.StandardContextValve.invokeInternal(StandardContextValve.java:198)
        at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:152)
        at org.apache.catalina.core.StandardValveContext.invokeNext(StandardValveContext.java:104)
        at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:520)
        at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:137)
        at org.apache.catalina.core.StandardValveContext.invokeNext(StandardValveContext.java:104)
        at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:118)
        at org.apache.catalina.core.StandardValveContext.invokeNext(StandardValveContext.java:102)
        at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:520)
        at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)
        at org.apache.catalina.core.StandardValveContext.invokeNext(StandardValveContext.java:104)
        at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:520)
        at org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:929)
        at org.apache.coyote.tomcat5.CoyoteAdapter.service(CoyoteAdapter.java:160)
        at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:799)
        at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.processConnection(Http11Protocol.java:705)
        at org.apache.tomcat.util.net.TcpWorkerThread.runIt(PoolTcpEndpoint.java:577)
        at org.apache.tomcat.util.threads.ThreadPool$ControlRunnable.run(ThreadPool.java:683)
        at java.lang.Thread.run(Thread.java:595)

4) wsn-consumer's log:
2009-5-25 14:15:41 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'consumer' has started initialization of capability 'http://docs.oasis-open.org/wsn/bw-2/NotificationConsumer'.
2009-5-25 14:15:41 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitialized'] The resource at 'consumer' has started initialization of capability 'http://ws.apache.org/muse/test/wsn/consumer'.
2009-5-25 14:15:41 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'consumer' has completed initialization of capability 'http://docs.oasis-open.org/wsn/bw-2/NotificationConsumer.
2009-5-25 14:15:41 org.apache.muse.core.SimpleResource initializeCapabilities
良好: [ID = 'CapabilityInitializationComplete'] The resource at 'consumer' has completed initialization of capability 'http://ws.apache.org/muse/test/wsn/consumer.
2009-5-25 14:15:41 org.apache.muse.core.SimpleResource initialize
信息: [ID = 'ResourceInitialized'] The resource at 'consumer' has been initialized.
2009-5-25 14:15:41 org.apache.muse.core.routing.SimpleResourceRouter initialize
信息: [ID = 'RouterIsInitialized'] The resource router has been initialized.