Skip to content

Commit c5ef32e

Browse files
messenseShannonDing
authored andcommitted
Properly construct DefaultMQPushConsumer (apache#55)
* Properly construct DefaultMQPushConsumer * Fix bash path in build.sh
1 parent 2a06e0f commit c5ef32e

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

build.sh

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
#!/usr/bin/bash
1+
#!/bin/bash
22

33
# Licensed to the Apache Software Foundation (ASF) under one or more
44
# contributor license agreements. See the NOTICE file distributed with

src/consumer/DefaultMQPushConsumer.cpp

+4-1
Original file line numberDiff line numberDiff line change
@@ -202,10 +202,13 @@ namespace rocketmq {
202202
DefaultMQPushConsumer::DefaultMQPushConsumer(const string &groupname)
203203
: m_consumeFromWhere(CONSUME_FROM_LAST_OFFSET),
204204
m_pOffsetStore(NULL),
205+
m_pRebalance(NULL),
205206
m_pPullAPIWrapper(NULL),
207+
m_consumerService(NULL),
206208
m_pMessageListener(NULL),
207209
m_consumeMessageBatchMaxSize(1),
208-
m_maxMsgCacheSize(1000) {
210+
m_maxMsgCacheSize(1000),
211+
m_pullmsgQueue(NULL) {
209212
//<!set default group name;
210213
string gname = groupname.empty() ? DEFAULT_CONSUMER_GROUP : groupname;
211214
setGroupName(gname);

0 commit comments

Comments
 (0)