org.graylog2.indexer.messages

Class Messages

java.lang.Object

org.graylog2.indexer.messages.Messages

public class Messages
extends java.lang.Object

Author:

Lennart Koopmann

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	TYPE

Constructor Summary

Constructors

Constructor and Description
Messages(org.elasticsearch.node.Node node, Configuration configuration)

Method Summary

Modifier and Type	Method and Description
java.util.List<java.lang.String>	analyze(java.lang.String string, java.lang.String index)
boolean	bulkIndex(java.util.List<Message> messages)
ResultMessage	get(java.lang.String messageId, java.lang.String index)
java.util.concurrent.LinkedBlockingQueue<java.util.List<DeadLetter>>	getDeadLetterQueue()

Methods inherited from class java.lang.Object

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

Field Detail

TYPE

public static final java.lang.String TYPE

See Also:

Constant Field Values

Constructor Detail

Messages

@Inject
public Messages(org.elasticsearch.node.Node node,
                        Configuration configuration)

Method Detail

getDeadLetterQueue

public java.util.concurrent.LinkedBlockingQueue<java.util.List<DeadLetter>> getDeadLetterQueue()

get

public ResultMessage get(java.lang.String messageId,
                         java.lang.String index)
                  throws org.elasticsearch.indices.IndexMissingException,
                         DocumentNotFoundException

Throws:

org.elasticsearch.indices.IndexMissingException

DocumentNotFoundException

analyze

public java.util.List<java.lang.String> analyze(java.lang.String string,
                                                java.lang.String index)
                                         throws org.elasticsearch.indices.IndexMissingException

Throws:

org.elasticsearch.indices.IndexMissingException

bulkIndex

public boolean bulkIndex(java.util.List<Message> messages)