public final class ClientConnection extends Object
Constructor and Description |
---|
ClientConnection(String jobIdentifier,
JobStatusHandler jobStatusHandler) |
Modifier and Type | Method and Description |
---|---|
void |
send(ReefServiceProtos.JobStatusProto status)
Send the given JobStatus to the client.
|
void |
sendMessage(byte[] message)
Send the given byte[] as a message to the client.
|
@Inject public ClientConnection(String jobIdentifier, JobStatusHandler jobStatusHandler)
public void send(ReefServiceProtos.JobStatusProto status)
status
- public void sendMessage(byte[] message)
message
- Copyright © 2017 The Apache Software Foundation. All rights reserved.