[Jmri-commits] CVS: jmri/jmrix/loconet/locormi LnMessageClientPollThread.java,NONE,1.1

[Alex S. <kiw...@us...>]

Update of /cvsroot/jmri/jmri/jmrix/loconet/locormi
In directory usw-pr-cvs1:/tmp/cvs-serv12754/src/jmri/jmrix/loconet/locormi

Added Files:
	LnMessageClientPollThread.java 
Log Message:
added client message poll thread

--- NEW FILE: LnMessageClientPollThread.java ---
package jmri.jmrix.loconet.locormi;

import java.lang.Thread;
import jmri.jmrix.loconet.LocoNetMessage;

class LnMessageClientPollThread extends Thread{
    LnMessageClient parent = null ;
   	static org.apache.log4j.Category log = org.apache.log4j.Category.getInstance(LnMessageClientPollThread.class.getName());

    LnMessageClientPollThread( LnMessageClient lnParent ){
        parent = lnParent ;
        this.setDaemon( true );
        this.start();
    }

    public void run() {
        try{
            Object[] lnMessages = null ;
            while( !this.interrupted() ){
                lnMessages = parent.lnMessageBuffer.getMessages( parent.pollTimeout ) ;

                if( lnMessages != null ){

                    log.debug( "Recieved Message Array Size: " + lnMessages.length );
                    for( int lnMessageIndex = 0; lnMessageIndex < lnMessages.length; lnMessageIndex++ ){
                        LocoNetMessage message = (LocoNetMessage)lnMessages[ lnMessageIndex ] ;
                        parent.message( message );
                    }
                }
            }
        }
        catch( Exception ex ){
            log.warn( "Exception: " + ex ) ;
        }
    }
}