Examples of org.glassfish.grizzly.filterchain.TransportFilter

Package org.glassfish.grizzly.filterchain

Examples of org.glassfish.grizzly.filterchain.TransportFilter

org.glassfish.grizzly.filterchain.TransportFilter
Transport {@link Filter} implementation, which should work with any{@link Transport}. This {@link Filter} tries to delegate I/O event processingto the {@link Transport}'s specific transport {@link Filter}. If {@link Transport} doesn't have own implementation - uses common I/O eventprocessing logic. TransportFilter could be set to work in 2 modes: stream or message. In stream mode, TransportFilter produces/consumes the socket channel directly. In message mode, TransportFilter represents {@link Connection}data as {@link Buffer}, using {@link FilterChainContext#getMessage()}}, {@link FilterChainContext#setMessage(Object)}. For specific {@link Transport}, one mode could be more preferable than another. For example {@link TCPNIOTransport } works just instream mode. {@link UDPNIOTransport }prefers message mode, but could also work in stream mode. @author Alexey Stashok


    private void configureListener(final NetworkListener listener) {
        FilterChain chain = listener.getFilterChain();
        if (chain == null) {
            final FilterChainBuilder builder = FilterChainBuilder.stateless();
            builder.add(new TransportFilter());
            if (listener.isSecure()) {
                SSLEngineConfigurator sslConfig = listener.getSslEngineConfig();
                if (sslConfig == null) {
                    sslConfig = new SSLEngineConfigurator(
                            SSLContextConfigurator.DEFAULT_CONFIG,

View Full Code Here

                                               ClientEngine.TimeoutHandler timeoutHandler,
                                               boolean sharedTransport, Integer sharedTransportTimeout) {
        FilterChainBuilder clientFilterChainBuilder = FilterChainBuilder.stateless();
        Filter sslFilter = null;


        clientFilterChainBuilder.add(new TransportFilter());
        if (serverSSLEngineConfigurator != null || clientSSLEngineConfigurator != null) {
            sslFilter = new SSLFilter(serverSSLEngineConfigurator, clientSSLEngineConfigurator);
            if (proxy) {
                sslFilter = new FilterWrapper(sslFilter);
            }

View Full Code Here

    }


    void initializeTransport(final AsyncHttpClientConfig clientConfig) {


        final FilterChainBuilder secure = FilterChainBuilder.stateless();
        secure.add(new TransportFilter());


        final int timeout = clientConfig.getRequestTimeout();
        if (timeout > 0) {
            int delay = 500;
            //noinspection ConstantConditions

View Full Code Here

        transport.setNIOChannelDistributor(
                new RoundRobinConnectionDistributor(
                transport,
                Boolean.parseBoolean(transportConfig.getDedicatedAcceptorEnabled())));
        
        filterChainBuilder.add(new TransportFilter());
    }

View Full Code Here

        transport.setNIOChannelDistributor(
                new RoundRobinConnectionDistributor(
                transport,
                Boolean.parseBoolean(transportConfig.getDedicatedAcceptorEnabled())));
        
        filterChainBuilder.add(new TransportFilter());
    }

View Full Code Here

        transport.setNIOChannelDistributor(
                new RoundRobinConnectionDistributor(
                transport,
                Boolean.parseBoolean(transportConfig.getDedicatedAcceptorEnabled())));
        
        filterChainBuilder.add(new TransportFilter());
    }

View Full Code Here

0 1

TOP

Related Classes of org.glassfish.grizzly.filterchain.TransportFilter

com.alibaba.dubbo.remoting.transport.grizzly.GrizzlyClient

com.alibaba.dubbo.remoting.transport.grizzly.GrizzlyServer

com.tinkerpop.rexster.client.RexProClientConnection

com.tinkerpop.rexster.client.RexsterClientFactory

com.tinkerpop.rexster.server.RexProRexsterServer

org.asynchttpclient.providers.grizzly.GrizzlyAsyncHttpProvider

org.glassfish.grizzly.config.GenericGrizzlyListener

org.glassfish.grizzly.http.server.HttpServer

org.glassfish.tyrus.container.grizzly.client.GrizzlyClientSocket

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.