com.continuent.tungsten.replicator.thl.serializer
Class ProtobufSerializer

java.lang.Object
  com.continuent.tungsten.replicator.thl.serializer.ProtobufSerializer

All Implemented Interfaces:

Serializer

public class ProtobufSerializer
extends java.lang.Object
implements Serializer

Version:

1.0

Author:

Stephane Giron

Constructor Summary

ProtobufSerializer()

Method Summary

THLEvent	deserializeEvent(java.io.InputStream inStream)
TungstenProtos.Header	deserializeHeader(java.io.InputStream is)
void	serializeEvent(THLEvent thlEvent, java.io.OutputStream outStream)
void	serializeHeader(THLEvent event, java.io.OutputStream outStream)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtobufSerializer

public ProtobufSerializer()

Method Detail

deserializeEvent

public THLEvent deserializeEvent(java.io.InputStream inStream)
                          throws java.io.IOException

Specified by:

deserializeEvent in interface Serializer

Throws:

java.io.IOException

See Also:

Serializer.deserializeEvent(java.io.InputStream)

serializeEvent

public void serializeEvent(THLEvent thlEvent,
                           java.io.OutputStream outStream)
                    throws java.io.IOException

Specified by:

serializeEvent in interface Serializer

Throws:

java.io.IOException

See Also:

Serializer.serializeEvent(com.continuent.tungsten.replicator.thl.THLEvent, java.io.OutputStream)

serializeHeader

public void serializeHeader(THLEvent event,
                            java.io.OutputStream outStream)
                     throws java.io.IOException

Throws:

java.io.IOException

deserializeHeader

public TungstenProtos.Header deserializeHeader(java.io.InputStream is)
                                        throws java.io.IOException

Throws:

java.io.IOException