com.cultofbits.integrationm.service.actionpack

Class EsActionPack

java.lang.Object

com.cultofbits.integrationm.service.actionpack.EsActionPack

public class EsActionPack
extends Object

Action pack for interacting with our own Elasticsearch server.
The action pack should be configured in com.cultofbits.integrationm.service.properties file with the elasticsearch key; for example:

  action.names=...,<es-ap-name>

  action.<es-ap-name>=elasticsearch
 

Constructor Summary

Constructors

Constructor and Description
EsActionPack(com.cultofbits.genesis.elasticsearch.IndexService indexService)

Method Summary

Modifier and Type	Method and Description
boolean	addOrUpdate(String index, String docId, Map<String,Object> fields) Indexes a doc based on the contents of the passed Map.
boolean	delete(String index, String docId) Delete an indexed document.

Methods inherited from class java.lang.Object

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

Constructor Detail

EsActionPack

public EsActionPack(com.cultofbits.genesis.elasticsearch.IndexService indexService)

Method Detail

addOrUpdate

public boolean addOrUpdate(String index,
                           String docId,
                           Map<String,Object> fields)

Indexes a doc based on the contents of the passed Map. If a doc with the same docId already exists, it is replaced.

Parameters:

index - the ElasticSearch index to be used

docId - the identifier of the indexed document

fields - the map of fields of the document to index

Returns:

true if the index operation is successful

delete

public boolean delete(String index,
                      String docId)

Delete an indexed document.

Parameters:

index - the ElasticSearch index to be used

docId - the identifier of the indexed document

Returns:

true if the delete operation is successful