org.graylog2.indexer.messages

Class Messages

java.lang.Object

org.graylog2.indexer.messages.Messages

@Singleton
public class Messages
extends Object

Constructor Summary

Constructors

Constructor and Description
Messages(com.codahale.metrics.MetricRegistry metricRegistry, io.searchbox.client.JestClient client, ProcessingStatusRecorder processingStatusRecorder, boolean useExpectContinue)

Method Summary

Modifier and Type	Method and Description
List<String>	analyze(String toAnalyze, String index, String analyzer)
List<String>	bulkIndex(List<Map.Entry<IndexSet,Message>> messageList)
List<String>	bulkIndex(List<Map.Entry<IndexSet,Message>> messageList, boolean isSystemTraffic)
ResultMessage	get(String messageId, String index)
LinkedBlockingQueue<List<IndexFailure>>	getIndexFailureQueue()
io.searchbox.core.Index	prepareIndexRequest(String index, Map<String,Object> source, String id)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Messages

@Inject
public Messages(com.codahale.metrics.MetricRegistry metricRegistry,
                        io.searchbox.client.JestClient client,
                        ProcessingStatusRecorder processingStatusRecorder,
                        @Named(value="elasticsearch_use_expect_continue")
                        boolean useExpectContinue)

Method Detail

get

public ResultMessage get(String messageId,
                         String index)
                  throws DocumentNotFoundException,
                         IOException

Throws:

DocumentNotFoundException

IOException

analyze

public List<String> analyze(String toAnalyze,
                            String index,
                            String analyzer)
                     throws IOException

Throws:

IOException

bulkIndex

public List<String> bulkIndex(List<Map.Entry<IndexSet,Message>> messageList)

bulkIndex

public List<String> bulkIndex(List<Map.Entry<IndexSet,Message>> messageList,
                              boolean isSystemTraffic)

prepareIndexRequest

public io.searchbox.core.Index prepareIndexRequest(String index,
                                                   Map<String,Object> source,
                                                   String id)

getIndexFailureQueue

public LinkedBlockingQueue<List<IndexFailure>> getIndexFailureQueue()