/** * $RCSfile$ * $Revision: 943 $ * $Date: 2005-02-04 01:53:20 -0300 (Fri, 04 Feb 2005) $ * * Copyright (C) 2006 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.wildfire.spi; import org.jivesoftware.wildfire.*; import org.jivesoftware.wildfire.container.BasicModule; import org.xmpp.packet.IQ; import org.xmpp.packet.Message; import org.xmpp.packet.Packet; import org.xmpp.packet.Presence; /** * An uber router that can handle any packet type.<p> * * The interface is provided primarily as a convenience for services * that must route all packet types (e.g. s2s routing, e2e encryption, etc). * * @author Iain Shigeoka */ public class PacketRouterImpl extends BasicModule implements PacketRouter { private IQRouter iqRouter; private PresenceRouter presenceRouter; private MessageRouter messageRouter; /** * Constructs a packet router. */ public PacketRouterImpl() { 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(); } }