org.teiid.transport
Class PgFrontendProtocol

java.lang.Object
  org.jboss.netty.channel.SimpleChannelUpstreamHandler
      org.jboss.netty.handler.codec.frame.FrameDecoder
          org.teiid.transport.PgFrontendProtocol

All Implemented Interfaces:

org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler

@ChannelPipelineCoverage(value="one")
public class PgFrontendProtocol
extends org.jboss.netty.handler.codec.frame.FrameDecoder

Represents the messages going from PG ODBC Client --> back end Server Some parts of this code is taken from H2's implementation of ODBC

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler

org.jboss.netty.channel.ChannelHandler.Sharable

Constructor Summary

PgFrontendProtocol(int maxObjectSize)

Method Summary

protected java.lang.Object

decode(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.Channel channel, org.jboss.netty.buffer.ChannelBuffer buffer)

Methods inherited from class org.jboss.netty.handler.codec.frame.FrameDecoder

channelClosed, channelDisconnected, decodeLast, exceptionCaught, messageReceived

Methods inherited from class org.jboss.netty.channel.SimpleChannelUpstreamHandler

channelBound, channelConnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, handleUpstream, writeComplete

Methods inherited from class java.lang.Object

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

Constructor Detail

PgFrontendProtocol

public PgFrontendProtocol(int maxObjectSize)

Method Detail

decode

protected java.lang.Object decode(org.jboss.netty.channel.ChannelHandlerContext ctx,
                                  org.jboss.netty.channel.Channel channel,
                                  org.jboss.netty.buffer.ChannelBuffer buffer)
                           throws java.lang.Exception

Specified by:

decode in class org.jboss.netty.handler.codec.frame.FrameDecoder

Throws:

java.lang.Exception