package com.primeton.dgs.kernel.core.message;

/**
 * <pre>
 *
 * Created by zhaopx.
 * User: zhaopx
 * Date: 2019/11/11
 * Time: 13:55
 *
 * </pre>
 *
 * @author zhaopx
 */
public interface MessageConsumer {





    /**
     * 接收到消息的处理
     * @param topic
     * @param message
     */
    public void onMessage(String topic, Object message);
}