thanks for your reply.

But I still don't get the exception  and although logging has been enabled
already.

Some wonder...

Something was wrong ? My code was followings :


public class ClientProxy {

        // log
        private static final Logger log =
LoggerFactory.getLogger(ClientProxy.class);
        // ssl support
        private static final boolean sslSupport = Constants.isSSLEnable();
        // compress support
        private static final boolean compressSupport =
Constants.isCompressEnable();
        
        private ClientMessage message;

        
        public ClientProxy(ClientMessage message){
                this.message = message;
        }
        
        /**
         *
         */
        public void start() throws Exception{
                
                SocketConnector connector = new SocketConnector();
                IoServiceConfig config = connector.getDefaultConfig();
                
                DefaultIoFilterChainBuilder filterChainBuilder = 
config.getFilterChain();
                
                //add protocol codec filter
                filterChainBuilder.addLast("codec", new ProtocolCodecFilter(
                                new MonitorServerCodecFactory(true)));
                
                //compress support,
                if (compressSupport) {
                        addCompressSupport(filterChainBuilder);
                }       
                        
                //ssl support
                if (sslSupport){
                        addSSLSupport(filterChainBuilder);
                }
                
                
                //log filter
                addLogger(filterChainBuilder);
                
                //connect               
                ConnectFuture future = connector.connect(new
InetSocketAddress(Constants.getServerIP(), Constants.getServerPort()),
                                new ClientSessionHandler(message));             
                
                future.join();
                
        }
        
        
        /**
         * add compress filter 
         * @param chain
         */
        private static void addCompressSupport(DefaultIoFilterChainBuilder 
chain)
throws Exception{
                
                CompressionFilter filter = new CompressionFilter(
                                CompressionFilter.COMPRESSION_MAX);
                chain.addFirst("compress", filter);
                
                log.info("Compress On");
        }

        /**
         * add ssl filter
         * @param chain
         * @throws Exception
         */
        private static void addSSLSupport(DefaultIoFilterChainBuilder chain)
                        throws Exception {              
                
                SSLFilter sslFilter = new
SSLFilter(BogusSSLContextFactory.getInstance(false));
                sslFilter.setUseClientMode(true);
                chain.addFirst("sslFilter", sslFilter);
                
                log.info("SSL ON");
        }

        /**
         * add log filter
         * @param chain
         * @throws Exception
         */
        private static void addLogger(DefaultIoFilterChainBuilder chain)
                        throws Exception {
                
                chain.addLast("logger", new LoggingFilter());
                
                log.info("Logging ON");         
        }
        
        
        
}




-- 
View this message in context: 
http://www.nabble.com/jzib.jar----exception-not-threw-while-using-CompressionFilter-tf4611738s16868.html#a13209818
Sent from the Apache MINA Support Forum mailing list archive at Nabble.com.

Reply via email to