public void run() {
    try {
      LoggerContext lc = (LoggerContext) getContext();
      while (!Thread.currentThread().isInterrupted()) {
        SocketConnector connector = createConnector(address, port, 0,
                reconnectionDelay);
        connectorTask = activateConnector(connector);
        if (connectorTask == null) {
          break;
        }
        socket = waitForConnectorToReturnASocket();
        if (socket == null)
          break;
        dispatchEvents(lc);
      }
    } catch (InterruptedException ex) {
      assert true;    // ok... we'll exit now
    }
    addInfo("shutting down");
  }
public void run() {
    try {
      LoggerContext lc = (LoggerContext) getContext();
      while (!Thread.currentThread().isInterrupted()) {
        SocketConnector connector = createConnector(address, port, 0,
                reconnectionDelay);
        connectorTask = activateConnector(connector);
        if (connectorTask == null) {
          break;
        }
        socket = waitForConnectorToReturnASocket();
        if (socket == null)
          break;
        dispatchEvents(lc);
      }
    } catch (InterruptedException ex) {
      assert true;    
    }
    addInfo("shutting down");
  }
public void run ( ) { try { LoggerContext lc = ( LoggerContext ) getContext ( ) ; while ( ! Thread . currentThread ( ) . isInterrupted ( ) ) { SocketConnector connector = createConnector ( address , port , 0 , reconnectionDelay ) ; connectorTask = activateConnector ( connector ) ; if ( connectorTask == null ) { break ; } socket = waitForConnectorToReturnASocket ( ) ; if ( socket == null ) break ; dispatchEvents ( lc ) ; } } catch ( InterruptedException ex ) { assert true ; // ok... we'll exit now } addInfo ( "shutting down" ) ; }
{@inheritDoc}
{