loopbackchannel.java

POS is a Java&#174 platform-based, mission-critical, ISO-8583 based financial transaction library/fr

/*
 * jPOS Project [http://jpos.org]
 * Copyright (C) 2000-2008 Alejandro P. Revilla
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

package org.jpos.iso.channel;
/**
 * sends back requests, posibly applying filters
 * @author <a href="mailto:[e-mail]">Alejandro P. Revilla</a>
 * @version $Revision: 2594 $ $Date: 2008-01-22 14:41:31 -0200 (Tue, 22 Jan 2008) $
 * @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;
    }
}