Examples of TradeResponse

org.springframework.amqp.rabbit.stocks.domain.TradeResponse
Simple trade request 'data' object. No functionality in this 'domain' class. @author Mark Pollack

Examples of org.springframework.amqp.rabbit.stocks.domain.TradeResponse

  private static Log log = LogFactory.getLog(ExecutionVenueServiceStub.class);
  
  private Random random = new Random();
  
  public TradeResponse executeTradeRequest(TradeRequest request) {
    TradeResponse response = new TradeResponse();
    response.setAccountName(request.getAccountName());
    response.setOrderType(request.getOrderType());
    response.setPrice(calculatePrice(request.getTicker(), request.getQuantity(), request.getOrderType(), request.getPrice(), request.getUserName()));
    response.setQuantity(request.getQuantity());
    response.setTicker(request.getTicker());
    response.setRequestId(request.getId());
    response.setConfirmationNumber(UUID.randomUUID().toString());
    
    
    try {
      log.info("Sleeping 2 seconds to simulate processing..");
      Thread.sleep(2000);

View Full Code Here

Examples of org.springframework.amqp.rabbit.stocks.domain.TradeResponse

    String key = response.getRequestId();
    responses.putIfAbsent(key, response);
    Collection<TradeResponse> queue = new ArrayList<TradeResponse>(responses.values());
    long timestamp = System.currentTimeMillis() - timeout;
    for (Iterator<TradeResponse> iterator = queue.iterator(); iterator.hasNext();) {
      TradeResponse tradeResponse = iterator.next();
      if (tradeResponse.getTimestamp() < timestamp) {
        responses.remove(tradeResponse.getRequestId());
      }
    }
  }

View Full Code Here

Examples of org.springframework.amqp.rabbit.stocks.domain.TradeResponse

  }


  @RequestMapping(value = "/trade", method = RequestMethod.GET)
  @ResponseBody
  public TradeResponse response(@RequestParam String requestId) {
    TradeResponse result = responses.get(requestId);
    return result;
  }

View Full Code Here

Examples of org.springframework.amqp.rabbit.stocks.domain.TradeResponse

    this.tradingService = tradingService;
  }


  public TradeResponse handleMessage(TradeRequest tradeRequest)
  {
        TradeResponse tradeResponse;
        List<?> errors = new ArrayList<Object>();
        if (creditCheckService.canExecute(tradeRequest, errors))
        {
            tradeResponse = executionVenueService.executeTradeRequest(tradeRequest);
        }
        else
        {
            tradeResponse = new TradeResponse();
            tradeResponse.setError(true);
            tradeResponse.setErrorMessage(StringUtils.arrayToCommaDelimitedString(errors.toArray()));
            
        }
        tradingService.processTrade(tradeRequest, tradeResponse);
        return tradeResponse;
  }

View Full Code Here

TOP

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.