Examples of keepAlive()


Examples of com.google.gwt.junit.remote.BrowserManager.keepAlive()

    for ( int i = 0; i < remoteTokens.length; ++i ) {
      int remoteToken = remoteTokens[ i ];
      BrowserManager mgr = browserManagers[ i ];
      if (remoteToken > 0) {
        try {
          mgr.keepAlive(remoteToken, PING_KEEPALIVE_MS);
        } catch (Exception e) {
          // TODO(tobyr): We're failing on the first exception, rather than
          //  collecting them, but that's probably OK for now.
          shell.getTopLogger().log(TreeLogger.WARN,
              "Unexpected exception keeping remote browser alive", e);
View Full Code Here

Examples of kilim.http.HttpRequest.keepAlive()

                        sendResponse(resp);
                    } else {
                        super.problem(resp, HttpResponse.ST_FORBIDDEN, "Only GET and HEAD accepted");
                    }
                   
                    if (!req.keepAlive())
                        break;
                    break;
                }
            } catch (EOFException e) {
                System.out.println("[" + this.id + "] Connection Terminated");
View Full Code Here

Examples of net.tomp2p.message.Message.keepAlive()

    rconMessage.version(message.version());
    // store the message id in the payload to get the cached message later
    rconMessage.intValue(message.messageId());
    // the message must have set the keepAlive Flag true. If not, the relay
    // peer will close the PeerConnection to the unreachable peer.
    rconMessage.keepAlive(true);
    // making the message ready to send
    PeerAddress recipient = message.recipient().changeAddress(socketAddress.inetAddress())
            .changePorts(socketAddress.tcpPort(), socketAddress.udpPort()).changeRelayed(false);
    rconMessage.recipient(recipient);
    rconMessage.command(RPC.Commands.RCON.getNr());
View Full Code Here

Examples of org.apache.activemq.broker.Locker.keepAlive()

        if (broker.getPersistenceAdapter() instanceof JDBCPersistenceAdapter) {
            JDBCPersistenceAdapter jdbcPersistenceAdapter = (JDBCPersistenceAdapter) broker.getPersistenceAdapter();
            Locker locker = jdbcPersistenceAdapter.getLocker();
            if (locker != null) {
                try {
                    if (!locker.keepAlive()) {
                        hasLock = false;
                    }
                } catch (IOException ignored) {
                }
View Full Code Here

Examples of org.apache.catalina.tribes.transport.MultiPointSender.keepalive()

                for (int i = 0; i < destination.length; i++) cx.addFaultyMember(destination[i], new NullPointerException("Unable to retrieve a sender from the sender pool"));
                throw cx;
            } else {
                sender.sendMessage(destination, msg);
            }
            sender.keepalive();
        }finally {
            if ( sender != null ) returnSender(sender);
        }
    }
View Full Code Here

Examples of org.apache.catalina.tribes.transport.MultiPointSender.keepalive()

                for (int i = 0; i < destination.length; i++) cx.addFaultyMember(destination[i]);
                throw cx;
            } else {
                sender.sendMessage(destination, msg);
            }
            sender.keepalive();
        }finally {
            if ( sender != null ) returnSender(sender);
        }
    }
View Full Code Here

Examples of org.apache.catalina.tribes.transport.MultiPointSender.keepalive()

                for (int i = 0; i < destination.length; i++) cx.addFaultyMember(destination[i], new NullPointerException("Unable to retrieve a sender from the sender pool"));
                throw cx;
            } else {
                sender.sendMessage(destination, msg);
            }
            sender.keepalive();
        }finally {
            if ( sender != null ) returnSender(sender);
        }
    }
View Full Code Here

Examples of org.apache.catalina.tribes.transport.MultiPointSender.keepalive()

                for (int i = 0; i < destination.length; i++) cx.addFaultyMember(destination[i], new NullPointerException("Unable to retrieve a sender from the sender pool"));
                throw cx;
            } else {
                sender.sendMessage(destination, msg);
            }
            sender.keepalive();
        }finally {
            if ( sender != null ) returnSender(sender);
        }
    }
View Full Code Here

Examples of org.apache.http.ConnectionReuseStrategy.keepAlive()

            HttpResponse response = httpexchange.getResponse();
            String method = request.getRequestLine().getMethod();
            int status = response.getStatusLine().getStatusCode();
            if (!(method.equalsIgnoreCase("CONNECT") && status < 300)) {
                ConnectionReuseStrategy connReuseStrategy = handler.getConnectionReuseStrategy();
                if (!connReuseStrategy.keepAlive(response, context)) {
                    conn.close();
                }
            }
        } else {
            conn.close();
View Full Code Here

Examples of org.apache.http.ConnectionReuseStrategy.keepAlive()

                httpexecutor.postProcess(response, httpproc, context);
               
                System.out.println("<< Response: " + response.getStatusLine());
                System.out.println(EntityUtils.toString(response.getEntity()));
                System.out.println("==============");
                if (!connStrategy.keepAlive(response, context)) {
                    conn.close();
                } else {
                    System.out.println("Connection kept alive...");
                }
            }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.