Skip to content

Commit 6171577

Browse files
authored
[ISSUE #291] Use separate factory for trace producer of push consumer.
fix(trace): use a separate factory for trace producer of push consumer.
1 parent 2da0647 commit 6171577

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/consumer/DefaultMQPushConsumerImpl.cpp

+3-3
Original file line numberDiff line numberDiff line change
@@ -1100,7 +1100,7 @@ bool DefaultMQPushConsumerImpl::dealWithMessageTrace() {
11001100
void DefaultMQPushConsumerImpl::createMessageTraceInnerProducer() {
11011101
m_DefaultMQProducerImpl = std::make_shared<DefaultMQProducerImpl>(getGroupName());
11021102
m_DefaultMQProducerImpl->setMessageTrace(false);
1103-
m_DefaultMQProducerImpl->setInstanceName(getInstanceName());
1103+
m_DefaultMQProducerImpl->setInstanceName("MESSAGE_TRACE_" + getInstanceName());
11041104
const SessionCredentials& session = getSessionCredentials();
11051105
m_DefaultMQProducerImpl->setSessionCredentials(session.getAccessKey(), session.getSecretKey(),
11061106
session.getAuthChannel());
@@ -1109,15 +1109,15 @@ void DefaultMQPushConsumerImpl::createMessageTraceInnerProducer() {
11091109
}
11101110
m_DefaultMQProducerImpl->setNameSpace(getNameSpace());
11111111
// m_DefaultMQProducerImpl->setNamesrvDomain(getNamesrvDomain());
1112-
m_DefaultMQProducerImpl->start(false);
1112+
m_DefaultMQProducerImpl->start();
11131113
}
11141114
void DefaultMQPushConsumerImpl::shutdownMessageTraceInnerProducer() {
11151115
if (!getMessageTrace()) {
11161116
return;
11171117
}
11181118
if (m_DefaultMQProducerImpl) {
11191119
LOG_INFO("Shutdown Message Trace Inner Producer In Consumer.");
1120-
m_DefaultMQProducerImpl->shutdown(false);
1120+
m_DefaultMQProducerImpl->shutdown();
11211121
}
11221122
}
11231123
bool DefaultMQPushConsumerImpl::hasConsumeMessageHook() {

0 commit comments

Comments
 (0)