public AsyncService(String serviceName) 
{
                        
        super(serviceName);
}

Constructs an asyncronous service.

Parameters:

serviceName - the name of the service

since: 0.2.0 -

 abstract protected int[] getAsyncMessageFilter()

Implement this method by returning the message ids of the asyncrounous
messages your implementation wants to receive.

 abstract protected  void onMessageReceived(SshMessage msg) throws IOException

Called by the service thread when an asyncronous message is received.

 protected  void onStart() throws IOException 
{
        if (Thread.currentThread() instanceof SshThread) {
            thread = ((SshThread) Thread.currentThread()).cloneThread(this,
                    getServiceName());
        } else {
            thread = new SshThread(this, getServiceName(), true);
        }
        log.info("Starting " + getServiceName() + " service thread");
        thread.start();
}

Implements the abstract Service method and starts the service thread.

 abstract protected  void onStop()

The service thread calls this method when the thread is exiting.

 public final  void run() 
{
        int[] messageFilter = getAsyncMessageFilter();
        state.setValue(ServiceState.SERVICE_STARTED);
        SshMessage msg = null;
        while ((state.getValue() == ServiceState.SERVICE_STARTED) &&
                transport.isConnected()) {
            try {
                // Get the next message from the message store
                msg = messageStore.getMessage(messageFilter);
                if (state.getValue() == ServiceState.SERVICE_STOPPED) {
                    break;
                }
                if (log.isDebugEnabled()) {
                    log.debug("Routing " + msg.getMessageName());
                }
                onMessageReceived(msg);
                if (log.isDebugEnabled()) {
                    log.debug("Finished processing " + msg.getMessageName());
                }
            } catch (MessageStoreEOFException eof) {
                stop();
            } catch (Exception ex) {
                if ((state.getValue() != ServiceState.SERVICE_STOPPED) &&
                        transport.isConnected()) {
                    log.fatal("Service message loop failed!", ex);
                    stop();
                }
            }
        }
        onStop();
        log.info(getServiceName() + " thread is exiting");
        thread = null;
}

Implements the asyncronous services message loop.