It took me a while to grok this problem, but I think that's a problem with
WS-*, not your email. :) I understand what's happening but do not have
the solution yet. I will copy this into a JIRA item and start work on it
on Monday.
Thanks,
Dan
Christian Ewers <[EMAIL PROTECTED]> wrote on 01/05/2007 06:16:09 AM:
>
> Hi,
>
> I want to reduce message exchanges when getting the
> ServiceGroupEntry-Properties by buffering the content elements instead
of
> getting it directly from the member-resource at every call.
> Fro doing so, I tried to extend the SimpleEntry class by buffering the
> content element and get notified by updates via WSRP change
notifications.
> That for the ServiceGroupEntry subscribes itself to the
content-properties
> (in my simple case the OperationalStatus) of the member-resource at the
end
> of its initializeCompleted-method:
>
> public void initializeCompleted() throws SoapFault {
> super.initializeCompleted();
> subscribeToMemberProperties();
> }
>
> private void subscribeToMemberProperties(){
> try {
> ServiceGroup sg =
>
(ServiceGroup)getServiceGroup().getCapability(WssgConstants.SERVICE_GROUP_URI);
>
> NotificationConsumer consumerCap =
>
(NotificationConsumer)getResource().getCapability(WsnConstants.CONSUMER_URI);
>
> EndpointReference producerEPR = getMemberEPR();
> EndpointReference myEPR = getResource().getEndpointReference();
>
> NotificationProducerClient producer = new
> NotificationProducerClient(producerEPR);
> if(logger.isDebugEnabled()){
> producer.setTrace(true);
> }
> //get the Property-QNames for the properties to subscribe
for
> QName[] contentNames = sg.getContentElements();
> for (QName topic : contentNames) {
> //
> // Step 1: subscribe myself to the producer resource
> //
> TopicFilter filter = new TopicFilter(topic);
> this.subscriptionClient = producer.subscribe(myEPR,
filter,
> null);
>
> // Add MessageListener for the topic (a simple private
> innerClass that accepts all messages when the subscriptionReferenceEPR
> equals the saved subscriptionClient.getEPR())
> EntryMessageListener listener = new
> EntryMessageListener(topic);
> consumerCap.addMessageListener(listener);
> }
> } catch (BaseFault e) {
> logger.error("subscribeToMemberProperties()", e);
> } catch (SoapFault e) {
> logger.error("subscribeToMemberProperties()", e);
> }
> }
>
> Can I create a single Filter for all contentElements? Could I do that
with
> the new FilterSet (JIRA - MUSE-122) ?
>
> With having two Resources I have the following subscriptions when
> registering the resources to the ServiceGroup:
>
> ServiceGroupEntry - MuseResource-2 subscribes to WsResource -
> MuseResource-1
>
> <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://134.100.14.93:
> 8080/DefaultService/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:9c01d504-
> eebd-5801-154e-22a17bc3a008</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>
> <muse-wsa:ResourceId
> xmlns:wsa="http://www.w3.org/2005/08/addressing";
> wsa:IsReferenceParameter="true"
>
xmlns:muse-wsa="http://ws.apache.org/muse/addressing";>MuseResource-1</muse-
> wsa:ResourceId>
> </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.28.1:
> 8080/RegistryService/services/ServiceGroupEntry</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-2</muse-
> wsa:ResourceId>
> </wsa:ReferenceParameters>
> </wsnt:ConsumerReference>
> <wsnt:Filter>
> <wsnt:TopicExpression
>
> Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Concrete";
> xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";>muws2:
> OperationalStatus</wsnt:TopicExpression>
> </wsnt:Filter>
> </wsnt:Subscribe>
> </soap:Body>
> </soap:Envelope>
>
> ServiceGroupEntry - MuseResource-3 subscribes to WsResource -
> MuseResource-2
>
> <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://134.100.14.93:
> 8080/DefaultService/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:993f6ca5-ea17-ce36-c9c3-
> ac45351da5ad</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>
> <muse-wsa:ResourceId
> xmlns:wsa="http://www.w3.org/2005/08/addressing";
> wsa:IsReferenceParameter="true"
>
xmlns:muse-wsa="http://ws.apache.org/muse/addressing";>MuseResource-2</muse-
> wsa:ResourceId>
> </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.28.1:
> 8080/RegistryService/services/ServiceGroupEntry</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-3</muse-
> wsa:ResourceId>
> </wsa:ReferenceParameters>
> </wsnt:ConsumerReference>
> <wsnt:Filter>
> <wsnt:TopicExpression
>
> Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Concrete";
> xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";>muws2:
> OperationalStatus</wsnt:TopicExpression>
> </wsnt:Filter>
> </wsnt:Subscribe>
> </soap:Body>
> </soap:Envelope>
>
> When changing the OperationalStatus of WsResource - MuseResource-1 to
> Unavailable by:
>
> <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://134.100.14.93:
> 8080/DefaultService/services/WsResource</wsa:To>
> <wsa:Action
> xmlns:wsa="http://www.w3.org/2005/08/addressing";>http://docs.oasis-open.
>
org/wsrf/rpw-2/SetResourceProperties/SetResourcePropertiesRequest</wsa:Action>
> <wsa:MessageID
> xmlns:wsa="http://www.w3.org/2005/08/addressing";>uuid:
> be807ac5-5dbb-96ed-6d1d-61c7629b0694</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>
> <muse-wsa:ResourceId
> xmlns:wsa="http://www.w3.org/2005/08/addressing";
> wsa:IsReferenceParameter="true"
>
xmlns:muse-wsa="http://ws.apache.org/muse/addressing";>MuseResource-1</muse-
> wsa:ResourceId>
> </soap:Header>
> <soap:Body>
> <wsrf-rp:SetResourceProperties
> xmlns:wsrf-rp="http://docs.oasis-open.org/wsrf/rp-2";>
> <wsrf-rp:Update>
> <muws2:OperationalStatus
>
xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";>Unavailable</muws2:
> OperationalStatus>
> </wsrf-rp:Update>
> </wsrf-rp:SetResourceProperties>
> </soap:Body>
> </soap:Envelope>
>
> I get the following Notifications from both WsResources:
>
> WsResource - MuseResource-1 notifies its entry (as it should be)
>
> <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.28.1:
> 8080/RegistryService/services/ServiceGroupEntry</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:10e4f1ff-0b96-
> fe39-3766-81a50ea820db</wsa:MessageID>
> <wsa:From xmlns:wsa="http://www.w3.org/2005/08/addressing";>
>
>
<wsa:Address>http://134.100.14.93:8080/DefaultService/services/WsResource</wsa:Address>
> <wsa:ReferenceParameters>
> <muse-wsa:ResourceId
>
xmlns:muse-wsa="http://ws.apache.org/muse/addressing";>MuseResource-1</muse-
> wsa:ResourceId>
> </wsa:ReferenceParameters>
> </wsa:From>
> <muse-wsa:ResourceId
> xmlns:wsa="http://www.w3.org/2005/08/addressing";
> wsa:IsReferenceParameter="true"
>
xmlns:muse-wsa="http://ws.apache.org/muse/addressing";>MuseResource-2</muse-
> wsa:ResourceId>
> </soap:Header>
> <soap:Body>
> <wsnt:Notify xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2";>
> <wsnt:NotificationMessage
> xmlns:muse-wsa="http://ws.apache.org/muse/addressing";
> xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";
> xmlns:wsa="http://www.w3.org/2005/08/addressing";
> xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2";
> xmlns:wsrf-rp="http://docs.oasis-open.org/wsrf/rp-2";>
> <wsnt:SubscriptionReference>
> <wsa:Address
> xmlns:wsa="http://www.w3.org/2005/08/addressing";>http://134.100.14.93:
> 8080/DefaultService/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-2</muse-
> wsa:ResourceId>
> </wsa:ReferenceParameters>
> </wsnt:SubscriptionReference>
> <wsnt:Topic
>
> Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Concrete";
> xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";>muws2:
> OperationalStatus</wsnt:Topic>
> <wsnt:ProducerReference>
> <wsa:Address
> xmlns:wsa="http://www.w3.org/2005/08/addressing";>http://134.100.14.93:
> 8080/DefaultService/services/WsResource</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:ProducerReference>
> <wsnt:Message>
> <wsrf-rp:ResourcePropertyValueChangeNotification
> xmlns:wsrf-rp="http://docs.oasis-open.org/wsrf/rp-2";>
> <wsrf-rp:OldValues>
> <muws2:OperationalStatus
>
xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";>Available</muws2:
> OperationalStatus>
> </wsrf-rp:OldValues>
> <wsrf-rp:NewValues>
> <muws2:OperationalStatus
>
xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";>Unavailable</muws2:
> OperationalStatus>
> </wsrf-rp:NewValues>
> </wsrf-rp:ResourcePropertyValueChangeNotification>
> </wsnt:Message>
> </wsnt:NotificationMessage>
> </wsnt:Notify>
> </soap:Body>
> </soap:Envelope>
>
> And WsResource - MuseResource-2 notifies its Entry of an
> PropertyValueChange (that is my problem)
>
> <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.28.1:
> 8080/RegistryService/services/ServiceGroupEntry</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:29bdb8a0-6936-1185-9b7f-
> d31ddc978590</wsa:MessageID>
> <wsa:From xmlns:wsa="http://www.w3.org/2005/08/addressing";>
>
>
<wsa:Address>http://134.100.14.93:8080/DefaultService/services/WsResource</wsa:Address>
> <wsa:ReferenceParameters>
> <muse-wsa:ResourceId
>
xmlns:muse-wsa="http://ws.apache.org/muse/addressing";>MuseResource-2</muse-
> wsa:ResourceId>
> </wsa:ReferenceParameters>
> </wsa:From>
> <muse-wsa:ResourceId
> xmlns:wsa="http://www.w3.org/2005/08/addressing";
> wsa:IsReferenceParameter="true"
>
xmlns:muse-wsa="http://ws.apache.org/muse/addressing";>MuseResource-3</muse-
> wsa:ResourceId>
> </soap:Header>
> <soap:Body>
> <wsnt:Notify xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2";>
> <wsnt:NotificationMessage
> xmlns:muse-wsa="http://ws.apache.org/muse/addressing";
> xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";
> xmlns:wsa="http://www.w3.org/2005/08/addressing";
> xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2";
> xmlns:wsrf-rp="http://docs.oasis-open.org/wsrf/rp-2";>
> <wsnt:SubscriptionReference>
> <wsa:Address
> xmlns:wsa="http://www.w3.org/2005/08/addressing";>http://134.100.14.93:
> 8080/DefaultService/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-3</muse-
> wsa:ResourceId>
> </wsa:ReferenceParameters>
> </wsnt:SubscriptionReference>
> <wsnt:Topic
>
> Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Concrete";
> xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";>muws2:
> OperationalStatus</wsnt:Topic>
> <wsnt:ProducerReference>
> <wsa:Address
> xmlns:wsa="http://www.w3.org/2005/08/addressing";>http://134.100.14.93:
> 8080/DefaultService/services/WsResource</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-2</muse-
> wsa:ResourceId>
> </wsa:ReferenceParameters>
> </wsnt:ProducerReference>
> <wsnt:Message>
> <wsrf-rp:ResourcePropertyValueChangeNotification
> xmlns:wsrf-rp="http://docs.oasis-open.org/wsrf/rp-2";>
> <wsrf-rp:OldValues>
> <muws2:OperationalStatus
>
xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";>Available</muws2:
> OperationalStatus>
> </wsrf-rp:OldValues>
> <wsrf-rp:NewValues>
> <muws2:OperationalStatus
>
xmlns:muws2="http://docs.oasis-open.org/wsdm/muws2-2.xsd";>Unavailable</muws2:
> OperationalStatus>
> </wsrf-rp:NewValues>
> </wsrf-rp:ResourcePropertyValueChangeNotification>
> </wsnt:Message>
> </wsnt:NotificationMessage>
> </wsnt:Notify>
> </soap:Body>
> </soap:Envelope>
>
> When getting the ResourcePropertiesDocument of WsResource -
MuseResource-2
> the OperationalStatus is still "Available" as it should be. Although the
> notification of a change was sent.
> I don't know what I am doing wrong, am I handling the subscription
process
> right?
> Sorry for this long email, I hope the xml-output will be readable.
> Thanks,
> Christian
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: [EMAIL PROTECTED]
> For additional commands, e-mail: [EMAIL PROTECTED]
>
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
