String processCorrelationId = (String)exchange.getProperty(JbiConstants.CORRELATION_ID); if (processCorrelationId != null) { outExchange.setProperty(JbiConstants.CORRELATION_ID, processCorrelationId); }
    public void forwardToInterface(QName name, MessageExchange exchange, NormalizedMessage in) throws MessagingException {        DeliveryChannel channel = getDeliveryChannel();        MessageExchangeFactory factory = channel.createExchangeFactory(name);        InOnly outExchange = factory.createInOnlyExchange();        forwardToExchange(exchange, outExchange, in);    }