org.wso2.ei.analytics.elk.publisher

Class ElasticStatisticsPublisher

java.lang.Object

org.wso2.ei.analytics.elk.publisher.ElasticStatisticsPublisher

public class ElasticStatisticsPublisher
extends Object

Processes the PublishingFlow into json strings and publishes to Elasticsearch using the RestHighLevelClient.

Method Summary

Modifier and Type	Method and Description
static Queue<Map<String,Object>>	getAllMappingsQueue()
static void	process(org.apache.synapse.aspects.flow.statistics.publishing.PublishingFlow publishingFlow) Processes the PublishingFlow into a simple json format
static void	publish(List<String> jsonsToSend, org.elasticsearch.client.RestHighLevelClient client) Publishes the array list of simplified jsons to Elasticsearch using the Java High Level REST Client.

Methods inherited from class java.lang.Object

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

Method Detail

process

public static void process(org.apache.synapse.aspects.flow.statistics.publishing.PublishingFlow publishingFlow)

Processes the PublishingFlow into a simple json format

Parameters:

publishingFlow - PublishingFlow object which contains the publishing events

publish

public static void publish(List<String> jsonsToSend,
                           org.elasticsearch.client.RestHighLevelClient client)

Publishes the array list of simplified jsons to Elasticsearch using the Java High Level REST Client.

Parameters:

jsonsToSend - array list of json strings to be published to Elasticsearch

client - elasticsearch RestHighLevelClient

getAllMappingsQueue

public static Queue<Map<String,Object>> getAllMappingsQueue()

Returns:

queue which includes all the Maps that are to be converted into json strings