import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
/**
 * Returns the room's configuration form that the room's owner can use or <tt>null</tt> if
 * no configuration is possible. The configuration form allows to set the room's language,
 * enable logging, specify room's type, etc..
 *
 * @return the Form that contains the fields to complete together with the instrucions or
 * <tt>null</tt> if no configuration is possible.
 * @throws XMPPException if an error occurs asking the configuration form for the room.
 */
public Form getConfigurationForm() throws XMPPException {
    MUCOwner iq = new MUCOwner();
    iq.setTo(room);
    iq.setType(IQ.Type.GET);

    // Filter packets looking for an answer from the server.
    PacketFilter responseFilter = new PacketIDFilter(iq.getPacketID());
    PacketCollector response = connection.createPacketCollector(responseFilter);
    // Request the configuration form to the server.
    connection.sendPacket(iq);
    // Wait up to a certain number of seconds for a reply.
    IQ answer = (IQ) response.nextResult(SmackConfiguration.getPacketReplyTimeout());
    // Stop queuing results
    response.cancel();

    if (answer == null) {
        throw new XMPPException("No response from server.");
    }
    else if (answer.getError() != null) {
        throw new XMPPException(answer.getError());
    }
    return Form.getFormFrom(answer);
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
/**
 * Sends the completed configuration form to the server. The room will be configured
 * with the new settings defined in the form. If the form is empty then the server
 * will create an instant room (will use default configuration).
 *
 * @param form the form with the new settings.
 * @throws XMPPException if an error occurs setting the new rooms' configuration.
 */
public void sendConfigurationForm(Form form) throws XMPPException {
    MUCOwner iq = new MUCOwner();
    iq.setTo(room);
    iq.setType(IQ.Type.SET);
    iq.addExtension(form.getDataFormToSend());

    // Filter packets looking for an answer from the server.
    PacketFilter responseFilter = new PacketIDFilter(iq.getPacketID());
    PacketCollector response = connection.createPacketCollector(responseFilter);
    // Send the completed configuration form to the server.
    connection.sendPacket(iq);
    // Wait up to a certain number of seconds for a reply.
    IQ answer = (IQ) response.nextResult(SmackConfiguration.getPacketReplyTimeout());
    // Stop queuing results
    response.cancel();

    if (answer == null) {
        throw new XMPPException("No response from server.");
    }
    else if (answer.getError() != null) {
        throw new XMPPException(answer.getError());
    }
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
private void changeAffiliationByOwner(String jid, String affiliation) throws XMPPException {
    MUCOwner iq = new MUCOwner();
    iq.setTo(room);
    iq.setType(IQ.Type.SET);
    // Set the new affiliation.
    MUCOwner.Item item = new MUCOwner.Item(affiliation);
    item.setJid(jid);
    iq.addItem(item);

    // Wait for a response packet back from the server.
    PacketFilter responseFilter = new PacketIDFilter(iq.getPacketID());
    PacketCollector response = connection.createPacketCollector(responseFilter);
    // Send the change request to the server.
    connection.sendPacket(iq);
    // Wait up to a certain number of seconds for a reply.
    IQ answer = (IQ) response.nextResult(SmackConfiguration.getPacketReplyTimeout());
    // Stop queuing results
    response.cancel();

    if (answer == null) {
        throw new XMPPException("No response from server.");
    }
    else if (answer.getError() != null) {
        throw new XMPPException(answer.getError());
    }
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
private MUCOwner.Item parseItem(XmlPullParser parser) throws Exception {
    boolean done = false;
    MUCOwner.Item item = new MUCOwner.Item(parser.getAttributeValue("", "affiliation"));
    item.setNick(parser.getAttributeValue("", "nick"));
    item.setRole(parser.getAttributeValue("", "role"));
    item.setJid(parser.getAttributeValue("", "jid"));
    while (!done) {
        int eventType = parser.next();
        if (eventType == XmlPullParser.START_TAG) {
            if (parser.getName().equals("actor")) {
                item.setActor(parser.getAttributeValue("", "jid"));
            }
            if (parser.getName().equals("reason")) {
                item.setReason(parser.nextText());
            }
        }
        else if (eventType == XmlPullParser.END_TAG) {
            if (parser.getName().equals("item")) {
                done = true;
            }
        }
    }
    return item;
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
private MUCOwner.Destroy parseDestroy(XmlPullParser parser) throws Exception {
    boolean done = false;
    MUCOwner.Destroy destroy = new MUCOwner.Destroy();
    destroy.setJid(parser.getAttributeValue("", "jid"));
    while (!done) {
        int eventType = parser.next();
        if (eventType == XmlPullParser.START_TAG) {
            if (parser.getName().equals("reason")) {
                destroy.setReason(parser.nextText());
            }
        }
        else if (eventType == XmlPullParser.END_TAG) {
            if (parser.getName().equals("destroy")) {
                done = true;
            }
        }
    }
    return destroy;
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
/**
 * Returns the room's configuration form that the room's owner can use or
 * <tt>null</tt> if no configuration is possible. The configuration form
 * allows to set the room's language, enable logging, specify room's type,
 * etc..
 * 
 * @return the Form that contains the fields to complete together with the
 *         instrucions or <tt>null</tt> if no configuration is possible.
 * @throws XMPPException
 *             if an error occurs asking the configuration form for the
 *             room.
 */
public Form getConfigurationForm() throws XMPPException {
	MUCOwner iq = new MUCOwner();
	iq.setTo(room);
	iq.setType(IQ.Type.GET);

	// Filter packets looking for an answer from the server.
	PacketFilter responseFilter = new PacketIDFilter(iq.getPacketID());
	PacketCollector response = connection
			.createPacketCollector(responseFilter);
	// Request the configuration form to the server.
	connection.sendPacket(iq);
	// Wait up to a certain number of seconds for a reply.
	IQ answer = (IQ) response.nextResult(SmackConfiguration
			.getPacketReplyTimeout());
	// Stop queuing results
	response.cancel();

	if (answer == null) {
		throw new XMPPException("No response from server.");
	} else if (answer.getError() != null) {
		throw new XMPPException(answer.getError());
	}
	return Form.getFormFrom(answer);
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
/**
 * Sends the completed configuration form to the server. The room will be
 * configured with the new settings defined in the form. If the form is
 * empty then the server will create an instant room (will use default
 * configuration).
 * 
 * @param form
 *            the form with the new settings.
 * @throws XMPPException
 *             if an error occurs setting the new rooms' configuration.
 */
public void sendConfigurationForm(Form form) throws XMPPException {
	MUCOwner iq = new MUCOwner();
	iq.setTo(room);
	iq.setType(IQ.Type.SET);
	iq.addExtension(form.getDataFormToSend());

	// Filter packets looking for an answer from the server.
	PacketFilter responseFilter = new PacketIDFilter(iq.getPacketID());
	PacketCollector response = connection
			.createPacketCollector(responseFilter);
	// Send the completed configuration form to the server.
	connection.sendPacket(iq);
	// Wait up to a certain number of seconds for a reply.
	IQ answer = (IQ) response.nextResult(SmackConfiguration
			.getPacketReplyTimeout());
	// Stop queuing results
	response.cancel();

	if (answer == null) {
		throw new XMPPException("No response from server.");
	} else if (answer.getError() != null) {
		throw new XMPPException(answer.getError());
	}
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
public IQ parseIQ(XmlPullParser parser) throws Exception {
	MUCOwner mucOwner = new MUCOwner();
	boolean done = false;
	while (!done) {
		int eventType = parser.next();
		if (eventType == XmlPullParser.START_TAG) {
			if (parser.getName().equals("item")) {
				mucOwner.addItem(parseItem(parser));
			} else if (parser.getName().equals("destroy")) {
				mucOwner.setDestroy(parseDestroy(parser));
			}
			// Otherwise, it must be a packet extension.
			else {
				mucOwner.addExtension(PacketParserUtils
						.parsePacketExtension(parser.getName(),
								parser.getNamespace(), parser));
			}
		} else if (eventType == XmlPullParser.END_TAG) {
			if (parser.getName().equals("query")) {
				done = true;
			}
		}
	}

	return mucOwner;
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
private MUCOwner.Item parseItem(XmlPullParser parser) throws Exception {
	boolean done = false;
	MUCOwner.Item item = new MUCOwner.Item(parser.getAttributeValue("",
			"affiliation"));
	item.setNick(parser.getAttributeValue("", "nick"));
	item.setRole(parser.getAttributeValue("", "role"));
	item.setJid(parser.getAttributeValue("", "jid"));
	while (!done) {
		int eventType = parser.next();
		if (eventType == XmlPullParser.START_TAG) {
			if (parser.getName().equals("actor")) {
				item.setActor(parser.getAttributeValue("", "jid"));
			}
			if (parser.getName().equals("reason")) {
				item.setReason(parser.nextText());
			}
		} else if (eventType == XmlPullParser.END_TAG) {
			if (parser.getName().equals("item")) {
				done = true;
			}
		}
	}
	return item;
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
private MUCOwner.Destroy parseDestroy(XmlPullParser parser)
		throws Exception {
	boolean done = false;
	MUCOwner.Destroy destroy = new MUCOwner.Destroy();
	destroy.setJid(parser.getAttributeValue("", "jid"));
	while (!done) {
		int eventType = parser.next();
		if (eventType == XmlPullParser.START_TAG) {
			if (parser.getName().equals("reason")) {
				destroy.setReason(parser.nextText());
			}
		} else if (eventType == XmlPullParser.END_TAG) {
			if (parser.getName().equals("destroy")) {
				done = true;
			}
		}
	}
	return destroy;
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
/**
 * Returns a collection of <code>Affiliate</code> that have the specified room affiliation
 * sending a request in the owner namespace.
 *
 * @param affiliation the affiliation of the users in the room.
 * @return a collection of <code>Affiliate</code> that have the specified room affiliation.
 * @throws XMPPException if an error occured while performing the request to the server or you
 *         don't have enough privileges to get this information.
 */
private Collection<Affiliate> getAffiliatesByOwner(String affiliation) throws XMPPException {
    MUCOwner iq = new MUCOwner();
    iq.setTo(room);
    iq.setType(IQ.Type.GET);
    // Set the specified affiliation. This may request the list of owners/admins/members/outcasts.
    MUCOwner.Item item = new MUCOwner.Item(affiliation);
    iq.addItem(item);

    // Wait for a response packet back from the server.
    PacketFilter responseFilter = new PacketIDFilter(iq.getPacketID());
    PacketCollector response = connection.createPacketCollector(responseFilter);
    // Send the request to the server.
    connection.sendPacket(iq);
    // Wait up to a certain number of seconds for a reply.
    MUCOwner answer = (MUCOwner) response.nextResult(SmackConfiguration.getPacketReplyTimeout());
    // Stop queuing results
    response.cancel();

    if (answer == null) {
        throw new XMPPException("No response from server.");
    }
    else if (answer.getError() != null) {
        throw new XMPPException(answer.getError());
    }
    // Get the list of affiliates from the server's answer
    List<Affiliate> affiliates = new ArrayList<Affiliate>();
    for (Iterator it = answer.getItems(); it.hasNext();) {
        affiliates.add(new Affiliate((MUCOwner.Item) it.next()));
    }
    return affiliates;
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
Affiliate(MUCOwner.Item item) {
    super();
    this.jid = item.getJid();
    this.affiliation = item.getAffiliation();
    this.role = item.getRole();
    this.nick = item.getNick();
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
public IQ parseIQ(XmlPullParser parser) throws Exception {
    MUCOwner mucOwner = new MUCOwner();
    boolean done = false;
    while (!done) {
        int eventType = parser.next();
        if (eventType == XmlPullParser.START_TAG) {
            if (parser.getName().equals("item")) {
                mucOwner.addItem(parseItem(parser));
            }
            else if (parser.getName().equals("destroy")) {
                mucOwner.setDestroy(parseDestroy(parser));
            }
            // Otherwise, it must be a packet extension.
            else {
                mucOwner.addExtension(PacketParserUtils.parsePacketExtension(parser.getName(),
                        parser.getNamespace(), parser));
            }
        }
        else if (eventType == XmlPullParser.END_TAG) {
            if (parser.getName().equals("query")) {
                done = true;
            }
        }
    }

    return mucOwner;
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
/**
 * Returns a collection of <code>Affiliate</code> that have the specified room affiliation
 * sending a request in the owner namespace.
 *
 * @param affiliation the affiliation of the users in the room.
 * @return a collection of <code>Affiliate</code> that have the specified room affiliation.
 * @throws XMPPException if an error occured while performing the request to the server or you
 *         don't have enough privileges to get this information.
 */
private Collection<Affiliate> getAffiliatesByOwner(String affiliation) throws XMPPException {
    MUCOwner iq = new MUCOwner();
    iq.setTo(room);
    iq.setType(IQ.Type.GET);
    // Set the specified affiliation. This may request the list of owners/admins/members/outcasts.
    MUCOwner.Item item = new MUCOwner.Item(affiliation);
    iq.addItem(item);

    // Wait for a response packet back from the server.
    PacketFilter responseFilter = new PacketIDFilter(iq.getPacketID());
    PacketCollector response = connection.createPacketCollector(responseFilter);
    // Send the request to the server.
    connection.sendPacket(iq);
    // Wait up to a certain number of seconds for a reply.
    MUCOwner answer = (MUCOwner) response.nextResult(SmackConfiguration.getPacketReplyTimeout());
    // Stop queuing results
    response.cancel();

    if (answer == null) {
        throw new XMPPException("No response from server.");
    }
    else if (answer.getError() != null) {
        throw new XMPPException(answer.getError());
    }
    // Get the list of affiliates from the server's answer
    List<Affiliate> affiliates = new ArrayList<Affiliate>();
    for (Iterator<MUCOwner.Item> it = answer.getItems(); it.hasNext();) {
        affiliates.add(new Affiliate(it.next()));
    }
    return affiliates;
}
 

import org.jivesoftware.smackx.packet.MUCOwner; //导入依赖的package包/类
private void changeAffiliationByOwner(String jid, String affiliation)
		throws XMPPException {
	MUCOwner iq = new MUCOwner();
	iq.setTo(room);
	iq.setType(IQ.Type.SET);
	// Set the new affiliation.
	MUCOwner.Item item = new MUCOwner.Item(affiliation);
	item.setJid(jid);
	iq.addItem(item);

	// Wait for a response packet back from the server.
	PacketFilter responseFilter = new PacketIDFilter(iq.getPacketID());
	PacketCollector response = connection
			.createPacketCollector(responseFilter);
	// Send the change request to the server.
	connection.sendPacket(iq);
	// Wait up to a certain number of seconds for a reply.
	IQ answer = (IQ) response.nextResult(SmackConfiguration
			.getPacketReplyTimeout());
	// Stop queuing results
	response.cancel();

	if (answer == null) {
		throw new XMPPException("No response from server.");
	} else if (answer.getError() != null) {
		throw new XMPPException(answer.getError());
	}
}