Examples of CoapMessageDecoder

de.uniluebeck.itm.ncoap.communication.codec.CoapMessageDecoder

A {@link CoapMessageDecoder} de-serializes inbound messages. Please note the following:

If the inbound message is a {@link CoapResponse} then malformed or unknown options are silentlyignored and the {@link CoapResponse} is further processed without these options.
If the inbound message is a {@link CoapRequest}, then malformed or unsupported, i.e. unknown non-critical options are silently ignored but critical options lead to an immediate {@link CoapResponse} with {@link MessageCode.Name#BAD_OPTION_402} being sent to the remote CoAP endpoints.
Malformed inbound {@link CoapMessage}s with malformed header, e.g. a TKL field that does not correspond to the actual tokens length, lead to an immediate {@link CoapMessage} with {@link MessageType.Name#RST} beingsent to the remote CoAP endpoints.
For inbound {@link CoapMessage}s with {@link MessageCode.Name#EMPTY} only the header, i.e. the first 4bytes are decoded and further processed. Any following bytes contained in the same encoded message are ignored.

@author Oliver Kleine

    public ClientChannelPipelineFactory(ScheduledExecutorService executor, TokenFactory tokenFactory){


        addChannelHandler(EXECUTION_HANDLER, new ExecutionHandler(executor));


        addChannelHandler(ENCODER, new CoapMessageEncoder());
        addChannelHandler(DECODER, new CoapMessageDecoder());


        addChannelHandler(OUTBOUND_RELIABILITY_HANDLER, new OutboundReliabilityHandler(executor));
        addChannelHandler(CLIENT_OBSERVATION_HANDLER, new ClientObservationHandler());
        addChannelHandler(CLIENT_CALLBACK_MANAGER, new ClientCallbackManager(executor, tokenFactory));
    }

    public ServerChannelPipelineFactory(ScheduledExecutorService executor, NotFoundHandler notFoundHandler){


        addChannelHandler(EXECUTION_HANDLER, new ExecutionHandler(executor));


        addChannelHandler(ENCODER, new CoapMessageEncoder());
        addChannelHandler(DECODER, new CoapMessageDecoder());


        addChannelHandler(OUTBOUND_RELIABILITY_HANDLER, new OutboundReliabilityHandler(executor));
        addChannelHandler(INBOUND_RELIABILITY_HANDLER, new InboundReliabilityHandler(executor));


        addChannelHandler(WEBSERVICE_MANAGER, new WebserviceManager(notFoundHandler, executor));


            @Override
            public ChannelPipeline getPipeline() throws Exception {
                ChannelPipeline pipeline = Channels.pipeline();
                pipeline.addLast("Encoder", new CoapMessageEncoder());
                pipeline.addLast("Decoder", new CoapMessageDecoder());
                pipeline.addLast("CoAP Endpoint", DummyEndpoint.this );
                return pipeline;
            }
        });

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.

Examples of CoapMessageDecoder

Examples of de.uniluebeck.itm.ncoap.communication.codec.CoapMessageDecoder

Examples of de.uniluebeck.itm.ncoap.communication.codec.CoapMessageDecoder

Examples of de.uniluebeck.itm.ncoap.communication.codec.CoapMessageDecoder