Examples of sendRequest()


Examples of com.addthis.meshy.service.host.HostSource.sendRequest()

                    } else if (cmd.equals("peer")) {
                        HostSource hostSource = new HostSource(more);
                        for (int i = 4; i < args.length; i++) {
                            hostSource.addPeer(args[i]);
                        }
                        hostSource.sendRequest();
                        hostSource.waitComplete();
                        for (HostNode node : hostSource.getHostList()) {
                            System.out.println(node.uuid + " \t " + node.address);
                        }
                    } else if (cmd.equals("madcat") && args.length > 5) {
View Full Code Here

Examples of com.adito.agent.AgentTunnel.sendRequest()

         
          if (DefaultAgentManager.getInstance().hasActiveAgent(session)) {
          try {
            Request agentRequest = ((ApplicationService) DefaultAgentManager.getInstance().getService(ApplicationService.class)).launchApplication(launchSession);
            AgentTunnel agent = DefaultAgentManager.getInstance().getAgentBySession(launchSession.getSession());
            if (!agent.sendRequest(agentRequest, true, 60000)) {
              throw new ExtensionException(ExtensionException.AGENT_REFUSED_LAUNCH);
            }
            ByteArrayReader baw = new ByteArrayReader(agentRequest.getRequestData());
            try {
              while(true) {
View Full Code Here

Examples of com.adito.agent.AgentTunnel.sendRequest()

    // LogonControllerFactory.getInstance().getSessionInfo(request);
    if (DefaultAgentManager.getInstance().hasActiveAgent(launchSession.getSession())) {
      try {
        Request agentRequest = ((ApplicationService) DefaultAgentManager.getInstance().getService(ApplicationService.class)).launchApplication(launchSession);
        AgentTunnel agent = DefaultAgentManager.getInstance().getAgentBySession(launchSession.getSession());
        if (!agent.sendRequest(agentRequest, true, 60000)) {
          throw new ExtensionException(ExtensionException.AGENT_REFUSED_LAUNCH);
        }
      } catch (ExtensionException ee) {
        throw ee;
      } catch (Exception e) {
View Full Code Here

Examples of com.adito.agent.AgentTunnel.sendRequest()

    SessionInfo session = launchSession.getSession();
    if (DefaultAgentManager.getInstance().hasActiveAgent(session)) {
      try {
        Request agentRequest = ((ApplicationService) DefaultAgentManager.getInstance().getService(ApplicationService.class)).launchApplication(launchSession);
        AgentTunnel agent = DefaultAgentManager.getInstance().getAgentBySession(launchSession.getSession());
        if (!agent.sendRequest(agentRequest, true, 60000)) {
          throw new ExtensionException(ExtensionException.AGENT_REFUSED_LAUNCH);
        }
      } catch (ExtensionException ee) {
        throw ee;
      } catch (Exception e) {
View Full Code Here

Examples of com.adito.agent.AgentTunnel.sendRequest()

        if (agentManager.hasActiveAgent(info) && info.getUser().getPrincipalName().equals(recipient.getRecipientAlias())) {
            try {
                Request request = new Request("agentMessage", msg.toByteArray());
                AgentTunnel tunnel = agentManager.getAgentBySession(info);
                if (tunnel != null) {
                    tunnel.sendRequest(request, false, 0);
                    return true;
                }
            } catch (IOException e) {
                LOG.error("Failed to send message to agent. Did it disconnect before we could send it?", e);
            }
View Full Code Here

Examples of com.alibaba.dubbo.rpc.benchmark.DemoService.sendRequest()

    @SuppressWarnings({ "unchecked", "rawtypes" })
    @Override
    public Object invoke(ServiceFactory serviceFactory) {
        DemoService demoService = (DemoService) serviceFactory.get(DemoService.class);
        return demoService.sendRequest("hello");
    }

}
View Full Code Here

Examples of com.eway.GatewayConnector.sendRequest()

      gwr.setCustomerLastName(billingAddress.getCustLastName());
      gwr.setCustomerPostcode(billingAddress.getCustZipCode());
      gwr.setCVN(creditCardInfo.getCreditCardVerNum());
      gwr.setTotalAmount((int) (orderHeader.getOrderTotal() * 100));
      //gwr.setTotalAmount(1000);
      GatewayResponse response = connector.sendRequest(gwr);
    if (!response.getTrxnStatus()) {
      logger.error("request = Not able to process credit card authorization for " + orderHeader.getCustAddress().getCustFirstName() + " " + orderHeader.getCustAddress().getCustLastName());
      logger.error("response = " + response.getTrxnError());
      paymentMessage = response.getTrxnError();
      throw new AuthorizationException(response.getTrxnError());
View Full Code Here

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

    public void find(int id, ResourceResponseHandler handler) {
        RequestBuilder builder = buildGet(id);
        ResourceResponseCallback requestCallback = new ResourceResponseCallback(factory, handler);
        
        try {
            Request response = builder.sendRequest(null, requestCallback);
        } catch (RequestException e) {
            handler.onError(null, e);
        }
    }
   
View Full Code Here

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

    public void findAll(CollectionResponseHandler handler) {
        RequestBuilder builder = buildGet();
        CollectionResponseCallback requestCallback = new CollectionResponseCallback(factory, handler, parser);
       
        try {
            Request response = builder.sendRequest(null, requestCallback);
        } catch (RequestException e) {
            handler.onError(null, e);
        }
    }
   
View Full Code Here

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

    public void create(Resource resource, ResourceResponseHandler handler) {
        RequestBuilder builder = buildPost();
        ResourceResponseCallback requestCallback = new ResourceCreationResponseCallback(factory, handler);
       
        try {
            Request response = builder.sendRequest(resource.toRepresentation(), requestCallback);
        } catch (RequestException e) {
            handler.onError(null, e);
        }
       
    }
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.