Class LoggingConsumer
- java.lang.Object
-
- rx.Subscriber<CouchbaseEvent>
-
- com.couchbase.client.core.event.consumers.LoggingConsumer
-
- All Implemented Interfaces:
rx.Observer<CouchbaseEvent>
,rx.Subscription
public class LoggingConsumer extends rx.Subscriber<CouchbaseEvent>
ConsumesCouchbaseEvent
s and logs them.- Since:
- 1.2.0
- Author:
- Michael Nitschinger
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
LoggingConsumer.OutputFormat
The target output format to log.
-
Field Summary
Fields Modifier and Type Field Description static LoggingConsumer.OutputFormat
DEFAULT_FORMAT
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static LoggingConsumer
create()
static LoggingConsumer
create(CouchbaseLogLevel level, LoggingConsumer.OutputFormat outputFormat)
void
onCompleted()
void
onError(Throwable ex)
void
onNext(CouchbaseEvent event)
-
-
-
Field Detail
-
DEFAULT_FORMAT
public static final LoggingConsumer.OutputFormat DEFAULT_FORMAT
-
-
Method Detail
-
create
public static LoggingConsumer create()
-
create
public static LoggingConsumer create(CouchbaseLogLevel level, LoggingConsumer.OutputFormat outputFormat)
-
onCompleted
public void onCompleted()
-
onError
public void onError(Throwable ex)
-
onNext
public void onNext(CouchbaseEvent event)
-
-