Package com.google.gwt.http.client

Examples of com.google.gwt.http.client.RequestBuilder.sendRequest()


    public void doGet(String url, RequestCallback callback) {
      RequestBuilder builder = new RequestBuilder(RequestBuilder.GET, url);
      responseState = State.COMPLETED;

      try {
         Request response = builder.sendRequest(null, callback);
      } catch (RequestException e) {
         responseState = State.ERROR;
         errorMessage = e.getMessage();
      }
    }
View Full Code Here


    final RxInfo rxInfo = new RxInfo(System.currentTimeMillis(), waitChannel);

    try {
      // LogUtil.log("[bus] TX: " + payload);
      final Request request = builder.sendRequest(payload, new RequestCallback() {
        @Override
        public void onResponseReceived(final Request request, final Response response) {
          if (!waitChannel) {
            measuredLatency = (int) (System.currentTimeMillis() - latencyTime);
          }
View Full Code Here

                public void onCancel() {

                }
            });

            rb.sendRequest(requestJSO, new RequestCallback(){
                @Override
                public void onResponseReceived(Request request, Response response) {
                    //System.out.println("response=");
                    //System.out.println(response.getText());
                    if(200 != response.getStatusCode()) {
View Full Code Here

    final RxInfo rxInfo = new RxInfo(System.currentTimeMillis(), waitChannel);

    try {
      // LogUtil.log("[bus] TX: " + payload);
      final Request request = builder.sendRequest(payload, new RequestCallback() {
        @Override
        public void onResponseReceived(final Request request, final Response response) {
          if (!waitChannel) {
            measuredLatency = (int) (System.currentTimeMillis() - latencyTime);
          }
View Full Code Here

    final RxInfo rxInfo = new RxInfo(System.currentTimeMillis(), waitChannel);

    try {
      // LogUtil.log("[bus] TX: " + payload);
      final Request request = builder.sendRequest(payload, new RequestCallback() {
        @Override
        public void onResponseReceived(final Request request, final Response response) {
          if (!waitChannel) {
            measuredLatency = (int) (System.currentTimeMillis() - latencyTime);
          }
View Full Code Here

    public static void send(final String httpBase, final String request, final ConnectorCallback listener)
      throws ConnectorException {
  Log.debug("GWT CONNECTOR SEND: " + request);
  final RequestBuilder builder = new RequestBuilder(RequestBuilder.POST, httpBase);
  try {
      builder.sendRequest(request, new RequestCallback() {
    public void onError(final Request arg0, final Throwable throwable) {
        Log.debug("GWT CONNECTOR ERROR: " + throwable);
        listener.onError(request, throwable);
    }
View Full Code Here

    }
    private JsonFile generateJsonFile(DataResource dataRes){
      final JsonFile json=new JsonFile(dataRes.getSafeUri().asString());
      RequestBuilder reqBuilder = new RequestBuilder(RequestBuilder.GET, json.getUrl());
      try {
        reqBuilder.sendRequest(null, new RequestCallback(){

          @Override
          public void onResponseReceived(Request request,Response response) {
            json.set(response.getText());
            assetOnLoad(json);
View Full Code Here

      try {
        builder.setTimeoutMillis(2000);

        markerRequestSentAt = System.currentTimeMillis();

        builder.sendRequest(null, new RequestCallback() {
          public void onError(Request request, Throwable e) {
            if (e instanceof RequestTimeoutException) {
              log(1,
                  "Timeout fetching marker data: "
                      + e.getMessage());
View Full Code Here

                    uri);
            // TODO enable timeout
            // rb.setTimeoutMillis(timeoutMillis);
            rb.setHeader("Content-Type", "text/plain;charset=utf-8");
            try {
                rb.sendRequest(rd, new RequestCallback() {
                    public void onError(Request request, Throwable exception) {
                        showCommunicationError(exception.getMessage());
                        endRequest();
                        if (!applicationRunning) {
                            // start failed, let's try to start the next app
View Full Code Here

              " \"PriorityProcessing\":\"1\"}";

      RequestBuilder initialRequest = getSendBuilder();
      initialRequest.setHeader("phase", "connection");

      initialRequest.sendRequest(initialMessage, new RequestCallback() {
        @Override
        public void onResponseReceived(Request request, Response response) {
          try {
            LogUtil.log("received response from initial handshake.");
            procIncomingPayload(response);
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.