/* | |
* Licensed to the Apache Software Foundation (ASF) under one or more | |
* contributor license agreements. See the NOTICE file distributed with | |
* this work for additional information regarding copyright ownership. | |
* The ASF licenses this file to You under the Apache License, Version 2.0 | |
* (the "License"); you may not use this file except in compliance with | |
* the License. You may obtain a copy of the License at | |
* | |
* http://www.apache.org/licenses/LICENSE-2.0 | |
* | |
* Unless required by applicable law or agreed to in writing, software | |
* distributed under the License is distributed on an "AS IS" BASIS, | |
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
* See the License for the specific language governing permissions and | |
* limitations under the License. | |
*/ | |
#ifndef __MQPRODUCER_H__ | |
#define __MQPRODUCER_H__ | |
#include "AsyncCallback.h" | |
#include "MQClient.h" | |
#include "MQMessageQueue.h" | |
#include "MQSelector.h" | |
#include "RocketMQClient.h" | |
#include "SendResult.h" | |
namespace rocketmq { | |
//<!*************************************************************************** | |
class ROCKETMQCLIENT_API MQProducer : public MQClient { | |
public: | |
MQProducer() {} | |
virtual ~MQProducer() {} | |
// if setted bActiveBroker, will search brokers with best service state | |
// firstly, then search brokers that had been sent failed by last time; | |
virtual SendResult send(MQMessage& msg, bool bSelectActiveBroker = false) = 0; | |
virtual SendResult send(MQMessage& msg, const MQMessageQueue& mq) = 0; | |
// strict order msg, if send failed on seleted MessageQueue, throw exception | |
// to up layer | |
virtual SendResult send(MQMessage& msg, MessageQueueSelector* selector, | |
void* arg) = 0; | |
// non-strict order msg, if send failed on seleted MessageQueue, will auto | |
// retry others Broker queues with autoRetryTimes; | |
// if setted bActiveBroker, if send failed on seleted MessageQueue, , and then | |
// search brokers with best service state, lastly will search brokers that had | |
// been sent failed by last time; | |
virtual SendResult send(MQMessage& msg, MessageQueueSelector* selector, | |
void* arg, int autoRetryTimes, | |
bool bActiveBroker = false) = 0; | |
virtual void send(MQMessage& msg, SendCallback* sendCallback, | |
bool bSelectActiveBroker = false) = 0; | |
virtual void send(MQMessage& msg, const MQMessageQueue& mq, | |
SendCallback* sendCallback) = 0; | |
virtual void send(MQMessage& msg, MessageQueueSelector* selector, void* arg, | |
SendCallback* sendCallback) = 0; | |
virtual SendResult send(std::vector<MQMessage>& msgs) = 0; | |
virtual SendResult send(std::vector<MQMessage>& msgs, const MQMessageQueue& mq) = 0; | |
virtual void sendOneway(MQMessage& msg, bool bSelectActiveBroker = false) = 0; | |
virtual void sendOneway(MQMessage& msg, const MQMessageQueue& mq) = 0; | |
virtual void sendOneway(MQMessage& msg, MessageQueueSelector* selector, | |
void* arg) = 0; | |
}; | |
//<!*************************************************************************** | |
} //<!end namespace; | |
#endif |