dispatcherfilter.java

银行项目为后台ｓｏｃｋｅｔ通信写的程序

/****************************************************************************
 * Package		: com.ecSolutions.ecAppServer.server.filter
 * File			: DispatcherFilter.java
 * Create Date  : 2007-7-20
 * Author		: Steven Chen
 * 
 * Copyright(C) 2006 ecSolutions(shanghai) Co.,Limited.All Rights Reserved.
 *			
 ***************************************************************************/
package com.ecSolutions.ecAppServer.server.filter;

import com.ecSolutions.ecAppServer.server.Packet;
import com.ecSolutions.ecAppServer.server.SessionFilter;
import com.ecSolutions.ecAppServer.server.SessionFilterChain;
import com.ecSolutions.ecAppServer.server.session.dispatcher.Dispatcher;

/**
 * Dispatch events. The first inner filter.
 * 
 * @author Steven Chen
 * @version $Id: DispatcherFilter.java,v 1.2 2007/07/26 03:24:37 stevenchen Exp $
 */
public class DispatcherFilter implements SessionFilter {

    private final Dispatcher dispatcher;

    public DispatcherFilter(Dispatcher dispatcher) {
        this.dispatcher = dispatcher;
    }

    public Dispatcher getDispatcher() {
        return dispatcher;
    }

    public void exceptionCaught(final SessionFilterChain filterChain,
            final Throwable cause) {
        dispatcher.dispatch(filterChain.getSession(), new Runnable() {

            public void run() {
                filterChain.exceptionCaught(cause);
            }
        });
    }

    public void packetReceived(final SessionFilterChain filterChain,
            final Packet packet) throws Exception {
        dispatcher.dispatch(filterChain.getSession(), new Runnable() {

            public void run() {
                filterChain.packetReceived(packet);
            }
        });
    }

    public void objectReceived(final SessionFilterChain filterChain,
            final Object obj) throws Exception {
        dispatcher.dispatch(filterChain.getSession(), new Runnable() {

            public void run() {
                filterChain.objectReceived(obj);
            }
        });
    }

    public void packetSend(final SessionFilterChain filterChain,
            final Packet packet) throws Exception {
        dispatcher.dispatch(filterChain.getSession(), new Runnable() {

            public void run() {
                filterChain.packetSend(packet);
            }
        });
    }

    public void packetSent(final SessionFilterChain filterChain,
            final Packet packet) throws Exception {
        dispatcher.dispatch(filterChain.getSession(), new Runnable() {

            public void run() {
                filterChain.packetSent(packet);
            }
        });
    }

    public void objectSent(final SessionFilterChain filterChain,
            final Object obj) throws Exception {
        dispatcher.dispatch(filterChain.getSession(), new Runnable() {

            public void run() {
                filterChain.objectSent(obj);
            };
        });
    }

    public void sessionClosed(final SessionFilterChain filterChain)
            throws Exception {
        dispatcher.dispatch(filterChain.getSession(), new Runnable() {

            public void run() {
                filterChain.sessionClosed();
            }
        });
    }

    public void sessionStarted(final SessionFilterChain filterChain)
            throws Exception {
        dispatcher.dispatch(filterChain.getSession(), new Runnable() {

            public void run() {
                filterChain.sessionStarted();
            }
        });
    }

    public void sessionTimeout(final SessionFilterChain filterChain)
            throws Exception {
        dispatcher.dispatch(filterChain.getSession(), new Runnable() {

            public void run() {
                filterChain.sessionTimeout();
            }
        });
    }

}