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