exchanges.put(exchange.getExchangeId(), exchange);
    public void process(MessageExchange exchange) throws Exception {        Continuation cont = (Continuation) locks.remove(exchange.getExchangeId());        if (cont != null) {            cont.resume();        } else {            throw new IllegalStateException("Exchange not found");        }    }