     import org.postgresql.febe.message.NoData;
     import org.postgresql.febe.message.NoticeResponse;
     import org.postgresql.febe.message.ParameterStatus;
+    import org.postgresql.febe.message.ParseComplete;
     import org.postgresql.febe.message.PasswordMessage;
     import org.postgresql.febe.message.Query;
     import org.postgresql.febe.message.ReadyForQuery;

            'n': NoData,
            'N': NoticeResponse,
            'S': ParameterStatus,
            'Z': ReadyForQuery,
            'T': RowDescription
        }


        private var _dispatcher:EventDispatcher;

        public function MessageBroker(stream:IDataStream) {
            _dataStream = stream;
            _dataStream.addEventListener(SocketDataStream.DATA_AVAILABLE, handleSocketData);
