@Override
    public void onReceiveMessages(MetaqMessage<Trade> msg) {
        if (msg.getBody() == null) {
            throw new RuntimeException();
        }
        this.counter.incrementAndGet();
    }
Process trade messages listener.

@author dennis
metamorphosis-integration-test/src/test/java/com/taobao/meta/test/spring/TradeMessageListener.java