Examples of org.xmpp.packet.Message.addChildElement()

org.xmpp.packet.Message.addChildElement()
abber.org/jeps">Jabber Enhancement Proposals (JEPs). @param name the element name. @param namespace the element namespace. @return the newly created child element.

        if (isNotifiedOfRetract()) {
            // Broadcast notification deletion to subscribers
            // Build packet to broadcast to subscribers
            Message message = new Message();
            Element event =
                    message.addChildElement("event", "http://jabber.org/protocol/pubsub#event");
            // Send notification that items have been deleted to subscribers and parent node
            // subscribers
            Set<NodeAffiliate> affiliatesToNotify = new HashSet<NodeAffiliate>(affiliates);
            // Get affiliates that are subscribed to a parent in the hierarchy of parent nodes
            for (CollectionNode parentNode : getParents()) {

View Full Code Here

                service.queueItemToRemove(item);
            }
            // Broadcast purge notification to subscribers
            // Build packet to broadcast to subscribers
            Message message = new Message();
            Element event = message.addChildElement("event", "http://jabber.org/protocol/pubsub#event");
            Element items = event.addElement("purge");
            items.addAttribute("node", nodeID);
            // Send notification that the node configuration has changed
            broadcastNodeEvent(message, false);
        }

View Full Code Here

        Message message = new Message();
        message.setError(PacketError.Condition.recipient_unavailable);
        message.setTo(inviter);
        message.setFrom(workgroup.getJID());
        message.setBody(body);
        Element element = message.addChildElement("invite", "http://jabber.org/protocol/workgroup");
        element.addAttribute("type", type.toString());
        Element sessionElement = element.addElement("session", "http://jivesoftware.com/protocol/workgroup");
        sessionElement.addAttribute("id", sessionID);
        element.addElement("inviter").setText(inviter.toString());
        element.addElement("invitee").setText(invitee.toString());

View Full Code Here

        Message message = new Message();
        message.setError(PacketError.Condition.recipient_unavailable);
        message.setTo(inviter);
        message.setFrom(workgroup.getJID());
        message.setBody(body);
        Element element = message.addChildElement("transfer", "http://jabber.org/protocol/workgroup");
        element.addAttribute("type", type.toString());
        Element sessionElement = element.addElement("session", "http://jivesoftware.com/protocol/workgroup");
        sessionElement.addAttribute("id", sessionID);
        element.addElement("inviter").setText(inviter.toString());
        element.addElement("invitee").setText(invitee.toString());

View Full Code Here

  }


  public void updateProgress(JID user, long pBytesRead, long pContentLength, String requestId) {
    Message message = new Message();
    message.setTo(user);
    Element payload = message.addChildElement("upload", "http://onesocialweb.org/spec/1.0/upload");
    payload.addElement("request-id").setText(requestId);
    payload.addElement("status").setText("progress");
    payload.addElement("bytes-read").setText(Long.toString(pBytesRead));
    payload.addElement("size").setText(Long.toString(pContentLength));
    XMPPServer.getInstance().getMessageRouter().route(message);

View Full Code Here

    em.getTransaction().commit();
    em.close();
    
    Message message = new Message();
    message.setTo(user);
    Element payload = message.addChildElement("upload", "http://onesocialweb.org/spec/1.0/upload");
    payload.addElement("request-id").setText(requestId);
    payload.addElement("status").setText("completed");
    payload.addElement("file-id").setText(file.getName());
    payload.addElement("size").setText(Long.toString(entry.getSize()));
    payload.addElement("mime-type").setText(entry.getType());

View Full Code Here


    final Message message = new Message();
    message.setFrom(fromJID);
    message.setBody("New activity: " + entry.getTitle());
    message.setType(Message.Type.headline);
    org.dom4j.Element eventElement = message.addChildElement("event", "http://jabber.org/protocol/pubsub#event");
    org.dom4j.Element itemsElement = eventElement.addElement("items");
    itemsElement.addAttribute("node", PEPActivityHandler.NODE);
    org.dom4j.Element itemElement = itemsElement.addElement("item");
    itemElement.addAttribute("id", entry.getId());
    itemElement.add((org.dom4j.Element) entryElement);

View Full Code Here

    final Message message = new Message();
    message.setFrom(fromJID);
    message.setBody("Delete activity: " + activityId);
    message.setType(Message.Type.headline);
    
    org.dom4j.Element eventElement = message.addChildElement("event", "http://jabber.org/protocol/pubsub#event");
    org.dom4j.Element itemsElement = eventElement.addElement("items");
    itemsElement.addAttribute("node", PEPActivityHandler.NODE);
    org.dom4j.Element retractElement = itemsElement.addElement("retract");
    retractElement.addAttribute("id", activityId);

View Full Code Here

    domDocument.removeChild(entryElement);


    final Message message = new Message();
    message.setFrom(localJID);
    message.setType(Message.Type.headline);
    org.dom4j.Element eventElement = message.addChildElement("event", "http://jabber.org/protocol/pubsub#event");
    org.dom4j.Element itemsElement = eventElement.addElement("items");
    itemsElement.addAttribute("node", NODE);
    org.dom4j.Element itemElement = itemsElement.addElement("item");
    itemElement.addAttribute("id", relation.getId());
    itemElement.add((org.dom4j.Element) entryElement);

View Full Code Here

    final Runnable countDown = new Runnable() {
      @Override
      public void run() {
        if (callbackCount.decrementAndGet() == 0 && receiptRequested != null) {
          Message response = XmppUtil.createResponseMessage(updateMessage);
          response.addChildElement("received", XmppNamespace.NAMESPACE_XMPP_RECEIPTS);
          responseCallback.run(response);
        }
      }
    };

View Full Code Here

0 1 2 3

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.