Package com.couchbase.transactions.log
Class EventBusPersistedLogger
- java.lang.Object
-
- com.couchbase.transactions.log.EventBusPersistedLogger
-
- All Implemented Interfaces:
java.lang.Runnable
,java.util.function.Consumer<com.couchbase.client.core.cnc.Event>
@Internal public class EventBusPersistedLogger extends java.lang.Object implements java.util.function.Consumer<com.couchbase.client.core.cnc.Event>, java.lang.Runnable
Listens for events on the Couchbase event bus and logs some to the transactions persisted log.- Since:
- 1.0.0
-
-
Constructor Summary
Constructors Constructor Description EventBusPersistedLogger(com.couchbase.client.core.cnc.EventBus eventBus, PersistedLogWriter log, MergedTransactionConfig config)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
accept(com.couchbase.client.core.cnc.Event event)
void
run()
-
-
-
Constructor Detail
-
EventBusPersistedLogger
public EventBusPersistedLogger(com.couchbase.client.core.cnc.EventBus eventBus, PersistedLogWriter log, MergedTransactionConfig config)
-
-