Package com.app55.message

Examples of com.app55.message.Message


    return request;
  }

  public UserUpdateRequest updateUser(User user)
  {
    UserUpdateRequest request = new UserUpdateRequest(user);
    request.setGateway(this);
    return request;
  }
View Full Code Here


  private String    apiKey;
  private String    apiSecret;

  public Gateway(Environment environment, String apiKey, String apiSecret)
  {
    this(environment, apiKey, apiSecret, new DefaultHttpAdapter());
  }
View Full Code Here

  private String    apiKey;
  private String    apiSecret;

  public Gateway(Environment environment, String apiKey, String apiSecret)
  {
    this(environment, apiKey, apiSecret, new DefaultHttpAdapter());
  }
View Full Code Here

      String qs = fetchQueryString();
      byte[] data = fetchData(qs);
      String url = fetchUrl(qs);
      String authString = fetchAuthString();
     
      getGateway().getHttpAdapter().onSendRequest(data, url, getHttpMethod(), authString, new HttpListener() {

        @Override
        public void onResponse(HttpResponse response)
        {
          T r = processRequest(response);
View Full Code Here

      String qs = fetchQueryString();
      byte[] data = fetchData(qs);
      String url = fetchUrl(qs);
      String authString = fetchAuthString();

      getGateway().getHttpAdapter().onSendRequest(data, url, getHttpMethod(), authString, new HttpListener() {

        @Override
        public void onResponse(HttpResponse response)
        {
          T r = processRequest(response);
View Full Code Here

      String qs = fetchQueryString();
      byte[] data = fetchData(qs);
      String url = fetchUrl(qs);
      String authString = fetchAuthString();
     
      HttpResponse response = getGateway().getHttpAdapter().onSendRequest(data, url, getHttpMethod(), authString);
      return processRequest(response);
    }
    catch (ApiException a)
    {
      // This just gets rethrown
View Full Code Here

      String qs = fetchQueryString();
      byte[] data = fetchData(qs);
      String url = fetchUrl("");
      String authString = fetchAuthString();
     
      HttpResponse response = getGateway().getHttpAdapter().onSendRequest(data, url, getHttpMethod(), authString, headers);
      return processRequest(response);
    }
    catch (ApiException a)
    {
      // This just gets rethrown
View Full Code Here

      String qs = fetchQueryString();
      byte[] data = fetchData(qs);
      String url = fetchUrl(qs);
      String authString = fetchAuthString();

      HttpResponse response = getGateway().getHttpAdapter().onSendRequest(data, url, getHttpMethod(), authString);
      return processRequest(response);
    }
    catch (ApiException a)
    {
      // This just gets rethrown
View Full Code Here

  {
    final MessageBuilder<?> builder = new RpcRequestBuilder(URI.create("test"))
            .setEntity(new byte[] {1,2,3,4})
            .build()
            .builder();
    final Message req = builder
            .setEntity(new byte[] {5,6,7,8})
            .build();

    Assert.assertEquals(new byte[] {5,6,7,8}, req.getEntity().copyBytes());
    Assert.assertTrue(req instanceof RpcRequest);
    Assert.assertEquals(URI.create("test"), ((RpcRequest)req).getURI());
  }
View Full Code Here

    final MessageBuilder<?> builder = new RpcResponseBuilder()
              .setEntity(new byte[] {1,2,3,4})
              .build()
              .builder();

    final Message res = builder
              .setEntity(new byte[] {5,6,7,8})
              .build();

    Assert.assertEquals(new byte[] {5,6,7,8}, res.getEntity().copyBytes());
  }
View Full Code Here

TOP

Related Classes of com.app55.message.Message

Copyright © 2018 www.massapicom. 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.