logback-android/src/main/java/ch/qos/logback/core/net/server/RemoteReceiverStreamClient.java
public void run() {
    addInfo(clientId + "connected");

    ObjectOutputStream oos = null;
    try {
      int counter = 0;
      oos = createObjectOutputStream();
      while (!Thread.currentThread().isInterrupted()) {
        try {
          Serializable event = queue.take();
          oos.writeObject(event);
          oos.flush();
          if (++counter >= CoreConstants.OOS_RESET_FREQUENCY) {
            // failing to reset the stream periodically will result in a
            // serious memory leak (as noted in AbstractSocketAppender)
            counter = 0;
            oos.reset();
          }
        }
        catch (InterruptedException ex) {
          Thread.currentThread().interrupt();
        }
      }
    }
    catch (SocketException ex) {
      addInfo(clientId + ex);
    }
    catch (IOException ex) {
      addError(clientId + ex);
    }
    catch (RuntimeException ex) {
      addError(clientId + ex);
    }
    finally {
      if (oos != null) {
        CloseUtil.closeQuietly(oos);
      }
      close();
      addInfo(clientId + "connection closed");
    }
  }
public void run() {
    addInfo(clientId + "connected");

    ObjectOutputStream oos = null;
    try {
      int counter = 0;
      oos = createObjectOutputStream();
      while (!Thread.currentThread().isInterrupted()) {
        try {
          Serializable event = queue.take();
          oos.writeObject(event);
          oos.flush();
          if (++counter >= CoreConstants.OOS_RESET_FREQUENCY) {
            // failing to reset the stream periodically will result in a
            // serious memory leak (as noted in AbstractSocketAppender)
            counter = 0;
            oos.reset();
          }
        }
        catch (InterruptedException ex) {
          Thread.currentThread().interrupt();
        }
      }
    }
    catch (SocketException ex) {
      addInfo(clientId + ex);
    }
    catch (IOException ex) {
      addError(clientId + ex);
    }
    catch (RuntimeException ex) {
      addError(clientId + ex);
    }
    finally {
      if (oos != null) {
        CloseUtil.closeQuietly(oos);
      }
      close();
      addInfo(clientId + "connection closed");
    }
  }
public void run ( ) { addInfo ( clientId + "connected" ) ; ObjectOutputStream oos = null ; try { int counter = 0 ; oos = createObjectOutputStream ( ) ; while ( ! Thread . currentThread ( ) . isInterrupted ( ) ) { try { Serializable event = queue . take ( ) ; oos . writeObject ( event ) ; oos . flush ( ) ; if ( ++ counter >= CoreConstants . OOS_RESET_FREQUENCY ) { // failing to reset the stream periodically will result in a // serious memory leak (as noted in AbstractSocketAppender) counter = 0 ; oos . reset ( ) ; } } catch ( InterruptedException ex ) { Thread . currentThread ( ) . interrupt ( ) ; } } } catch ( SocketException ex ) { addInfo ( clientId + ex ) ; } catch ( IOException ex ) { addError ( clientId + ex ) ; } catch ( RuntimeException ex ) { addError ( clientId + ex ) ; } finally { if ( oos != null ) { CloseUtil . closeQuietly ( oos ) ; } close ( ) ; addInfo ( clientId + "connection closed" ) ; } }
{@inheritDoc}
{