Package org.gcube.event.publisher
Class BufferedEventProcessor
java.lang.Object
org.gcube.event.publisher.BufferedEventProcessor
-
Constructor Summary
ConstructorsConstructorDescriptionBufferedEventProcessor(String conductorEndpoint, String clientId, String clientSecret, String keycloakTokenEndpoint, Function<Event, String> logInfoGenerator) BufferedEventProcessor(String conductorEndpoint, String clientId, String clientSecret, String keycloakTokenEndpoint, Function<Event, String> logInfoGenerator, int bufferSize) -
Method Summary
Modifier and TypeMethodDescriptionvoidenqueueEvent(Event event) intgetCount()intlonggetMax()longgetMin()
-
Constructor Details
-
BufferedEventProcessor
public BufferedEventProcessor(String conductorEndpoint, String clientId, String clientSecret, String keycloakTokenEndpoint, Function<Event, String> logInfoGenerator) throws EventProcessorException- Throws:
EventProcessorException
-
BufferedEventProcessor
public BufferedEventProcessor(String conductorEndpoint, String clientId, String clientSecret, String keycloakTokenEndpoint, Function<Event, String> logInfoGenerator, int bufferSize) throws EventProcessorException- Throws:
EventProcessorException
-
-
Method Details
-
enqueueEvent
- Throws:
InterruptedException
-
allQueuedFinishedCorrectly
-
getCount
public int getCount() -
getMin
public long getMin() -
getMax
public long getMax() -
getErrors
public int getErrors()
-