/** * $RCSfile$ * $Revision$ * $Date$ * * Copyright (C) 2004 Jive Software. All rights reserved. * * This software is published under the terms of the GNU Public License (GPL), * a copy of which is included in this distribution. */ package org.jivesoftware.messenger; import org.xmpp.packet.Packet; import org.xmpp.packet.Message; import org.xmpp.packet.Presence; import org.xmpp.packet.IQ; import org.jivesoftware.messenger.container.BasicModule; /** * <p>An uber router that can handle any packet type.</p> * <p>The interface is provided primarily as a convenience for services * that must route all packet types (e.g. s2s routing, e2e encryption, etc).</p> * * @author Iain Shigeoka */ public class PacketRouter extends BasicModule { private IQRouter iqRouter; private PresenceRouter presenceRouter; private MessageRouter messageRouter; /** * Constructs a packet router. */ public PacketRouter() { super("XMPP Packet Router"); } /** * Routes the given packet based on packet recipient and sender. The * router defers actual routing decisions to other classes. * <h2>Warning</h2> * Be careful to enforce concurrency DbC of concurrent by synchronizing * any accesses to class resources. * * @param packet The packet to route */ public void route(Packet packet) { if (packet instanceof Message) { route((Message)packet); } else if (packet instanceof Presence) { route((Presence)packet); } else if (packet instanceof IQ) { route((IQ)packet); } else { throw new IllegalArgumentException(); } } public void route(IQ packet) { iqRouter.route(packet); } public void route(Message packet) { messageRouter.route(packet); } public void route(Presence packet) { presenceRouter.route(packet); } public void initialize(XMPPServer server) { super.initialize(server); iqRouter = server.getIQRouter(); messageRouter = server.getMessageRouter(); presenceRouter = server.getPresenceRouter(); } }