Examples of Notify

RemoveEventsWithAnchoredObjects.Notify
Notify

@author Generated from Forte @since 19-Nov-2008
com.sonymobile.tools.gerrit.gerritevents.dto.rest.Notify
org.activemq.ws.xmlbeans.notification.base.NotifyDocument.Notify
org.apache.niolex.notify.Notify
The core class of this notify framework. Watch the changes of node data and node properties. User can also change node data and node properties.
Users can use this class as:
```
 1. Global configuration center. 2. Message middle-ware. 3. Signal dispatcher. etc... 
```
@author Xie, Jiyun @version 1.0.5 @since 2012-12-27
org.oasis_open.docs.wsn.b_2.Notify
Applet for playing sounds via javascript. The applet is configured with a list of sounds to play, each of which may be played from javascript using play("sound"); If no "soundn" parameter is supplied, then "sound.au" is assumed. ...
org.red5.server.net.rtmp.event.Notify
Stream notification event. The invoke / transaction id is "always" equal to zero for a Notify.
org.servicemix.ws.xmlbeans.notification.base.NotifyDocument.Notify
reactor.core.dynamic.annotation.Notify

Examples of org.oasis_open.docs.wsn.b_2.Notify

    public void notify(String topic, Object msg) {
        notify(null, topic, msg);
    }


    public void notify(Referencable publisher, String topic, Object msg) {
        Notify notify = new Notify();
        NotificationMessageHolderType holder = new NotificationMessageHolderType();
        if (publisher != null) {
            holder.setProducerReference(publisher.getEpr());
        }
        if (topic != null) {
            TopicExpressionType topicExp = new TopicExpressionType();
            topicExp.getContent().add(topic);
            holder.setTopic(topicExp);
        }
        holder.setMessage(new NotificationMessageHolderType.Message());
        holder.getMessage().setAny(msg);
        notify.getNotificationMessage().add(holder);
        broker.notify(notify);
    }

View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.Notify

        // START SNIPPET: sub
        PullPoint pullPoint = wsnCreatePullPoint.createPullPoint();
        Subscription subscription = wsnBroker.subscribe(pullPoint.getEndpoint(), "myTopic", null);
        // END SNIPPET: sub


        wsnBroker.notify("myTopic", new Notify());
        // Wait for notification
        Thread.sleep(150);


        assertEquals(1, pullPoint.getMessages(0).size());


        subscription.unsubscribe();


        wsnBroker.notify("myTopic", new Notify());
        // Wait for notification
        Thread.sleep(150);


        assertEquals(0, pullPoint.getMessages(0).size());

View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.Notify


    public void testPauseResume() throws Exception {
        PullPoint pullPoint = wsnCreatePullPoint.createPullPoint();
        Subscription subscription = wsnBroker.subscribe(pullPoint.getEndpoint(), "myTopic", null);


        wsnBroker.notify("myTopic", new Notify());
        // Wait for notification
        Thread.sleep(150);


        assertEquals(1, pullPoint.getMessages(0).size());


        subscription.pause();


        wsnBroker.notify("myTopic", new Notify());
        // Wait for notification
        Thread.sleep(150);


        assertEquals(0, pullPoint.getMessages(0).size());


        subscription.resume();


        wsnBroker.notify("myTopic", new Notify());
        // Wait for notification
        Thread.sleep(150);


        assertEquals(1, pullPoint.getMessages(0).size());

View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.Notify


    public void testPull() throws Exception {
        PullPoint pullPoint = wsnCreatePullPoint.createPullPoint();
        wsnBroker.subscribe(pullPoint.getEndpoint(), "myTopic", null);


        wsnBroker.notify("myTopic", new Notify());
        // Wait for notification
        Thread.sleep(150);


        List<NotificationMessageHolderType> msgs = pullPoint.getMessages(0);
        assertNotNull(msgs);

View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.Notify


  @Override
  protected synchronized void store(NotificationMessageHolderType messageHolder) {
    try {
      initSession();
            Notify notify = new Notify();
            notify.getNotificationMessage().add(messageHolder);
            StringWriter writer = new StringWriter();
            jaxbContext.createMarshaller().marshal(notify, writer);
            Message message = session.createTextMessage(writer.toString());
            producer.send(message);
    } catch (JMSException e) {

View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.Notify

        if (msg == null) {
          break;
        }
        TextMessage txtMsg = (TextMessage) msg;
        StringReader reader = new StringReader(txtMsg.getText());
        Notify notify = (Notify) jaxbContext.createUnmarshaller().unmarshal(reader);
        messages.addAll(notify.getNotificationMessage());
      }
      return messages;
    } catch (JMSException e) {
      log.info("Error retrieving messages", e);
      if (session != null) {

View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.Notify

    Session session = null;
    try {
            Topic topic = topicConverter.toActiveMQTopic(messageHolder.getTopic());
      session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageProducer producer = session.createProducer(topic);
            Notify notify = new Notify();
            notify.getNotificationMessage().add(messageHolder);
            StringWriter writer = new StringWriter();
            jaxbContext.createMarshaller().marshal(notify, writer);
            Message message = session.createTextMessage(writer.toString());
            producer.send(message);
    } catch (JMSException e) {

View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.Notify

    setEndpoint(createWSA(WSN_URI + "/" + WSN_SERVICE + "/" + brokerName));
    setResolver(resolveWSA(getEndpoint()));
  }


  public void notify(String topic, Object msg) throws JBIException {
    Notify notify = new Notify();
    NotificationMessageHolderType holder = new NotificationMessageHolderType();
    if (topic != null) {
      TopicExpressionType topicExp = new TopicExpressionType();
      topicExp.getContent().add(topic);
      holder.setTopic(topicExp);
    }
    holder.setMessage(new NotificationMessageHolderType.Message());
    holder.getMessage().setAny(msg);
    notify.getNotificationMessage().add(holder);
    send(notify);
  }

View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.Notify

            } catch (JAXBException e) {
                //ignore, we'll try and let the runtime handle it as is
            }
        }
        
        Notify notify = new Notify();
        NotificationMessageHolderType holder = new NotificationMessageHolderType();
        if (publisher != null) {
            holder.setProducerReference(publisher.getEpr());
        }
        if (topic != null) {
            TopicExpressionType topicExp = new TopicExpressionType();
            topicExp.getContent().add(topic);
            holder.setTopic(topicExp);
        }
        holder.setMessage(new NotificationMessageHolderType.Message());
        holder.getMessage().setAny(msg);
        notify.getNotificationMessage().add(holder);
        getBroker().notify(notify);
    }

View Full Code Here

Examples of org.red5.server.net.rtmp.event.Notify

  
  protected void onCommand(RTMPConnection conn, Channel channel, Header source, ICommand command) {
    if (!(command instanceof Notify)) {
      return;
    }
    Notify invoke = (Notify)command;
    if (invoke.getType() == IEvent.Type.STREAM_DATA) {
      return;
    }
    
    String method = invoke.getCall().getServiceMethodName();
    if ("stopStream".equals(method)) {
      stopStream();
    } else if ("sendRemoteCursorEvent".equals(method)) {
      sendRemoteCursorEvent(invoke.getCall().getArguments()[0]);
    } else if ("screenSharerAction".equals(method)) {
      Object[] args = invoke.getCall().getArguments();
      if (args != null && args.length > 0) {
        @SuppressWarnings("unchecked")
        Map<String, Object> params = (Map<String, Object>)args[0];
        if (bool(params.get("stopPublishing"))) {
          stopPublishing();

View Full Code Here

0 1 2 3 4 5

TOP

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.