loopbackchannel.java

来自「java pos,你可以直接编译运行,」· Java 代码 · 共 147 行

/*
 * Copyright (c) 2004 jPOS.org 
 *
 * See terms of license at http://jpos.org/license.html
 *
 */

package org.jpos.iso.channel;
/**
 * sends back requests, posibly applying filters
 * @author <a href="mailto:[e-mail]">Alejandro P. Revilla</a>
 * @version $Revision: 1.14 $ $Date: 2004/05/05 14:23:06 $
 * @since 1.2.2
 */

import java.io.IOException;

import org.jpos.iso.FilteredBase;
import org.jpos.iso.ISOException;
import org.jpos.iso.ISOMsg;
import org.jpos.iso.ISOPackager;
import org.jpos.iso.ISOFilter.VetoException;
import org.jpos.util.BlockingQueue;
import org.jpos.util.LogEvent;
import org.jpos.util.LogSource;
import org.jpos.util.Logger;
import org.jpos.util.NameRegistrar;

public class LoopbackChannel extends FilteredBase implements LogSource {
    boolean usable = true;
    private int[] cnt;
    String name;
    BlockingQueue queue;
    Logger logger;
    String realm;

    public LoopbackChannel () {
        super();
        cnt = new int[SIZEOF_CNT];
        queue = new BlockingQueue();
    }

   /**
    * setPackager is optional on LoopbackChannel, it is
    * used for debugging/formating purposes only
    */
    public void setPackager(ISOPackager packager) {
        // N/A
    }
    
    public void connect () {
        cnt[CONNECT]++;
        usable = true;
        setChanged();
        notifyObservers();
    }

    /**
     * disconnects ISOChannel
     */
    public void disconnect () {
        usable = false;
        setChanged();
        notifyObservers();
    }

    public void reconnect() {
        usable = true;
        setChanged();
        notifyObservers();
    }

    public boolean isConnected() {
        return usable;
    }

    public void send (ISOMsg m)
        throws IOException,ISOException, VetoException
    {
        if (!isConnected())
            throw new ISOException ("unconnected ISOChannel");
        LogEvent evt = new LogEvent (this, "loopback-send", m);
        m = applyOutgoingFilters (m, evt);
        queue.enqueue (m);
        cnt[TX]++;
        notifyObservers();
        Logger.log (evt);
    }

    public ISOMsg receive() throws IOException, ISOException
    {
        if (!isConnected())
            throw new ISOException ("unconnected ISOChannel");
        try {
            ISOMsg m = (ISOMsg) ((ISOMsg) queue.dequeue()).clone();
            LogEvent evt = new LogEvent (this, "loopback-receive", m);
            m = applyIncomingFilters (m, evt);
            cnt[RX]++;
            notifyObservers();
            Logger.log (evt);
            return m;
        } catch (InterruptedException e) {
            throw new IOException (e.toString());
        } catch (BlockingQueue.Closed e) {
            throw new IOException (e.toString());
        }
    }

    public void setUsable(boolean usable) {
        this.usable = usable;
        setChanged();
        notifyObservers();
    }

    public int[] getCounters() {
        return cnt;
    }

    public void setName (String name) {
        this.name = name;
        NameRegistrar.register ("channel."+name, this);
    }

    public String getName() {
        return name;
    }

    public ISOPackager getPackager() {
        return null;
    }

    public void resetCounters() {
        for (int i=0; i<SIZEOF_CNT; i++)
            cnt[i] = 0;
    }
    public void setLogger (Logger logger, String realm) {
        this.logger = logger;
        this.realm  = realm;
    }
    public String getRealm () {
        return realm;
    }
    public Logger getLogger() {
        return logger;
    }
}