basereaderthread.java

First of all, the Applet-phone is a SIP User-Agent with audio and text messaging capabilities. But

/*
 * BaseReaderThread.java
 *
 * Created on August 1, 2003, 2:19 PM
 */

package gov.nist.examples.bps.reader;

import gov.nist.examples.bps.reader.baselistener.*;

/**
 *
 * @author  Deruelle Olivier
 */
public class BaseReaderThread extends Thread{
    
    private BaseReader baseReader;
    private CommandManager commandManager;
    private BaseReaderNotificationImpl notifier;
    
    /** Creates a new instance of BaseReaderThread */
    public BaseReaderThread(BaseReader baseReader) {
        try{
            this.baseReader=baseReader;
            Configuration configuration=baseReader.getConfiguration();
            
            BaseReaderDebug.println("BaseReaderThread, serial debug is: "+configuration.serialDebug);
            SerialDebug serialDebug=new SerialDebug(configuration.serialDebug);
            
            BaseCommunicator baseCommunicator=new BaseCommunicator(configuration.serialPortIdentifier,
            configuration.serialLocalPort);
            baseCommunicator.connect();
            commandManager=baseCommunicator.getCommandManager();
            
            BaseReaderDebug.println("BaseReaderThread, Trying to update the base attenuation to: "+
            configuration.baseReaderRange);
            if (configuration.baseReaderRange!=null &&
                !configuration.baseReaderRange.trim().equals("") ) {
                commandManager.setBaseRxAttenuation(configuration.baseReaderRange);
            }
            BaseReaderDebug.println();
            String attenuation=commandManager.getBaseRxAttenuation();
            BaseReaderDebug.println("BaseReaderThread, The base attenuation is: "+attenuation );
            BaseReaderDebug.println();
            
            int timeout=commandManager.getBaseTimeOut();
            BaseReaderDebug.println("BaseReaderThread, The base timeout is: "+timeout +" seconds");
            BaseReaderDebug.println();
            
        }
        catch(Exception e) {
            BaseReaderDebug.println("BaseReaderThread, unable to connect to the base: ");
            e.printStackTrace();
        }
    }
    
    public void run() {
        try{
            /*
             * SYNCHRONOUS MODE: we pool the base reader.
            while (true) {
                
                BaseReaderDebug.println("BaseReader pooling...");
                Vector activeBadges=commandManager.getIdTable();
                BaseReaderDebug.println("The active badges are: ");
                for (int i=0;i<activeBadges.size();i++) {
                    Badge badge=(Badge)activeBadges.elementAt(i);
                    BaseReaderDebug.println("    - ID hex: "+badge.getBadgeIdHex()+" ; Id dec: "+
                    badge.getBadgeId() );
                }
                BaseReaderDebug.println();
                BaseReaderDebug.println("BaseReader pooling in waiting...");
                BaseReaderDebug.println();
                Thread.sleep(20000);
            }
             */
           
           /* ASYNCHRONOUS MODE: we wait for datas from the base reader.
            */
            notifier=new BaseReaderNotificationImpl(baseReader);
            BadgeAsynchronousThread thread=commandManager.getAsynchronousThread(notifier);
            thread.start();
                
            
        }
        catch(Exception e) {
            BaseReaderDebug.println("BaseReaderThread, unable to poll the base: ");
            e.printStackTrace();
            BaseReaderDebug.println("BaseReaderThread, the thread is over. ");
        }
        
    }
    
    public BaseReaderNotificationImpl getNotifier() {
        return notifier;
    }

}