package ch.qos.logback.core;
 
import java.io.IOException;
import java.io.OutputStream;
 
import org.junit.Test;
 
import ch.qos.logback.core.encoder.EncoderBase;
 
 
public class TestAppender {
      
       @Test
       public void testAppender() throws InterruptedException {
             OutputStreamAppender<Object> appender = new OutputStreamAppender<Object>() {
                    @Override
                    public void addError(String msg, Throwable ex) {
                           throw new RuntimeException(msg, ex);
                    }
             };
             appender.setEncoder(new EncoderBase<Object>() {
 
                    @Override
                    public byte[] headerBytes() {
                           return null;
                    }
 
                    @Override
                    public byte[] encode(Object event) {
                           try {
                                  Thread.sleep(1000);
                           } catch (InterruptedException e) {
                                  // TODO Auto-generated catch block
                                  e.printStackTrace();
                           }
                           return new byte[] {'A'};
                    }
 
                    @Override
                    public byte[] footerBytes() {
                           // TODO Auto-generated method stub
                           return null;
                    }
             });
             appender.setOutputStream(new OutputStream() {
                   
                    @Override
                    public void write(int b) throws IOException {
                           throw new RuntimeException("not closed appender");
                    }
             });
             appender.start();
            
             Thread t = new Thread(new Runnable() {
                   
                    @Override
                    public void run() {
                           try {
                                  Thread.sleep(500);
                           } catch (InterruptedException e) {
                                  // TODO Auto-generated catch block
                                  e.printStackTrace();
                           }
                           appender.stop();
                    }
             });
             t.start();
             appender.doAppend(new Object());
             t.join();
       }
 
}