Examples of org.apache.mina.filter.ssl.SslFilter

org.apache.mina.filter.ssl.SslFilter
rt SSLFilter to get ready for handshaking session.getFilterChain().addFirst(sslFilter); // Disable encryption temporarilly. // This attribute will be removed by SSLFilter // inside the Session.write() call below. session.setAttribute(SSLFilter.DISABLE_ENCRYPTION_ONCE, Boolean.TRUE); // Write StartTLSResponse which won't be encrypted. session.write(new MyStartTLSResponse(OK)); // Now DISABLE_ENCRYPTION_ONCE attribute is cleared. assert session.getAttribute(SSLFilter.DISABLE_ENCRYPTION_ONCE) == null; } } @author The Apache MINA Project (dev@mina.apache.org) @version $Rev: 616100 $, $Date: 2008-01-29 07:58:32 +0900 (화, 29 1월 2008) $

  }  


  public SslFilter getSslFilter() throws Exception {
    SSLContext context = getSslContext();
    // create the ssl filter using server mode
    SslFilter sslFilter = new SslFilter(context);
    return sslFilter;
  }

View Full Code Here

    }


    connector = new NioSocketConnector();


    if ( ssl_config != null ) {
      SslFilter ssl_filter = new SslFilter( ssl_config.getSSLContext() );
      ssl_filter.setUseClientMode( ssl_config.isUseClientMode() );
      ssl_filter.setWantClientAuth( ssl_config.isWantClientAuth() );
      ssl_filter.setNeedClientAuth( ssl_config.isNeedClientAuth() );
      ssl_filter.setEnabledCipherSuites( ssl_config.getEnabledCipherSuites() );
      ssl_filter.setEnabledProtocols( ssl_config.getEnabledProtocols() );
      connector.getFilterChain().addLast( "ssl", ssl_filter );
    }


    if ( enable_compression ) {
      connector.getFilterChain().addLast( "compress", new CompressionFilter() );
    }
    connector.getFilterChain().addLast( "intrepid", new ProtocolCodecFilter( codec ) );
//    connector.getFilterChain().addLast( "logger", new LoggingFilter() );
    connector.setHandler( this );


    connector.getSessionConfig().setThroughputCalculationInterval( 1 );


    // Disable Nagle's algorithm
    connector.getSessionConfig().setTcpNoDelay( true );


    // Enable keep alive
    connector.getSessionConfig().setKeepAlive( true );


    // Make sure sockets don't linger
    connector.getSessionConfig().setSoLinger( 0 );


    if ( server_address != null || server_port != null ) {
      if ( server_port == null ) server_port = Integer.valueOf( 0 );


      acceptor = new NioSocketAcceptor();


      if ( ssl_config != null ) {
        SslFilter ssl_filter = new SslFilter( ssl_config.getSSLContext() );
        ssl_filter.setUseClientMode( ssl_config.isUseClientMode() );
        ssl_filter.setWantClientAuth( ssl_config.isWantClientAuth() );
        ssl_filter.setNeedClientAuth( ssl_config.isNeedClientAuth() );
        ssl_filter.setEnabledCipherSuites( ssl_config.getEnabledCipherSuites() );
        ssl_filter.setEnabledProtocols( ssl_config.getEnabledProtocols() );
        acceptor.getFilterChain().addLast( "ssl", ssl_filter );
      }


      if ( enable_compression ) {
        acceptor.getFilterChain().addLast( "compress", new CompressionFilter() );

View Full Code Here

        {
            throw new LdapException( I18n.err( I18n.ERR_683 ), e );
        }


        DefaultIoFilterChainBuilder chain = new DefaultIoFilterChainBuilder();
        SslFilter sslFilter = new SslFilter( sslCtx );
        sslFilter.setWantClientAuth( true );
        chain.addLast( "sslFilter", sslFilter );
        return chain;
    }

View Full Code Here

    public void handleExtendedOperation( LdapSession session, ExtendedRequest<ExtendedResponse> req ) throws Exception
    {
        LOG.info( "Handling StartTLS request." );


        IoFilterChain chain = session.getIoSession().getFilterChain();
        SslFilter sslFilter = ( SslFilter ) chain.get( "sslFilter" );
        if ( sslFilter == null )
        {
            sslFilter = new SslFilter( sslContext );
            chain.addFirst( "sslFilter", sslFilter );
        }
        else
        {
            sslFilter.startSsl( session.getIoSession() );
        }


        ExtendedResponseDecorator<ExtendedResponse> res = new ExtendedResponseDecorator<ExtendedResponse>( 
            LdapApiServiceFactory.getSingleton(), new ExtendedResponseImpl( req.getMessageId() ) );
        LdapResult result = res.getLdapResult();

View Full Code Here

        try
        {
            SSLContext sslContext = SSLContext.getInstance( config.getSslProtocol() );
            sslContext.init( config.getKeyManagers(), config.getTrustManagers(), config.getSecureRandom() );


            SslFilter sslFilter = new SslFilter( sslContext, true );
            sslFilter.setUseClientMode( true );
            sslFilter.setEnabledCipherSuites( config.getEnabledCipherSuites() );


            // for LDAPS
            if ( ldapSession == null )
            {
                connector.getFilterChain().addFirst( SSL_FILTER_KEY, sslFilter );

View Full Code Here

        try
        {
            SSLContext sslContext = SSLContext.getInstance( config.getSslProtocol() );
            sslContext.init( config.getKeyManagers(), config.getTrustManagers(), config.getSecureRandom() );


            SslFilter sslFilter = new SslFilter( sslContext, true );
            sslFilter.setUseClientMode( true );
            sslFilter.setEnabledCipherSuites( config.getEnabledCipherSuites() );


            // for LDAPS
            if ( ldapSession == null )
            {
                connector.getFilterChain().addFirst( SSL_FILTER_KEY, sslFilter );

View Full Code Here

        if (minaLogger) {
            connector.getFilterChain().addLast("logger", new LoggingFilter());
        }
        appendIoFiltersToChain(filters, connector.getFilterChain());
        if (configuration.getSslContextParameters() != null) {
            connector.getFilterChain().addFirst("sslFilter", new SslFilter(configuration.getSslContextParameters().createSSLContext(), configuration.isAutoStartTls()));
        }
        configureCodecFactory("Mina2Producer", connector);
        // set connect timeout to mina in seconds
        connector.setConnectTimeoutMillis(timeout);
    }

View Full Code Here

        return (Date) getAttribute(ATTRIBUTE_LAST_ACCESS_TIME);
    }


    public Certificate[] getClientCertificates() {
        if (getFilterChain().contains(SslFilter.class)) {
            SslFilter sslFilter = (SslFilter) getFilterChain().get(
                    SslFilter.class);


            SSLSession sslSession = sslFilter.getSslSession(this);


            if (sslSession != null) {
                try {
                    return sslSession.getPeerCertificates();
                } catch (SSLPeerUnverifiedException e) {

View Full Code Here


    private void testMessageSentIsCalled(boolean useSSL) throws Exception {
        // Workaround to fix TLS issue : http://java.sun.com/javase/javaseforbusiness/docs/TLSReadme.html
        java.lang.System.setProperty( "sun.security.ssl.allowUnsafeRenegotiation", "true" );


        SslFilter sslFilter = null;
        if (useSSL) {
            sslFilter = new SslFilter(BogusSslContextFactory.getInstance(true));
            acceptor.getFilterChain().addLast("sslFilter", sslFilter);
        }
        acceptor.getFilterChain().addLast(
                "codec",
                new ProtocolCodecFilter(new TextLineCodecFactory(Charset

View Full Code Here


    @Before
    public void setUp() throws Exception {
        super.setUp();
        handler = new EchoConnectorHandler();
        connectorSSLFilter = new SslFilter(BogusSslContextFactory
                .getInstance(false));
        connectorSSLFilter.setUseClientMode(true); // set client mode
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.apache.mina.filter.ssl.SslFilter

com.akdeniz.googleplaycrawler.gsf.MTalkConnector

com.ettrema.ftp.MiltonListener

com.notnoop.apns.internal.MinaAdaptor

com.starlight.intrepid.spi.mina.MINAIntrepidSPI

devutilsplugin.utils.SocketClient

devutilsplugin.utils.SocketServer

org.apache.camel.component.mina2.Mina2Consumer

org.apache.camel.component.mina2.Mina2Producer

org.apache.directory.ldap.client.api.LdapConnection

org.apache.directory.ldap.client.api.LdapNetworkConnection

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.