exchanges.put(exchange.getExchangeId(), exchange); cont.resume();
synchronized (cont) { if (log.isDebugEnabled()) { log.debug("Resuming continuation for exchange: " + exchange.getExchangeId()); } exchanges.put(exchange.getExchangeId(), exchange); cont.resume(); }
    public void process(MessageExchange exchange) throws Exception {        Continuation cont = (Continuation) locks.remove(exchange.getExchangeId());        if (cont != null) {            exchanges.put(exchange.getExchangeId(), exchange);            cont.resume();        } else {            throw new IllegalStateException("Exchange not found");        }    }