public class ResponseHandler extends Object implements com.lmax.disruptor.EventHandler<ResponseEvent>
Modifier and Type | Field and Description |
---|---|
static com.lmax.disruptor.EventTranslatorTwoArg<ResponseEvent,CouchbaseMessage,rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>> |
RESPONSE_TRANSLATOR
Translates
CouchbaseRequest s into RequestEvent s. |
Constructor and Description |
---|
ResponseHandler(CoreEnvironment environment,
ClusterFacade cluster,
ConfigurationProvider provider)
Creates a new
ResponseHandler . |
Modifier and Type | Method and Description |
---|---|
void |
onEvent(ResponseEvent event,
long sequence,
boolean endOfBatch)
Handles
ResponseEvent s that come into the response RingBuffer. |
public static final com.lmax.disruptor.EventTranslatorTwoArg<ResponseEvent,CouchbaseMessage,rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>> RESPONSE_TRANSLATOR
Translates CouchbaseRequest
s into RequestEvent
s.
public ResponseHandler(CoreEnvironment environment, ClusterFacade cluster, ConfigurationProvider provider)
Creates a new ResponseHandler
.
environment
- the global environment.cluster
- the cluster reference.provider
- th configuration provider.public void onEvent(ResponseEvent event, long sequence, boolean endOfBatch) throws Exception
Handles ResponseEvent
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.
onEvent
in interface com.lmax.disruptor.EventHandler<ResponseEvent>
Exception
Copyright © 2017 Couchbase, Inc.. All rights reserved.