Hi Dan. I modified the wsn-producer to have 2 resources in the same war with different topics on the producer side. I modified the wsn-consumer to have 2 different MessageListener(s) and to subscribe to separate topics using TopicFilter. Although both MessageListener(s) have their own subscriptions, the NotificationMessage(s) are sent to the one NotificationConsumerClient, which passes the messages to all registered listeners, so both listeners get the both messages. This means that the listeners have to filter in the accept() method using the same filter specified in the subscription. OR am I doing something wrong? I checked the code, and it seems there is no way around this.
Daniel Jemiolo wrote: > > It does have this operation, but there are two resource types in the > wsn-producer sample: the producer resource and the subscription resource. > you need to add the WSRP Set capability to the *subscription* resource's > WSDL/definition. you can find the subscription portType in > /wsdl/WS-BaseNotification-1_3.wsdl - you'll need to copy in the > SetResourceProperties content. > > As for your scenario, I believe what you want to do is have each consumer > resource subscribe() with the producer, specifying their own filters each > time. They will each get back their own subscription reference, and the > filter will already be set to what they need. Trying to share one > subscription among many consumer resources won't work for two reasons: > > 1. A WSN subscription can only have one consumer (wsnt:ConsumerReference). > > 2. Setting the filter and receiving notifications will not be an atomic > operation, and the latter takes an unknown amount of time, so you have a > big synchronization problem. > > The right way to handle this is to use NotificationProducerClient in your > ConsumerCapability.initialize() method to subscribe() using the filters > you want. Then you don't have to filter on the consumer side - you > subscribed with a given filter, so you know that you're going to get > messages that meet that filter. you only need to change the filter (with > SetResourceProperties) if a consumer resource wants to change the type of > data its processing, not because of something another consumer resource > has done. > > Dan > > > > dnguyen <[EMAIL PROTECTED]> wrote on 02/28/2007 06:48:07 PM: > >> >> Hi. The wsn-producer sample has that operation in the WsResource.wsdl >> already. I am assuming that I do not need to create one for > wsn-consumer? >> The scenario we are going for with the updates of the filter is that >> multiple client applications will be using this one wsn-consumer WS, > since >> we were not sure of dynamic deployment of wsn-consumer WS for distinct >> endpoints. Each client would specify its own filter for data, which > would >> be passed to a "broker" (each client would also have an associated >> ConsumerCapability that will have that client's filter), which would > then >> update the filter to the existing subscription. Since the notify call > would >> contain the combine data from the producer, the wsn-consumer WS would > then >> pass the data to each ConsumerCapability to be filtered again for their >> perspective clients. >> >> We didn't want to do the filtering twice, but we don't see another way > at >> the moment. Please let us know if there is a better way to do this. >> >> Regards, >> Dong >> >> >> Daniel Jemiolo wrote: >> > >> > You would need to add the WSRP Set capability ( >> > http://docs.oasis-open.org/wsrf/rpw-2/Set), with impl class >> > org.apache.muse.ws.resource.properties.set.impl.SimpleSetCapability. > It >> > will probably be easier if you add the WSRP SetResourceProperties >> > operation to your WSDL and have wsdl2java handle all of the > code/artifact >> > generation. The SetResourceProperties WSDL content can be found in the > >> > 'wsrf' sample app (see /wsdl/WsResource.wsdl). >> > >> > However, no one has ever tried to switch a subscription filter >> > mid-lifecycle, and so I believe a serializer for the Filter type will > also >> > be needed. Let me work on this for a few minutes and assuming I can > fix >> > the scenario, I'll write back and have you try the nightly build > (you'll >> > still need to add SetResourceProperties to your WSDL). >> > >> > Dan >> > >> > >> > >> > dnguyen <[EMAIL PROTECTED]> wrote on 02/28/2007 04:39:00 PM: >> > >> >> >> >> I am trying to update the filter in the SubscriptionClient through > the >> >> updateResourceProperty() method but not having any success. I get > the >> > error >> >> below: >> >> >> >> >> >> ****************************** >> >> org.apache.muse.ws.addressing.soap.SoapFault: [ID = >> > 'ActionNotSupported'] >> >> The re >> >> source at 'SubscriptionManager' does not expose an operation with the >> >> WS-Action >> >> 'http://docs.oasis-open. >> >> org/wsrf/rpw-2/SetResourceProperties/SetResourcePropertiesRequest' >> >> through any of its capabilities. >> >> at >> >> >> > > org.apache.muse.core.AbstractResourceClient.invoke(AbstractResourceClient.java:279) >> >> at >> >> >> > > org.apache.muse.core.AbstractResourceClient.invoke(AbstractResourceClient.java:235) >> >> at >> >> org.apache.muse.ws.resource.remote.WsResourceClient. >> >> setResourceProperties(WsResourceClient.java:175) >> >> at >> >> org.apache.muse.ws.resource.remote.WsResourceClient. >> >> updateResourceProperty(WsResourceClient.java:202) >> >> at org.apache.muse.test.wsn.WsnTestClient2.main(Unknown > Source) >> >> ************************************ >> >> >> >> >> >> I then added this to the SubscriptionManager resource in the >> > wsn-producer >> >> muse.xml file: >> >> >> >> >> >> ************************************* >> >> <capability> >> >> >> >> >> > > <capability-uri>http://docs.oasis-open.org/wsrf/rpw-2/Get</capability-uri> >> >> >> >> > <java-capability-class>org.apache.muse.ws.resource.properties.get.impl. >> >> SimpleGetCapability</java-capability-class> >> >> </capability> >> >> ************************************ >> >> >> >> >> >> But I still get the same exception. I looked in the source code for >> >> anything related to SetResourceProperties but didn't find anything >> > helpful. >> >> I read that the WS-N spec states that the impl can throw an exception > in >> >> this case, but it also says this is allowed. I am not sure if this > is >> >> allowable in Muse, but the error message indicates it is possible by >> > adding >> >> the correct capability. Also, I am not sure I am doing this right. > The >> >> example I am using is below >> >> >> >> >> >> ******************************* >> >> package org.apache.muse.test.wsn; >> >> >> >> import javax.xml.namespace.QName; >> >> >> >> import java.net.InetAddress; >> >> import java.net.URI; >> >> import java.net.UnknownHostException; >> >> >> >> import org.apache.muse.ws.addressing.EndpointReference; >> >> import >> > org.apache.muse.ws.notification.remote.NotificationProducerClient; >> >> import org.apache.muse.ws.notification.remote.SubscriptionClient; >> >> import org.apache.muse.ws.notification.impl.*; >> >> import org.apache.muse.ws.notification.WsnConstants; >> >> import org.apache.muse.util.xml.*; >> >> >> >> >> >> public class WsnTestClient2 >> >> { >> >> public static URI getLocalAddress(String contextPath, int port) >> >> throws UnknownHostException >> >> { >> >> String ip = InetAddress.getLocalHost().getHostAddress(); >> >> >> >> StringBuffer address = new StringBuffer(); >> >> address.append("http://";); >> >> address.append(ip); >> >> address.append(':'); >> >> address.append(port); >> >> >> >> if (contextPath.charAt(0) != '/') >> >> address.append('/'); >> >> >> >> address.append(contextPath); >> >> >> >> return URI.create(address.toString()); >> >> } >> >> >> >> public static void main(String[] args) >> >> { >> >> try >> >> { >> >> // >> >> // change these to point to different > applications/servers >> >> // >> >> String webAppRoot = "/isr-producer/services"; >> >> int producer_port = >> >> Integer.parseInt(System.getProperty("producer_port","8080")); >> >> int consumer_port = >> >> Integer.parseInt(System.getProperty("consumer_port","8080")); >> >> >> >> // >> >> // create producer EPR/client, and use it to subscribe >> >> // the consumer to all messages >> >> // >> >> >> >> String contextPath = webAppRoot + "/IsrResource"; >> >> URI address = (args.length == 0) ? >> > getLocalAddress(contextPath, >> >> producer_port) : URI.create(args[0] + contextPath); >> >> EndpointReference epr = new EndpointReference(address); >> >> >> >> webAppRoot = "/isr-consumer/services"; >> >> contextPath = webAppRoot + "/IsrConsumer"; >> >> address = getLocalAddress(contextPath, consumer_port); >> >> EndpointReference consumer = new > EndpointReference(address); >> >> >> >> // >> >> // null filter == send all messages to consumer >> >> // >> >> NotificationProducerClient producer = new >> >> NotificationProducerClient(epr); >> >> producer.setTrace(true); >> >> >> >> SubscriptionClient subscription = null; >> >> >> >> while( true ) >> >> { >> >> System.out.println( "s - subscribe, u - unsubscribe, > v - >> >> view, q - quit" ); >> >> >> >> char choice = (char)System.in.read(); >> >> >> >> if( choice == 's' ) >> >> { >> >> subscription = producer.subscribe(consumer, null, > >> > null); >> >> } >> >> else if( choice == 'u' ) >> >> { >> >> subscription.destroy(); >> >> } >> >> else if( choice == 'v' ) >> >> { >> >> >> >> System.out.println(XmlUtils.toString(subscription. >> >> getResourceProperty(WsnConstants.FILTER_QNAME)[0])); >> >> } >> >> else if( choice == 'f' ) >> >> { >> >> QName messageName = new >> >> QName("http://ws.apache.org/muse/test/wsrf";, "MyTopic", "tns"); >> >> >> >> subscription.updateResourceProperty(WsnConstants.FILTER_QNAME, new >> > Object[] >> >> { new TopicFilter(messageName) }); >> >> } >> >> else if( choice == 'q' ) >> >> { >> >> break; >> >> } >> >> } >> >> } >> >> >> >> catch (Throwable error) >> >> { >> >> error.printStackTrace(); >> >> } >> >> } >> >> } >> >> >> >> -- >> >> View this message in context: http://www.nabble.com/Problem-updating- >> >> subscription-resource-property.-tf3323382.html#a9239032 >> >> Sent from the Muse User mailing list archive at Nabble.com. >> >> >> >> >> >> --------------------------------------------------------------------- >> >> 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] >> > >> > >> > >> >> -- >> View this message in context: http://www.nabble.com/Problem-updating- >> subscription-resource-property.-tf3323382.html#a9241004 >> Sent from the Muse User mailing list archive at Nabble.com. >> >> >> --------------------------------------------------------------------- >> 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] > > > -- View this message in context: http://www.nabble.com/Problem-updating-subscription-resource-property.-tf3323382.html#a9348119 Sent from the Muse User mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
