Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package com.internetitem.logback.elasticsearch;
 
 
 import java.io.Writer;
public class ElasticsearchOutputAggregator extends Writer {
	private Settings settings;
	public ElasticsearchOutputAggregator(Settings settingsErrorReporter errorReporter) {
		this. = new ArrayList<SafeWriter>();
		this. = settings;
		this. = errorReporter;
	}
	public void addWriter(SafeWriter writer) {
		.add(writer);
	}
	public void write(char[] cbufint offint lenthrows IOException {
		for (SafeWriter writer : ) {
			writer.write(cbufofflen);
		}
	}
	public boolean hasPendingData() {
		for (SafeWriter writer : ) {
			if (writer.hasPendingData()) {
				return true;
			}
		}
		return false;
	}
	public boolean hasOutputs() {
		return !.isEmpty();
	}
	public boolean sendData() {
		boolean success = true;
		for (SafeWriter writer : ) {
			try {
				writer.sendData();
catch (Exception e) {
				success = false;
				.logError("Failed to send events to Elasticsearch: " + e.getMessage(), e);
					..println("[" + new Date().toString() + "] Failed to send events to Elasticsearch: " + e.getMessage());
				}
			}
		}
		return success;
	}
	public void flush() throws IOException {
		// No-op
	}
	public void close() throws IOException {
		// No-op
	}
New to GrepCode? Check out our FAQ X