Package com.couchbase.client.core
Class ResponseHandler
- java.lang.Object
-
- com.couchbase.client.core.ResponseHandler
-
- All Implemented Interfaces:
com.lmax.disruptor.EventHandler<ResponseEvent>
public class ResponseHandler extends Object implements com.lmax.disruptor.EventHandler<ResponseEvent>
-
-
Field Summary
Fields Modifier and Type Field Description static com.lmax.disruptor.EventTranslatorTwoArg<ResponseEvent,CouchbaseMessage,rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>>
RESPONSE_TRANSLATOR
TranslatesCouchbaseRequest
s intoRequestEvent
s.
-
Constructor Summary
Constructors Constructor Description ResponseHandler(CoreEnvironment environment, ClusterFacade cluster, ConfigurationProvider provider)
Creates a newResponseHandler
.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onEvent(ResponseEvent event, long sequence, boolean endOfBatch)
HandlesResponseEvent
s that come into the response RingBuffer.
-
-
-
Field Detail
-
RESPONSE_TRANSLATOR
public static final com.lmax.disruptor.EventTranslatorTwoArg<ResponseEvent,CouchbaseMessage,rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>> RESPONSE_TRANSLATOR
TranslatesCouchbaseRequest
s intoRequestEvent
s.
-
-
Constructor Detail
-
ResponseHandler
public ResponseHandler(CoreEnvironment environment, ClusterFacade cluster, ConfigurationProvider provider)
Creates a newResponseHandler
.- Parameters:
environment
- the global environment.cluster
- the cluster reference.provider
- th configuration provider.
-
-
Method Detail
-
onEvent
public void onEvent(ResponseEvent event, long sequence, boolean endOfBatch) throws Exception
HandlesResponseEvent
s that come into the response RingBuffer. Hey I just mapped you, And this is crazy, But here's my data so subscribe me maybe. It's hard to block right, at you baby, But here's my data , so subscribe me maybe.- Specified by:
onEvent
in interfacecom.lmax.disruptor.EventHandler<ResponseEvent>
- Throws:
Exception
-
-