blob: 738b8a717f6f8c4ed405d8c7bb9eccdd209bb69b [file]
#pragma once
#include "ReceiveMessageResult.h"
#include "rocketmq/AsyncCallback.h"
ROCKETMQ_NAMESPACE_BEGIN
class ReceiveMessageCallback : public AsyncCallback {
public:
virtual ~ReceiveMessageCallback() = default;
virtual void onSuccess(ReceiveMessageResult& result) = 0;
virtual void onException(MQException& e) = 0;
};
ROCKETMQ_NAMESPACE_END