Examples of com.linkedin.r2.message.RequestContext

com.linkedin.r2.message.RequestContext
RequestContext should not be shared across requests. @author Josh Walker @version $Revision: $

                          RequestContext requestContext,
                          Callback<RestResponse> callback)
  {
    final Map<String, String> wireAttrs = new HashMap<String, String>();
    //make a copy of the caller's RequestContext to ensure that we have a unique instance per-request
    _client.restRequest(request, new RequestContext(requestContext), wireAttrs, new TransportCallbackAdapter<RestResponse>(callback));
  }

View Full Code Here

                         RequestContext requestContext,
                         Callback<RpcResponse> callback)
  {
    final Map<String, String> wireAttrs = new HashMap<String, String>();
    //make a copy of the caller's RequestContext to ensure that we have a unique instance per-request
    _client.rpcRequest(request, new RequestContext(requestContext), wireAttrs, new TransportCallbackAdapter<RpcResponse>(callback)
    );
  }

View Full Code Here

    {
      writeToServletError(resp, RestStatus.BAD_REQUEST, e.toString());
      return;
    }


    RequestContext requestContext = readRequestContext(req);


    final AtomicReference<TransportResponse<RestResponse>> result =
        new AtomicReference<TransportResponse<RestResponse>>();
    final CountDownLatch latch = new CountDownLatch(1);

View Full Code Here

   * @param req The HTTP servlet request
   * @return The request context
   */
  protected RequestContext readRequestContext(HttpServletRequest req)
  {
    RequestContext context = new RequestContext();
    context.putLocalAttr(R2Constants.REMOTE_ADDR, req.getRemoteAddr());
    if (req.isSecure())
    {
      // attribute name documented in ServletRequest API:
      // http://docs.oracle.com/javaee/6/api/javax/servlet/ServletRequest.html#getAttribute%28java.lang.String%29
      Object[] certs = (Object[]) req.getAttribute("javax.servlet.request.X509Certificate");
      if (certs != null && certs.length > 0)
      {
        context.putLocalAttr(R2Constants.CLIENT_CERT, certs[0]);
      }
      context.putLocalAttr(R2Constants.IS_SECURE, true);
    }
    else
    {
      context.putLocalAttr(R2Constants.IS_SECURE, false);
    }
    return context;
  }

View Full Code Here

        String expectedErrorMessage =
            "Rest.li protocol version " + clientProtocolVersion + " used by the client is not supported!";
        assertEquals(e.getCause().getMessage(), expectedErrorMessage);
      }
    };
    restLiServer.handleRequest(request, new RequestContext(), callback);
  }

View Full Code Here

   * @param request to send
   * @return response future
   */
  public <T> ResponseFuture<T> sendRequest(Request<T> request)
  {
    return sendRequest(request, new RequestContext());
  }

View Full Code Here

        callback.onSuccess(stat);
        return null;
      }
    });
    EasyMock.replay(statusResource);
    _server.handleRequest(request, new RequestContext(), callback);
  }

View Full Code Here

        EasyMock.verify(statusResource);
        EasyMock.reset(statusResource);
      }
    };


    _server.handleRequest(request, new RequestContext(), callback);
  }

View Full Code Here

   * @param errorHandlingBehavior error handling behavior
   * @return response future
   */
  public <T> ResponseFuture<T> sendRequest(Request<T> request, ErrorHandlingBehavior errorHandlingBehavior)
  {
    return sendRequest(request, new RequestContext(), errorHandlingBehavior);
  }

View Full Code Here

        EasyMock.verify(statusResource);
        EasyMock.reset(statusResource);
      }
    };


    _server.handleRequest(request, new RequestContext(), callback);
  }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of com.linkedin.r2.message.RequestContext

com.example.d2.client.BigDataClientExample

com.example.d2.client.CacheClientExample

com.example.d2.client.EmailClientExample

com.example.d2.client.ExampleD2Client

com.example.d2.client.ProfileClientExample

com.example.fortune.inject.FortunesGuiceServletConfig

com.example.fortune.RestLiFortunesClient

com.linkedin.d2.balancer.clients.DynamicClientTest

com.linkedin.d2.balancer.clients.RewriteClientTest

com.linkedin.d2.balancer.clients.TrackerClientTest

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.