Package org.apache.mina.core.filterchain

Examples of org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder

379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
        loadKeyStore();

        String sslFilterName = "sslFilter";
        for ( IoFilterChainBuilder chainBuilder : chainBuilders )
        {
            DefaultIoFilterChainBuilder dfcb = ( ( DefaultIoFilterChainBuilder ) chainBuilder );
            if ( dfcb.contains( sslFilterName ) )
            {
                DefaultIoFilterChainBuilder newChain = ( DefaultIoFilterChainBuilder ) LdapsInitializer.init( keyStore,
                    certificatePassword );
                dfcb.replace( sslFilterName, newChain.get( sslFilterName ) );
                newChain = null;
            }
        }

        StartTlsHandler handler = ( StartTlsHandler ) getExtendedOperationHandler( StartTlsHandler.EXTENSION_OID );
View Full Code Here
430
431
432
433
434
435
436
437
438
439
440
                loadKeyStore();
                chain = LdapsInitializer.init( keyStore, certificatePassword );
            }
            else
            {
                chain = new DefaultIoFilterChainBuilder();
            }

            // Inject the codec into the chain
            ( ( DefaultIoFilterChainBuilder ) chain ).addLast( "codec", new ProtocolCodecFilter( this
                .getProtocolCodecFactory() ) );
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
        // add an IoFilter .  This class is responsible for converting the incoming and
        // outgoing raw data to ImageRequest and ImageResponse objects
        acceptor.getFilterChain().addLast("protocol", new ProtocolCodecFilter(new ImageCodecFactory(false)));
       
        // get a reference to the filter chain from the acceptor
        DefaultIoFilterChainBuilder filterChainBuilder = acceptor.getFilterChain();
       
        // add an ExecutorFilter to the filter chain.  The preferred order is to put the executor filter
        // after any protocol filters due to the fact that protocol codecs are generally CPU-bound
        // which is the same as I/O filters.
        filterChainBuilder.addLast("threadPool", new ExecutorFilter(Executors.newCachedThreadPool()));
       
        // set this NioSocketAcceptor's handler to the ImageServerHandler
        acceptor.setHandler(handler);
       
        // Bind to the specified address.  This kicks off the listening for
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
       
        // add the protocolFilter to the acceptor, otherwise no filtering of data will happen
        acceptor.getFilterChain().addLast("protocol", protocolFilter);
       
        // get a reference to the filter chain from the acceptor
        DefaultIoFilterChainBuilder filterChainBuilder = acceptor.getFilterChain();
       
        // add an ExecutorFilter to the filter chain.  The preferred order is to put the executor filter
        // after any protocol filters due to the fact that protocol codecs are generally CPU-bound
        // which is the same as I/O filters.
        filterChainBuilder.addLast("threadPool", new ExecutorFilter(Executors.newCachedThreadPool()));
       
        // set this NioSocketAcceptor's handler to the ImageServerHandler
        acceptor.setHandler(handler);
       
        // Bind to the specified address.  This kicks off the listening for
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
    /** Set this to true if you want to make the server SSL */
    private static final boolean USE_SSL = false;

    public static void main(String[] args) throws Exception {
        NioSocketAcceptor acceptor = new NioSocketAcceptor();
        DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();

        MdcInjectionFilter mdcInjectionFilter = new MdcInjectionFilter();
        chain.addLast("mdc", mdcInjectionFilter);

        // Add SSL filter if SSL is enabled.
        if (USE_SSL) {
            addSSLSupport(chain);
        }

        chain.addLast("codec", new ProtocolCodecFilter(
                new TextLineCodecFactory()));

        addLogger(chain);

        // Bind
View Full Code Here
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
            setTransports( transport );

            DatagramAcceptor acceptor = transport.getAcceptor();

            // Inject the chain
            IoFilterChainBuilder udpChainBuilder = new DefaultIoFilterChainBuilder();

            ( ( DefaultIoFilterChainBuilder ) udpChainBuilder ).addFirst( "codec",
                new ProtocolCodecFilter(
                    KerberosProtocolCodecFactory.getInstance() ) );

            acceptor.setFilterChainBuilder( udpChainBuilder );

            // Inject the protocol handler
            acceptor.setHandler( new KerberosProtocolHandler( this, store ) );

            // Bind to the configured address
            acceptor.bind();
        }
        else
        {
            // Kerberos can use UDP or TCP
            for ( Transport transport : transports )
            {
                IoAcceptor acceptor = transport.getAcceptor();

                // Now, configure the acceptor
                // Inject the chain
                IoFilterChainBuilder chainBuilder = new DefaultIoFilterChainBuilder();

                if ( transport instanceof TcpTransport )
                {
                    // Now, configure the acceptor
                    // Disable the disconnection of the clients on unbind
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
71
    public MemoryMonitor() throws IOException {

        NioDatagramAcceptor acceptor = new NioDatagramAcceptor();
        acceptor.setHandler(new MemoryMonitorHandler(this));

        DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
        chain.addLast("logger", new LoggingFilter());

        DatagramSessionConfig dcfg = acceptor.getSessionConfig();
        dcfg.setReuseAddress(true);

        frame = new JFrame("Memory monitor");
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
    /** Set this to true if you want to make the server SSL */
    private static final boolean USE_SSL = false;

    public static void main(String[] args) throws Exception {
        SocketAcceptor acceptor = new NioSocketAcceptor();
        DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
       
        // Add SSL filter if SSL is enabled.
        if (USE_SSL) {
            addSSLSupport(chain);
        }
View Full Code Here
222
223
224
225
226
227
228
229
230
    /**
     * {@inheritDoc}
     */
    public final void setFilterChainBuilder(IoFilterChainBuilder builder) {
        if (builder == null) {
            builder = new DefaultIoFilterChainBuilder();
        }
        filterChainBuilder = builder;
    }
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
91
    public void start() throws IOException
    {
        IoHandler ntpProtocolHandler = new NtpProtocolHandler();

        // Create the chain for the NTP server
        DefaultIoFilterChainBuilder ntpChain = new DefaultIoFilterChainBuilder();
        ntpChain.addLast( "codec", new ProtocolCodecFilter( NtpProtocolCodecFactory.getInstance() ) );

        if ( ( transports == null ) || ( transports.size() == 0 ) )
        {
            // Default to UDP with port 123
            // We have to create a DatagramAcceptor
View Full Code Here
TOP

Related Classes of org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder

  • asia.stampy.client.mina.ClientMinaMessageGateway
  • asia.stampy.server.mina.ServerMinaMessageGateway
  • devutilsplugin.utils.SocketServer
  • org.adbcj.mysql.mina.MysqlConnectionManager
  • org.adbcj.postgresql.mina.MinaConnectionManager
  • org.apache.directory.server.kerberos.kdc.KdcServer
  • org.apache.directory.server.ldap.handlers.ssl.LdapsInitializer
  • org.apache.directory.server.ldap.LdapServer
  • org.apache.directory.server.ntp.NtpServer
  • org.apache.mina.core.DefaultIoFilterChainBuilderTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.