Examples of org.apache.muse.ws.notification.impl.TopicFilter

Package org.apache.muse.ws.notification.impl

Examples of org.apache.muse.ws.notification.impl.TopicFilter

org.apache.muse.ws.notification.impl.TopicFilter
TopicFilter is the implementation of topic-based filters for WS-N subscriptions. All messages that have a wsnt:Topic field that matches the filter's topic will be sent to subscribers. Only simple and concrete topic expressions are supported by this filter. @author Dan Jemiolo (danj)

            EndpointReference epr = new EndpointReference(eprXML);
            
            NotificationProducer wsn = 
                (NotificationProducer)getResource().getCapability(WsnConstants.PRODUCER_URI);
            
            wsn.subscribe(epr, new TopicFilter(MuwsConstants.ADV_ME_CREATION_TOPIC), null, null);
            wsn.subscribe(epr, new TopicFilter(MuwsConstants.ADV_ME_DESTRUCTION_TOPIC), null, null);
        }
    }

View Full Code Here

            EndpointReference epr = new EndpointReference(eprXML);
            
            NotificationProducer wsn = 
                (NotificationProducer)getResource().getCapability(WsnConstants.PRODUCER_URI);
            
            wsn.subscribe(epr, new TopicFilter(MuwsConstants.ADV_ME_CREATION_TOPIC), null, null);
            wsn.subscribe(epr, new TopicFilter(MuwsConstants.ADV_ME_DESTRUCTION_TOPIC), null, null);
        }
    }

View Full Code Here

  private void topicSubscriptionWithoutTerminationTime(EndpointReference producer, EndpointReference consumer) throws SoapFault
  {
    NotificationProducerClient producerClient = new NotificationProducerClient(producer);
        producerClient.setTrace(true);


    TopicFilter filter = new TopicFilter(Names.EVENTS_LIFECYLE_TOPIC_NAME);


        producerClient.subscribe(
            consumer,  // Consumer Endpoint reference
            filter,      // Topic Filter
            null);      // Termination Time : if null the subscription will never expire.

View Full Code Here

  private void topicSubscriptionWithTerminationTime(EndpointReference producer, EndpointReference consumer) throws SoapFault
  {
    NotificationProducerClient producerClient = new NotificationProducerClient(producer);
        producerClient.setTrace(true);


    TopicFilter filter = new TopicFilter(Names.EVENTS_LIFECYLE_TOPIC_NAME);


        producerClient.subscribe(
            consumer,  // Consumer Endpoint reference
            filter,      // Topic Filter
            new Date(System.currentTimeMillis() + 10000));  // Termination Time

View Full Code Here

    NotificationProducerClient producerClient = new NotificationProducerClient(producer);
        producerClient.setTrace(true);


        FilterCollection filter = new FilterCollection();
        
    TopicFilter topicFilter = new TopicFilter(Names.EVENTS_LIFECYLE_TOPIC_NAME);
        MessagePatternFilter messageFilter= new MessagePatternFilter(
            "/wsnt:NotificationMessage/wsnt:Message/qman:LifeCycleEvent/qman:Resource/qman:Name/text()='connection'", // expression (XPath)
            XPathUtils.NAMESPACE_URI); // Dialect : the only supported dialect is XPath 1.0


        ProducerPropertiesFilter producerFilter = new ProducerPropertiesFilter(

View Full Code Here

TOP

Related Classes of org.apache.muse.ws.notification.impl.TopicFilter

org.apache.muse.ws.dm.muws.adv.impl.AbstractAdvertisement

org.apache.qpid.management.example.ConsumerAndProducerExample

javax.xml.namespace.QName

org.w3c.dom.Element

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.