import org.jivesoftware.openfire.multiplex.Route; //导入依赖的package包/类
@Override
boolean processUnknowPacket(Element doc) {
    String tag = doc.getName();
    if ("route".equals(tag)) {
        // Process stanza wrapped by the route packet
        processRoute(new Route(doc));
        return true;
    } else if ("handshake".equals(tag)) {
        if (!((LocalConnectionMultiplexerSession) session).authenticate(doc.getStringValue())) {
            session.close();
        }
        return true;
    } else if ("error".equals(tag) && "stream".equals(doc.getNamespacePrefix())) {
        session.close();
        return true;
    }
    return false;
}
 

import org.jivesoftware.openfire.multiplex.Route; //导入依赖的package包/类
@Override
boolean processUnknowPacket(Element doc) {
       String tag = doc.getName();
       if ("route".equals(tag)) {
           // Process stanza wrapped by the route packet
           processRoute(new Route(doc));
           return true;
       } else if ("handshake".equals(tag)) {
           if (!((LocalConnectionMultiplexerSession) session).authenticate(doc.getStringValue())) {
               session.close();
           }
           return true;
       } else if ("error".equals(tag) && "stream".equals(doc.getNamespacePrefix())) {
           session.close();
           return true;
       }
       return false;
   }
 

import org.jivesoftware.openfire.multiplex.Route; //导入依赖的package包/类
/**
 * Sets up the test fixtures.
 */
@Before
public void setup() {
    normalMessage = new Message();
    normalMessage.setType(Message.Type.normal);
    chatMessage = new Message();
    chatMessage.setType(Message.Type.chat);
    groupMessage = new Message();
    groupMessage.setType(Message.Type.groupchat);
    errorMessage = new Message();
    errorMessage.setType(Message.Type.error);
    headlineMessage = new Message();
    headlineMessage.setType(Message.Type.headline);
    presence = new Presence();
    joinRoom = new JoinRoom("a", "b");
    leaveRoom = new LeaveRoom("a", "b");
    iq = new IQ();
    route = new Route("id");
}
 

import org.jivesoftware.openfire.multiplex.Route; //导入依赖的package包/类
/**
 * Process stanza sent by a client that is connected to a connection manager. The
 * original stanza is wrapped in the route element. Only a single stanza must be
 * wrapped in the route element.
 *
 * @param packet the route element.
 */
private void processRoute(final Route packet) {
    if (session.getStatus() != Session.STATUS_AUTHENTICATED) {
        // Session is not authenticated so return error
        Route reply = new Route(packet.getStreamID());
        reply.setID(packet.getID());
        reply.setTo(packet.getFrom());
        reply.setFrom(packet.getTo());
        reply.setError(PacketError.Condition.not_authorized);
        session.process(reply);
        return;
    }
    // Process the packet
    packetHandler.route(packet);
}