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(org.elasticsearch.client.Client client, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method and Description
List<String>	analyze(String string, String index, String analyzer)
org.elasticsearch.action.index.IndexRequest	buildIndexRequest(String index, Map<String,Object> source, String id)
boolean	bulkIndex(List<Map.Entry<IndexSet,Message>> messageList)
ResultMessage	get(String messageId, String index)
LinkedBlockingQueue<List<IndexFailure>>	getIndexFailureQueue()

Methods inherited from class java.lang.Object

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

Constructor Detail

Messages

@Inject
public Messages(org.elasticsearch.client.Client client,
                        com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

get

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

Throws:

DocumentNotFoundException

analyze

public List<String> analyze(String string,
                            String index,
                            String analyzer)

bulkIndex

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

buildIndexRequest

public org.elasticsearch.action.index.IndexRequest buildIndexRequest(String index,
                                                                     Map<String,Object> source,
                                                                     String id)

getIndexFailureQueue

public LinkedBlockingQueue<List<IndexFailure>> getIndexFailureQueue()