public class RemoteReceiverStage extends Object implements EStage<TransportEvent>
Constructor and Description |
---|
RemoteReceiverStage(EventHandler<RemoteEvent<byte[]>> handler,
EventHandler<Throwable> errorHandler,
int numThreads)
Constructs a remote receiver stage.
|
public RemoteReceiverStage(EventHandler<RemoteEvent<byte[]>> handler, EventHandler<Throwable> errorHandler, int numThreads)
handler
- the handler of remote eventserrorHandler
- the exception handlernumThreads
- the number of threadspublic void onNext(TransportEvent value)
onNext
in interface EventHandler<TransportEvent>
value
- the eventpublic void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2017 The Apache Software Foundation. All rights reserved.