Examples of org.jivesoftware.smack.filter.AndFilter

org.jivesoftware.smack.filter.AndFilter
Implements the logical AND operation over two or more packet filters. In other words, packets pass this filter if they pass all of the filters. @author Matt Tucker

        reg.setTo(connection.getServiceName());
        Map<String, String> attributes = new HashMap<String, String>();
        // To delete an account, we add a single attribute, "remove", that is blank.
        attributes.put("remove", "");
        reg.setAttributes(attributes);
        PacketFilter filter = new AndFilter(new PacketIDFilter(reg.getPacketID()),
                new PacketTypeFilter(IQ.class));
        PacketCollector collector = connection.createPacketCollector(filter);
        connection.sendPacket(reg);
        IQ result = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
        // Stop queuing results

View Full Code Here

     * @throws XMPPException if an error occurs.
     */
    private synchronized void getRegistrationInfo() throws XMPPException {
        Registration reg = new Registration();
        reg.setTo(connection.getServiceName());
        PacketFilter filter = new AndFilter(new PacketIDFilter(reg.getPacketID()),
                new PacketTypeFilter(IQ.class));
        PacketCollector collector = connection.createPacketCollector(filter);
        connection.sendPacket(reg);
        IQ result = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
        // Stop queuing results

View Full Code Here

    public static synchronized Registration getRegistrationInfo(
        String toRegister, Connection connection) throws XMPPException {
        Registration reg = new Registration();
        reg.setTo(connection.getServiceName());
        reg.setFrom(toRegister);
        PacketFilter filter = new AndFilter(new PacketIDFilter(
            reg.getPacketID()), new PacketTypeFilter(IQ.class));
        PacketCollector collector = connection.createPacketCollector(filter);
        connection.sendPacket(reg);
        IQ result = (IQ) collector.nextResult(SmackConfiguration
            .getPacketReplyTimeout());

View Full Code Here

            super(sessionID);
        }


        @Override
        public PacketFilter getFilter() {
            return new AndFilter(super.getFilter(),
                PacketExtensionUtils.getSessionIDPacketFilter(sessionID));
        }

View Full Code Here

            super(sessionID);
        }


        @Override
        public PacketFilter getFilter() {
            return new AndFilter(super.getFilter(),
                PacketExtensionUtils.getSessionIDPacketFilter(sessionID));
        }

View Full Code Here

     *         current session
     */
    public static PacketFilter getSessionIDPacketFilter(
        final SessionIDObservable sessionIDObservable) {


        return new AndFilter(new MessageTypeFilter(Message.Type.chat),
            new PacketFilter() {
                public boolean accept(Packet arg0) {
                    Message message = (Message) arg0;
                    return sessionIDObservable.getValue().equals(
                        getSessionID(message));

View Full Code Here

    public static PacketFilter getIncomingTransferObjectFilter(
        final IncomingTransferObjectExtensionProvider extProv,
        final SessionIDObservable sessionID, final String invitationID,
        final String type) {


        return new AndFilter(extProv.getPacketFilter(), new PacketFilter() {


            public boolean accept(Packet packet) {
                IncomingTransferObject payload = extProv.getPayload(packet);


                if (payload == null) {

View Full Code Here

    }


    public static PacketFilter getIncomingFileListFilter(
        final IncomingTransferObjectExtensionProvider extProv,
        final String sessionID, final String processID, final JID peer) {
        return new AndFilter(extProv.getPacketFilter(), new PacketFilter() {


            public boolean accept(Packet packet) {
                IncomingTransferObject payload = extProv.getPayload(packet);


                if (payload == null) {

View Full Code Here

     */
    public static PacketFilter getInvitationFilter(
        XStreamExtensionProvider<? extends DefaultInvitationInfo> extProv,
        SessionIDObservable sessionID, final String invitationID) {


        return new AndFilter(getSessionIDFilter(extProv, sessionID),
            getInvitationIDFilter(extProv, invitationID));
    }

View Full Code Here

     */
    public static PacketFilter getSessionIDFilter(
        final XStreamExtensionProvider<? extends DefaultSessionInfo> extProv,
        final SessionIDObservable sessionID) {


        return new AndFilter(extProv.getPacketFilter(), new PacketFilter() {
            public boolean accept(Packet packet) {
                DefaultSessionInfo info = extProv.getPayload(packet);


                if (info == null) {
                    log.error("Invalid payload in packet: " + packet);

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.jivesoftware.smack.filter.AndFilter

com.liuyix.xmpp.ConversationManager

com.liuyix.xmpp.Register

com.valhalla.jbother.RegistrationForm$GetRegistrationFormThread

com.valhalla.jbother.RegistrationForm$RegisterThread

com.valhalla.jbother.SearchDialog

de.fu_berlin.inf.dpp.net.business.LeaveHandler$Handler

de.fu_berlin.inf.dpp.net.business.RequestForActivityHandler$Handler

de.fu_berlin.inf.dpp.net.internal.extensions.PacketExtensionUtils

de.fu_berlin.inf.dpp.net.XMPPUtil

JabberClient.MainWindow

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.