Examples of ProtocolHandler

com.sun.enterprise.web.portunif.ProtocolHandler
Once a TCP protocol has been found by a ProtocolFinder @author Jeanfrancois Arcand
com.yz.net.ProtocolHandler

协议处理器，使用者通过实现此接口来解析从网络收到字节数据，并把数据转换成内存中的
消息模形

@author 胡玮@ritsky
javax.servlet.http.ProtocolHandler
org.adbcj.postgresql.codec.ProtocolHandler
@author Mike Heath
org.apache.coyote.ProtocolHandler
Abstract the protocol implementation, including threading, etc. Processor is single threaded and specific to stream-based protocols, will not fit Jk protocols like JNI. This is the main interface to be implemented by a coyoute connector. Adapter is the main interface to be impleneted by a coyote servlet container. @author Remy Maucherat @author Costin Manolache @see Adapter
org.apache.james.protocols.api.handler.ProtocolHandler
Just the base interface for all kind of "protocol" handlers. Every of them should implement this interface
org.apache.oodt.cas.pushpull.protocol.ProtocolHandler
This class is responsible for creating the appropriate Protocol for the given RemoteSites. The boolean argument 'allowReuse' allows for one unique protocol for each URL. That is, if allowReuse is set to true, then if no Protocol has been created for the current site, the Protocol created will be saved and then returned for any later called with allowReuse equals true. This is to allow for the same Protocol object to be used by several classes. The Protocol class has been synchronized so this is thread-safe. If you set 'allowReuse' to false then a new Protocol object will be created and returned.

@author bfoster
org.apache.qpid.amqp_1_0.codec.ProtocolHandler
org.exist.debuggee.dbgp.ProtocolHandler
@author Dmitriy Shabanov
org.exist.debugger.dbgp.ProtocolHandler
@author Dmitriy Shabanov
org.hornetq.core.protocol.ProtocolHandler
org.jboss.narayana.txframework.impl.handlers.ProtocolHandler
org.openbel.framework.core.protocol.handler.ProtocolHandler
ProtocolHandler defines an object that understands how to read data from a protocol. The supported protocols by the OpenBEL Framework are:
- http
- https
- file
- ftp
- sftp
@author Anthony Bargnesi {@code }
simple.http.ProtocolHandler

Examples of com.sun.enterprise.web.portunif.ProtocolHandler

     * @param task An implementation of <code>ReadTask</code>
     */
    public void addTask(Task task) {
        // Performance optimization used when a single protocol
        // is supported by this Pipeline.
        ProtocolHandler protocolHandler = null;
        boolean cachedHandler = (mappedProtocols != null) &&
                ((protocolHandler = mappedProtocols.get(task.getSelectionKey())) != null);
        SelectorThread selectorThread = task.getSelectorThread();
        KeepAlivePipeline kap = (selectorThread == null) ? null
                : selectorThread.getKeepAlivePipeline();

View Full Code Here

Examples of com.sun.enterprise.web.portunif.ProtocolHandler

        if (System.getProperty(PROTOCOL_HANDLERS) != null) {
            StringTokenizer st = new StringTokenizer(System.getProperty(
                    PROTOCOL_HANDLERS), ",");
            
            while (st.hasMoreTokens()) {
                ProtocolHandler protocolHandler = (ProtocolHandler) loadInstance(st.nextToken());
                
                if (protocolHandler != null) {
                    String[] protocols = protocolHandler.getProtocols();
                    
                    for (String protocol : protocols) {
                        protocolHandlers.put(protocol, protocolHandler);
                    }
                }

View Full Code Here

Examples of com.sun.enterprise.web.portunif.ProtocolHandler

        // Always add http finder at the end.
        addProtocol(HTTP,pipeline,classLoader);   


        Iterator<String> iterator = supportedHandlers.iterator();
        while(iterator.hasNext()){
            ProtocolHandler handler = 
                    (ProtocolHandler)loadInstance(iterator.next(),classLoader);
            if (handler != null){
                pipeline.addProtocolHandler(handler);
            }
        }

View Full Code Here

Examples of com.yz.net.ProtocolHandler

    MessageProcessTask.addFilter(new FiltrateTask());    //添加任务处理的过滤任务
    
    PlayerManager.getInstance();
    
    service = new IoServerImpl();
    ProtocolHandler protocolGroup = service.buildProtocolGroup(4, new CmNetProtocolHandler(), new CmWapProtocolHandler());
    
    Configure config = new Configure();
    config.setAddress(new InetSocketAddress("127.0.0.1",8899));
    config.setProtocolHandler(protocolGroup);
    config.setIoHandler(new LogicHandler());

View Full Code Here

Examples of com.yz.net.ProtocolHandler

    }
    
  
    int size = handlerList.size();
    for(int i=0; i<size; i++) {
      ProtocolHandler handler = handlerList.get(i);
      if(handler == null) {
        continue;
      }
      
      List<NetMessage> list = handler.onData(data, session);
      if(list != null && list.size() > 0) {
        return list;
      }
    }

View Full Code Here

Examples of com.yz.net.ProtocolHandler

    }
    
    ProtocolGroup group = new ProtocolGroup(prefixByteNum);
    int len = handlers.length;
    for(int i=0; i<len; i++) {
      ProtocolHandler handler = handlers[i];
      if(handler == null) {
        continue;
      }
      
      group.addHandler(handler);

View Full Code Here

Examples of javax.servlet.http.ProtocolHandler


        // Calls the protocol handler's init method if the request is marked to be upgraded
        if (request instanceof org.apache.catalina.connector.Request) {
            org.apache.catalina.connector.Request req = (org.apache.catalina.connector.Request) request;
            if (req.isUpgrade()) {
                ProtocolHandler handler = req.getProtocolHandler();
                if (handler != null) {
                    handler.init(
                            new WebConnectionImpl(
                            req.getInputStream(),
                            ((org.apache.catalina.connector.Response)req.getResponse()).getOutputStream()));
                } else {
                    log.log(Level.SEVERE, sm.getString("standardPipeline.protocolHandler.required"));

View Full Code Here

Examples of org.adbcj.postgresql.codec.ProtocolHandler

        @Override
        public void operationComplete(ChannelFuture future) throws Exception {
          Channel channel = future.getChannel();
          Connection connection = new Connection(NettyConnectionManager.this, channel, PostgresqlConnectFuture.this);
          ConnectionState state = connection.getConnectionState();
          ProtocolHandler protocolHandler = new ProtocolHandler(NettyConnectionManager.this);


          ChannelPipeline pipeline = channel.getPipeline();
          pipeline.addLast(ENCODER, new Encoder(state));
          pipeline.addLast(DECODER, new Decoder(state));
          pipeline.addLast(QUEUE_HANDLER, new Handler(connection, protocolHandler));


          protocolHandler.connectionOpened(connection);
        }
      });
    }

View Full Code Here

Examples of org.apache.coyote.ProtocolHandler

          }
          if (server != null) {
            Service[] findServices = server.findServices();
            for (Service service : findServices) {
              for (Connector connector : service.findConnectors()) {
                ProtocolHandler protocolHandler = connector.getProtocolHandler();
                if (protocolHandler instanceof Http11Protocol
                    || protocolHandler instanceof Http11AprProtocol
                    || protocolHandler instanceof Http11NioProtocol) {
                  Http11Protocol p = (Http11Protocol) protocolHandler;
                  if (p.getSslImplementationName() == null

View Full Code Here

Examples of org.apache.coyote.ProtocolHandler

    factory.addConnectorCustomizers(
        new TomcatConnectorCustomizer() {


          @Override
          public void customize(Connector connector) {
            ProtocolHandler handler = connector.getProtocolHandler();
            if (handler instanceof AbstractProtocol) {
              AbstractProtocol protocol = (AbstractProtocol) handler;
              protocol.setMaxThreads(maxThreads);
              protocol.setConnectionTimeout(connectionTimeout);
              protocol.setMaxConnections(maxConnections);

View Full Code Here

0 1 2 3 4 5

TOP

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.