Package org.mycore.webcli.flow

Class MCRLogEventProcessor

java.lang.Object

java.util.concurrent.SubmissionPublisher<com.google.gson.JsonObject>

org.mycore.webcli.flow.MCRLogEventProcessor

All Implemented Interfaces:

AutoCloseable, Flow.Processor<org.apache.logging.log4j.core.LogEvent,com.google.gson.JsonObject>, Flow.Publisher<com.google.gson.JsonObject>, Flow.Subscriber<org.apache.logging.log4j.core.LogEvent>

public class MCRLogEventProcessor
extends SubmissionPublisher<com.google.gson.JsonObject>
implements Flow.Processor<org.apache.logging.log4j.core.LogEvent,com.google.gson.JsonObject>

Constructor Summary

Constructors

Constructor	Description
MCRLogEventProcessor()

Method Summary

Modifier and Type	Method	Description
void	close()
void	onComplete()
void	onError(Throwable throwable)
void	onNext(org.apache.logging.log4j.core.LogEvent event)
void	onSubscribe(Flow.Subscription subscription)

Methods inherited from class java.util.concurrent.SubmissionPublisher

closeExceptionally, consume, estimateMaximumLag, estimateMinimumDemand, getClosedException, getExecutor, getMaxBufferCapacity, getNumberOfSubscribers, getSubscribers, hasSubscribers, isClosed, isSubscribed, offer, offer, submit, subscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Flow.Publisher

subscribe

Constructor Details

MCRLogEventProcessor

public MCRLogEventProcessor()

Method Details

onSubscribe

public void onSubscribe(Flow.Subscription subscription)

Specified by:

onSubscribe in interface Flow.Subscriber<org.apache.logging.log4j.core.LogEvent>

onNext

public void onNext(org.apache.logging.log4j.core.LogEvent event)

Specified by:

onNext in interface Flow.Subscriber<org.apache.logging.log4j.core.LogEvent>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface Flow.Subscriber<org.apache.logging.log4j.core.LogEvent>

onComplete

public void onComplete()

Specified by:

onComplete in interface Flow.Subscriber<org.apache.logging.log4j.core.LogEvent>

close

public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class SubmissionPublisher<com.google.gson.JsonObject>