Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package com.internetitem.logback.elasticsearch;
  
  
 import java.net.URL;
 
 public abstract class AbstractElasticsearchAppender<T> extends UnsynchronizedAppenderBase<T> {
 
 	protected Settings settings;
     protected ErrorReporter errorReporter;
 
 		this. = new Settings();
 	}
 
     public AbstractElasticsearchAppender(Settings settings) {
         this. = settings;
     }
 
 	public void start() {
 		super.start();
         this. = getErrorReporter();
         try {
 		} catch (IOException e) {
 			throw new RuntimeException(e);
 		}
 	}
 
     protected void publishEvent(T eventObject) {
         .addEvent(eventObject);
     }
 
     //VisibleForTesting
     protected ErrorReporter getErrorReporter() {
         return new ErrorReporter(getContext());
     }
 
     //VisibleForTesting
     protected abstract AbstractElasticsearchPublisher<T> buildElasticsearchPublisher() throws IOException;
 
     @Override
 	public void stop() {
 		super.stop();
 	}
 
 	protected void append(T eventObject) {
 		appendInternal(eventObject);
 	}
 
     protected abstract void appendInternal(T eventObject);
 
     public void setProperties(ElasticsearchProperties elasticsearchProperties) {
 		this. = elasticsearchProperties;
 	}
 
 	public void setSleepTime(int sleepTime) {
 		.setSleepTime(sleepTime);
 	}
 
 	public void setMaxRetries(int maxRetries) {
 		.setMaxRetries(maxRetries);
 	}
 
 	public void setConnectTimeout(int connectTimeout) {
 		.setConnectTimeout(connectTimeout);
 	}
 
 	public void setReadTimeout(int readTimeout) {
 		.setReadTimeout(readTimeout);
 	}
 
 	public void setIncludeCallerData(boolean includeCallerData) {
 		.setIncludeCallerData(includeCallerData);
 	}
 
 	public void setErrorsToStderr(boolean errorsToStderr) {
 		.setErrorsToStderr(errorsToStderr);
 	}
 
 	public void setLogsToStderr(boolean logsToStderr) {
 		.setLogsToStderr(logsToStderr);
 	}
 
 	public void setMaxQueueSize(int maxQueueSize) {
 		.setMaxQueueSize(maxQueueSize);
 	}
 
 	public void setIndex(String index) {
 		.setIndex(index);
	}
	public void setType(String type) {
	}
	public void setUrl(String urlthrows MalformedURLException {
		.setUrl(new URL(url));
	}
	public void setLoggerName(String logger) {
	}
	public void setErrorLoggerName(String logger) {
	}
New to GrepCode? Check out our FAQ X