edu.iu.dsc.tws.api.comms.packing

Interface MessageSerializer

All Known Implementing Classes:

BaseSerializer, DataSerializer, FixedSchemaDataSerializer, FixedSchemaKeyedDataSerializer, KeyedDataSerializer

public interface MessageSerializer

Method Summary

Modifier and Type	Method and Description
ChannelMessage	build(java.lang.Object message, java.lang.Object partialBuildObject) This method will be called repeatedly until the message is fully built
void	init(Config cfg, java.util.Queue<DataBuffer> sendBuffs) Initialize the serializer, it should use the sendBuffs queue to pick a network buffer

Method Detail

init

void init(Config cfg,
          java.util.Queue<DataBuffer> sendBuffs)

Initialize the serializer, it should use the sendBuffs queue to pick a network buffer

Parameters:

cfg - configuration

sendBuffs - the send buffer qeue

build

ChannelMessage build(java.lang.Object message,
                     java.lang.Object partialBuildObject)

This method will be called repeatedly until the message is fully built

Parameters:

message - message to serialize

partialBuildObject - the out message to serialize

Returns:

a channel message