org.apache.reef.io.network.impl

Class NSMessageCodec<T>

java.lang.Object

org.apache.reef.io.network.impl.NSMessageCodec<T>

Type Parameters:

T - type

All Implemented Interfaces:

Codec<NSMessage<T>>, Decoder<NSMessage<T>>, Encoder<NSMessage<T>>

public class NSMessageCodec<T>
extends Object
implements Codec<NSMessage<T>>

Network service message codec.

Constructor Summary

Constructors

Constructor and Description
NSMessageCodec(Codec<T> codec, IdentifierFactory factory) Constructs a network service message codec.

Method Summary

Methods

Modifier and Type	Method and Description
NSMessage<T>	decode(byte[] buf) Decodes a network service message from bytes.
byte[]	encode(NSMessage<T> obj) Encodes a network service message to bytes.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NSMessageCodec

public NSMessageCodec(Codec<T> codec,
              IdentifierFactory factory)

Constructs a network service message codec.

Parameters:

codec - a codec

factory - an identifier factory

Method Detail

encode

public byte[] encode(NSMessage<T> obj)

Encodes a network service message to bytes.

Specified by:

encode in interface Encoder<NSMessage<T>>

Parameters:

obj - a message

Returns:

bytes

decode

public NSMessage<T> decode(byte[] buf)

Decodes a network service message from bytes.

Specified by:

decode in interface Decoder<NSMessage<T>>

Parameters:

buf - bytes

Returns:

a message