Examples of DiscoverItems


Examples of org.jivesoftware.smackx.packet.DiscoverItems

     * @throws XMPPException If the user is not allowed to make this request or the server does
     *                       not support offline message retrieval.
     */
    public Iterator<OfflineMessageHeader> getHeaders() throws XMPPException {
        List<OfflineMessageHeader> answer = new ArrayList<OfflineMessageHeader>();
        DiscoverItems items = ServiceDiscoveryManager.getInstanceFor(connection).discoverItems(
                null, namespace);
        for (Iterator it = items.getItems(); it.hasNext();) {
            DiscoverItems.Item item = (DiscoverItems.Item) it.next();
            answer.add(new OfflineMessageHeader(item));
        }
        return answer.iterator();
    }
View Full Code Here

Examples of org.jivesoftware.smackx.packet.DiscoverItems

        ServiceDiscoveryManager serviceDiscoveryManager = ServiceDiscoveryManager.getInstanceFor(this.connection);

        List<String> proxies = new ArrayList<String>();

        // get all items form XMPP server
        DiscoverItems discoverItems = serviceDiscoveryManager.discoverItems(this.connection.getServiceName());
        Iterator<Item> itemIterator = discoverItems.getItems();

        // query all items if they are SOCKS5 proxies
        while (itemIterator.hasNext()) {
            Item item = itemIterator.next();
View Full Code Here

Examples of org.jivesoftware.smackx.packet.DiscoverItems

     */
    public static Iterator<String> getJoinedRooms(Connection connection, String user) {
        try {
            ArrayList<String> answer = new ArrayList<String>();
            // Send the disco packet to the user
            DiscoverItems result =
                ServiceDiscoveryManager.getInstanceFor(connection).discoverItems(user, discoNode);
            // Collect the entityID for each returned item
            for (Iterator<DiscoverItems.Item> items=result.getItems(); items.hasNext();) {
                answer.add(items.next().getEntityID());
            }
            return answer.iterator();
        }
        catch (XMPPException e) {
View Full Code Here

Examples of org.jivesoftware.smackx.packet.DiscoverItems

     * @throws XMPPException if an error occured while trying to discover MUC services.
     */
    public static Collection<String> getServiceNames(Connection connection) throws XMPPException {
        final List<String> answer = new ArrayList<String>();
        ServiceDiscoveryManager discoManager = ServiceDiscoveryManager.getInstanceFor(connection);
        DiscoverItems items = discoManager.discoverItems(connection.getServiceName());
        for (Iterator<DiscoverItems.Item> it = items.getItems(); it.hasNext();) {
            DiscoverItems.Item item = it.next();
            try {
                DiscoverInfo info = discoManager.discoverInfo(item.getEntityID());
                if (info.containsFeature("http://jabber.org/protocol/muc")) {
                    answer.add(item.getEntityID());
View Full Code Here

Examples of org.jivesoftware.smackx.packet.DiscoverItems

     */
    public static Collection<HostedRoom> getHostedRooms(Connection connection, String serviceName)
            throws XMPPException {
        List<HostedRoom> answer = new ArrayList<HostedRoom>();
        ServiceDiscoveryManager discoManager = ServiceDiscoveryManager.getInstanceFor(connection);
        DiscoverItems items = discoManager.discoverItems(serviceName);
        for (Iterator<DiscoverItems.Item> it = items.getItems(); it.hasNext();) {
            answer.add(new HostedRoom(it.next()));
        }
        return answer;
    }
View Full Code Here

Examples of org.jivesoftware.smackx.packet.DiscoverItems

   * @throws XMPPException
   */
  public DiscoverItems discoverItems()
    throws XMPPException
  {
    DiscoverItems items = new DiscoverItems();
    items.setTo(to);
    items.setNode(getId());
    return (DiscoverItems)SyncPacketSend.getReply(con, items);
  }
View Full Code Here

Examples of org.jivesoftware.smackx.packet.DiscoverItems

        LOGGER.debug("Service listing");

        ServiceDiscoveryManager disco = ServiceDiscoveryManager
                .getInstanceFor(connection);
        try {
            DiscoverItems items = disco.discoverItems(connection.getServiceName());

            Iterator iter = items.getItems();
            while (iter.hasNext()) {
                DiscoverItems.Item item = (DiscoverItems.Item) iter.next();
                DiscoverInfo info = disco.discoverInfo(item.getEntityID());

                Iterator<DiscoverInfo.Identity> iter2 = info.getIdentities();
View Full Code Here

Examples of org.jivesoftware.smackx.packet.DiscoverItems

    LeafNode myNode = getRandomPubnode(getManager(), true, false);
    myNode.send(new Item());
    myNode.send(new Item());
    myNode.send(new Item());
    myNode.send(new Item());
    DiscoverItems items = myNode.discoverItems();
   
    int count = 0;
   
    for(Iterator it = items.getItems(); it.hasNext(); it.next(),count++);
   
    assertEquals(4, count);
  }
View Full Code Here

Examples of org.jivesoftware.smackx.packet.DiscoverItems

   * @throws XMPPException
   */
  public DiscoverItems discoverNodes(String nodeId)
    throws XMPPException
  {
    DiscoverItems items = new DiscoverItems();
   
    if (nodeId != null)
      items.setNode(nodeId);
    items.setTo(to);
    DiscoverItems nodeItems = (DiscoverItems)SyncPacketSend.getReply(con, items);
    return nodeItems;
  }
View Full Code Here

Examples of org.jivesoftware.smackx.packet.DiscoverItems

     * @throws XMPPException If the user is not allowed to make this request or the server does
     *                       not support offline message retrieval.
     */
    public Iterator<OfflineMessageHeader> getHeaders() throws XMPPException {
        List<OfflineMessageHeader> answer = new ArrayList<OfflineMessageHeader>();
        DiscoverItems items = ServiceDiscoveryManager.getInstanceFor(connection).discoverItems(
                null, namespace);
        for (Iterator it = items.getItems(); it.hasNext();) {
            DiscoverItems.Item item = (DiscoverItems.Item) it.next();
            answer.add(new OfflineMessageHeader(item));
        }
        return answer.iterator();
    }
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.