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 TransportClient

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.transport.TransportClient client) Publishes the array list of simplified jsons to Elasticsearch using the Transport 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.transport.TransportClient client)

Publishes the array list of simplified jsons to Elasticsearch using the Transport client

Parameters:

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

client - elasticsearch Transport client

getAllMappingsQueue

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

Returns:

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