Examples of ProtocolEncoderException

org.apache.mina.codec.ProtocolEncoderException
ache.org">Apache MINA Project
org.apache.mina.filter.codec.ProtocolEncoderException
An exception that is thrown when {@link ProtocolEncoder}cannot understand or failed to validate the specified message object. @author The Apache Directory Project (mina-dev@directory.apache.org) @version $Rev: 555855 $, $Date: 2007-07-13 12:19:00 +0900 (Fri, 13 Jul 2007) $

Examples of org.apache.mina.codec.ProtocolEncoderException

    @Override
    public void writeTo(INPUT message, ByteBuffer buffer) {
        try {
            buffer.put(prepareBuffer(message));
        } catch (TException e) {
            throw new ProtocolEncoderException(e);
        }
    }

View Full Code Here

Examples of org.apache.mina.codec.ProtocolEncoderException

                byte[] encoded = out.toByteArray();
                encodedMessage = ByteBuffer.wrap(encoded);
                out.close();
            } catch (IOException ioEx) {
                LOG.error("error while marshalling", ioEx);
                throw new ProtocolEncoderException(ioEx.getMessage());
            }
        } else if (message instanceof SpecificRecord) {
            DatumWriter<T> writer = new SpecificDatumWriter<T>(message.getSchema());
            Encoder encoder = EncoderFactory.get().binaryEncoder(out, null);
            try {
                writer.write(message, encoder);
                encoder.flush();
                byte[] encoded = out.toByteArray();
                encodedMessage = ByteBuffer.wrap(encoded);
                out.close();
            } catch (IOException ioEx) {
                LOG.error("error while marshalling", ioEx);
                throw new ProtocolEncoderException(ioEx.getMessage());
            }
        } else {
            LOG.warn("Unknown object type, serialization method not known for {}", message.getClass());
            throw new ProtocolEncoderException(message.getClass() + " cannot be Serialized");
        }


        return encodedMessage != null ? encodedMessage.capacity() : -1;
    }

View Full Code Here

Examples of org.apache.mina.filter.codec.ProtocolEncoderException

        public void encode(IoSession session, Object message,
                ProtocolEncoderOutput out) throws Exception {
            Class<?> type = message.getClass();
            MessageEncoder encoder = findEncoder(type);
            if (encoder == null) {
                throw new ProtocolEncoderException("Unexpected message type: "
                        + type);
            }


            encoder.encode(session, message, out);
        }

View Full Code Here

Examples of org.apache.mina.filter.codec.ProtocolEncoderException

    }


    public void encode(IoSession session, Object message,
            ProtocolEncoderOutput out) throws Exception {
        if (!(message instanceof Message)) {
            throw new ProtocolEncoderException(
                    "This encoder can decode only Netty Messages.");
        }


        for (;;) {
            ByteBuffer buf = ByteBuffer.allocate(8192);

View Full Code Here

Examples of org.apache.mina.filter.codec.ProtocolEncoderException

        public void encode(IoSession session, Object message,
                ProtocolEncoderOutput out) throws Exception {
            Class<?> type = message.getClass();
            MessageEncoder encoder = findEncoder(type);
            if (encoder == null) {
                throw new ProtocolEncoderException("Unexpected message type: "
                        + type);
            }


            encoder.encode(session, message, out);
        }

View Full Code Here

Examples of org.apache.mina.filter.codec.ProtocolEncoderException


    public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception
    {
        if( !( message instanceof Message ) )
        {
            throw new ProtocolEncoderException(
                    "This encoder can decode only Netty Messages." );
        }


        for( ;; )
        {

View Full Code Here

Examples of org.apache.mina.filter.codec.ProtocolEncoderException

        {
            Class type = message.getClass();
            MessageEncoder encoder = findEncoder( type );
            if( encoder == null )
            {
                throw new ProtocolEncoderException( "Unexpected message type: " + type );
            }
            
            encoder.encode( session, message, out );
        }

View Full Code Here

Examples of org.apache.mina.filter.codec.ProtocolEncoderException

        public void encode(IoSession session, Object message,
                ProtocolEncoderOutput out) throws Exception {
            Class type = message.getClass();
            MessageEncoder encoder = findEncoder(type);
            if (encoder == null) {
                throw new ProtocolEncoderException("Unexpected message type: "
                        + type);
            }


            encoder.encode(session, message, out);
        }

View Full Code Here

Examples of org.apache.mina.filter.codec.ProtocolEncoderException


    public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception
    {
        if( !( message instanceof Message ) )
        {
            throw new ProtocolEncoderException(
                    "This encoder can decode only Netty Messages." );
        }


        for( ;; )
        {

View Full Code Here

Examples of org.apache.mina.filter.codec.ProtocolEncoderException

        {
            Class type = message.getClass();
            MessageEncoder encoder = findEncoder( type );
            if( encoder == null )
            {
                throw new ProtocolEncoderException( "Unexpected message type: " + type );
            }
            
            encoder.encode( session, message, out );
        }

View Full Code Here

0 1 2 3

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.