@Override
    public void onReceiveMessages(MetaqMessage<Trade> msg) {
        Trade trade = msg.getBody();
        System.out.println("receive trade message:" + trade);
    }
Process trade messages listener.

@author dennis
metamorphosis-example/src/main/java/com/taobao/metamorphosis/example/spring/TradeMessageListener.java