public class RemoteSenderStage extends Object implements Stage
Constructor and Description |
---|
RemoteSenderStage(Encoder encoder,
Transport transport,
int numThreads)
Constructs a remote sender stage.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the stage.
|
<T> EventHandler<RemoteEvent<T>> |
getHandler()
Returns a new remote sender event handler.
|
public RemoteSenderStage(Encoder encoder, Transport transport, int numThreads)
encoder
- the encoder of the eventtransport
- the transport to send eventsnumThreads
- the number of threadspublic <T> EventHandler<RemoteEvent<T>> getHandler()
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2017 The Apache Software Foundation. All rights reserved.