import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.bson.types.ObjectId;
import com.google.common.collect.Maps;
import org.graylog2.Core;
<BUG>import org.graylog2.buffers.MessageEvent;
</BUG>
import org.graylog2.outputs.OutputRouter;
import org.graylog2.outputs.OutputStreamConfigurationImpl;
import org.graylog2.plugin.Message;

import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.bson.types.ObjectId;
import com.google.common.collect.Maps;
import org.graylog2.Core;
import org.graylog2.plugin.buffers.MessageEvent;
import org.graylog2.outputs.OutputRouter;
import org.graylog2.outputs.OutputStreamConfigurationImpl;
import org.graylog2.plugin.Message;
