public class GroupCommunicationMessageCodec extends Object implements StreamingCodec<GroupCommunicationMessage>
ReefNetworkGroupCommProtos.GroupCommMessage
.Constructor and Description |
---|
GroupCommunicationMessageCodec() |
Modifier and Type | Method and Description |
---|---|
GroupCommunicationMessage |
decode(byte[] data)
Decodes the given byte array into an object.
|
GroupCommunicationMessage |
decodeFromStream(DataInputStream stream) |
byte[] |
encode(GroupCommunicationMessage msg)
Encodes the given object into a Byte Array.
|
void |
encodeToStream(GroupCommunicationMessage msg,
DataOutputStream stream) |
@Inject public GroupCommunicationMessageCodec()
public GroupCommunicationMessage decode(byte[] data)
Decoder
decode
in interface Decoder<GroupCommunicationMessage>
data
- the data to be decodedpublic GroupCommunicationMessage decodeFromStream(DataInputStream stream)
decodeFromStream
in interface StreamingCodec<GroupCommunicationMessage>
public byte[] encode(GroupCommunicationMessage msg)
Encoder
encode
in interface Encoder<GroupCommunicationMessage>
msg
- an object to be encodedpublic void encodeToStream(GroupCommunicationMessage msg, DataOutputStream stream)
encodeToStream
in interface StreamingCodec<GroupCommunicationMessage>
Copyright © 2017 The Apache Software Foundation. All rights reserved.