Package org.apache.muse.ws.notification

Examples of org.apache.muse.ws.notification.NotificationProducer

73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
        manager.addListener(this);
               
        //
        // initialize the advertisement topics
        //
        NotificationProducer wsn =
            (NotificationProducer)resource.getCapability(WsnConstants.PRODUCER_URI);
       
        wsn.addTopic(MuwsConstants.ADV_ME_CREATION_TOPIC);
        wsn.addTopic(MuwsConstants.ADV_ME_DESTRUCTION_TOPIC);
       
        //
        // create subscriptions for all event consumer that are going to
        // receive notifications from the above topics
        //
View Full Code Here
146
147
148
149
150
151
152
153
       
        Situation situation = factory.createSituation();
        situation.setCategoryType(situationCategory);
        event.setSituation(situation);

        NotificationProducer wsn = (NotificationProducer)advertiser.getCapability(WsnConstants.PRODUCER_URI);
        wsn.publish(topicName, event.toXML());
    }
View Full Code Here
167
168
169
170
171
172
173
174
175
176
177
178
            Document eprDoc = env.getDocument(fileName);
            Element eprXML = XmlUtils.getFirstElement(eprDoc);
           
            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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
        Filter filter = pullPointCap.getFilter();
       
        //
        // create subscription that will send messages to the pullpoint
        //
        NotificationProducer wsn = (NotificationProducer)getResource().getCapability(WsnConstants.PRODUCER_URI);
        WsResource sub = null;
       
        try
        {
            sub = wsn.subscribe(epr, filter, null, null);
        }
       
        catch (BaseFault error)
        {
            throw new UnableToCreatePullPointFault(error);
View Full Code Here
41
42
43
44
45
46
47
48
     * @return An instance of ChangeNotificationListener.
     *
     */
    public PropertyChangeListener newInstance(QName property, WsResource resource)
    {
        NotificationProducer wsn = (NotificationProducer)resource.getCapability(WsnConstants.PRODUCER_URI);
        return new ChangeNotificationListener(property, wsn);
    }
View Full Code Here
45
46
47
48
49
50
51
52
     * @return An instance of ChangeNotificationListener.
     *
     */
    public PropertyChangeListener newInstance(QName property, WsResource resource)
    {
        NotificationProducer wsn = (NotificationProducer)resource.getCapability(WsnConstants.PRODUCER_URI);
        return new ChangeNotificationListener(property, wsn);
    }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
        manager.addListener(this);
               
        //
        // initialize the advertisement topics
        //
        NotificationProducer wsn =
            (NotificationProducer)resource.getCapability(WsnConstants.PRODUCER_URI);
       
        wsn.addTopic(MuwsConstants.ADV_ME_CREATION_TOPIC);
        wsn.addTopic(MuwsConstants.ADV_ME_DESTRUCTION_TOPIC);
       
        //
        // create subscriptions for all event consumer that are going to
        // receive notifications from the above topics
        //
View Full Code Here
150
151
152
153
154
155
156
157
       
        Situation situation = factory.createSituation();
        situation.setCategoryType(situationCategory);
        event.setSituation(situation);

        NotificationProducer wsn = (NotificationProducer)advertiser.getCapability(WsnConstants.PRODUCER_URI);
        wsn.publish(topicName, event.toXML());
    }
View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
182
            Document eprDoc = env.getDocument(fileName);
            Element eprXML = XmlUtils.getFirstElement(eprDoc);
           
            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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
        Filter filter = pullPointCap.getFilter();
       
        //
        // create subscription that will send messages to the pullpoint
        //
        NotificationProducer wsn = (NotificationProducer)getResource().getCapability(WsnConstants.PRODUCER_URI);
        WsResource sub = null;
       
        try
        {
            sub = wsn.subscribe(epr, filter, null, null);
        }
       
        catch (BaseFault error)
        {
            throw new UnableToCreatePullPointFault(error);
View Full Code Here
TOP

Related Classes of org.apache.muse.ws.notification.NotificationProducer

  • org.apache.muse.ws.dm.muws.adv.impl.AbstractAdvertisement
  • org.apache.muse.ws.notification.impl.SimplePullPointCreation
  • org.apache.muse.ws.notification.properties.WsrpNotificationListenerFactory
  • org.apache.ws.muse.test.wsrf.MyCapabilityImpl
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.