Examples of Notify

Examples of org.servicemix.ws.xmlbeans.notification.base.NotifyDocument.Notify

119
120
121
122
123
124
125
126
127
128
129
130
        return responseDoc;
    }

    public void notify(NotifyDocument requestDoc) {
        try {
            Notify notify = requestDoc.getNotify();
            NotificationMessageHolderType[] messageHolders = notify.getNotificationMessageArray();
            for (int i = 0; i < messageHolders.length; i++) {
                NotificationMessageHolderType messageHolder = messageHolders[i];
                Topic topic = TopicExpressionConverter.toActiveMQTopic(messageHolder.getTopic());
                EndpointReferenceType producerReference = messageHolder.getProducerReference();
                ActiveMQPublisherRegistration publisher = getPublisher(producerReference);
View Full Code Here

Examples of org.servicemix.ws.xmlbeans.notification.base.NotifyDocument.Notify

68
69
70
71
72
73
74
75
76
77
78
79
        Session session = connection.createSession(false, 0);
        ActiveMQTopic topic = new ActiveMQTopic("Test");
        MessageConsumer consumer = session.createConsumer(topic);
       
        NotifyDocument request = NotifyDocument.Factory.newInstance();
        Notify notify = request.addNewNotify();
        NotificationMessageHolderType messageHolder = notify.addNewNotificationMessage();
        messageHolder.setTopic( TopicExpressionConverter.toTopicExpression(topic) );
        XmlObject o = createMessage();
        messageHolder.setMessage(o);
       
        System.out.println(request);
View Full Code Here

Examples of org.servicemix.ws.xmlbeans.notification.base.NotifyDocument.Notify

57
58
59
60
61
62
63
64
65
66
67
68
        }
    }

    private void dispatch(TopicExpressionType topic, XmlObject xml) {
        NotifyDocument request = NotifyDocument.Factory.newInstance();
        Notify notify = request.addNewNotify();
        NotificationMessageHolderType messageHolder = notify.addNewNotificationMessage();

        EndpointReferenceType producerReference = getProducerReference();
        if (producerReference != null) {
            messageHolder.setProducerReference((EndpointReferenceType) producerReference.copy());
        }
View Full Code Here

Examples of reactor.core.dynamic.annotation.Notify

38
39
40
41
42
43
44
45
46
47
48
49
50
51
  }

  @Override
  public String apply(Method method) {
    String key;
    Notify notifyAnno = AnnotationUtils.find(method, Notify.class);

    if (null != notifyAnno) {
      key = notifyAnno.value();
    } else {
      key = methodNameToNotificationKey(method.getName());
    }

    return key;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.