@Test public void testStart_OffsetShouldNotNUllAfterStart() { Assert.assertNotNull(pushConsumer.getOffsetStore()); }
@Deprecated public OffsetStore getOffsetStore() { return offsetStore; }
DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer { @Deprecated public OffsetStore getOffsetStore() { return offsetStore; } }
DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer { @Deprecated public OffsetStore getOffsetStore() { return offsetStore; } DefaultMQPushConsumer();  DefaultMQPushConsumer(final String consumerGroup);  DefaultMQPushConsumer(final String namespace, final String consumerGroup);  DefaultMQPushConsumer(RPCHook rpcHook);  DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook);  DefaultMQPushConsumer(final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy);  DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy);  DefaultMQPushConsumer(final String consumerGroup, boolean enableMsgTrace);  DefaultMQPushConsumer(final String consumerGroup, boolean enableMsgTrace, final String customizedTraceTopic);  DefaultMQPushConsumer(final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy, boolean enableMsgTrace, final String customizedTraceTopic);  DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy, boolean enableMsgTrace, final String customizedTraceTopic); }
DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer { @Deprecated public OffsetStore getOffsetStore() { return offsetStore; } DefaultMQPushConsumer();  DefaultMQPushConsumer(final String consumerGroup);  DefaultMQPushConsumer(final String namespace, final String consumerGroup);  DefaultMQPushConsumer(RPCHook rpcHook);  DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook);  DefaultMQPushConsumer(final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy);  DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy);  DefaultMQPushConsumer(final String consumerGroup, boolean enableMsgTrace);  DefaultMQPushConsumer(final String consumerGroup, boolean enableMsgTrace, final String customizedTraceTopic);  DefaultMQPushConsumer(final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy, boolean enableMsgTrace, final String customizedTraceTopic);  DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy, boolean enableMsgTrace, final String customizedTraceTopic); @Deprecated @Override void createTopic(String key, String newTopic, int queueNum); @Deprecated @Override void createTopic(String key, String newTopic, int queueNum, int topicSysFlag); @Deprecated @Override long searchOffset(MessageQueue mq, long timestamp); @Deprecated @Override long maxOffset(MessageQueue mq); @Deprecated @Override long minOffset(MessageQueue mq); @Deprecated @Override long earliestMsgStoreTime(MessageQueue mq); @Deprecated @Override MessageExt viewMessage(
        String offsetMsgId); @Deprecated @Override QueryResult queryMessage(String topic, String key, int maxNum, long begin, long end); @Deprecated @Override MessageExt viewMessage(String topic,
        String msgId); AllocateMessageQueueStrategy getAllocateMessageQueueStrategy(); void setAllocateMessageQueueStrategy(AllocateMessageQueueStrategy allocateMessageQueueStrategy); int getConsumeConcurrentlyMaxSpan(); void setConsumeConcurrentlyMaxSpan(int consumeConcurrentlyMaxSpan); ConsumeFromWhere getConsumeFromWhere(); void setConsumeFromWhere(ConsumeFromWhere consumeFromWhere); int getConsumeMessageBatchMaxSize(); void setConsumeMessageBatchMaxSize(int consumeMessageBatchMaxSize); String getConsumerGroup(); void setConsumerGroup(String consumerGroup); int getConsumeThreadMax(); void setConsumeThreadMax(int consumeThreadMax); int getConsumeThreadMin(); void setConsumeThreadMin(int consumeThreadMin); @Deprecated DefaultMQPushConsumerImpl getDefaultMQPushConsumerImpl(); MessageListener getMessageListener(); void setMessageListener(MessageListener messageListener); MessageModel getMessageModel(); void setMessageModel(MessageModel messageModel); int getPullBatchSize(); void setPullBatchSize(int pullBatchSize); long getPullInterval(); void setPullInterval(long pullInterval); int getPullThresholdForQueue(); void setPullThresholdForQueue(int pullThresholdForQueue); int getPullThresholdForTopic(); void setPullThresholdForTopic(final int pullThresholdForTopic); int getPullThresholdSizeForQueue(); void setPullThresholdSizeForQueue(final int pullThresholdSizeForQueue); int getPullThresholdSizeForTopic(); void setPullThresholdSizeForTopic(final int pullThresholdSizeForTopic); Map<String, String> getSubscription(); @Deprecated void setSubscription(Map<String, String> subscription); @Deprecated @Override void sendMessageBack(MessageExt msg, int delayLevel); @Deprecated @Override void sendMessageBack(MessageExt msg, int delayLevel, String brokerName); @Override Set<MessageQueue> fetchSubscribeMessageQueues(String topic); @Override void start(); @Override void shutdown(); @Override @Deprecated void registerMessageListener(MessageListener messageListener); @Override void registerMessageListener(MessageListenerConcurrently messageListener); @Override void registerMessageListener(MessageListenerOrderly messageListener); @Override void subscribe(String topic, String subExpression); @Override void subscribe(String topic, String fullClassName, String filterClassSource); @Override void subscribe(final String topic, final MessageSelector messageSelector); @Override void unsubscribe(String topic); @Override void updateCorePoolSize(int corePoolSize); @Override void suspend(); @Override void resume(); @Deprecated OffsetStore getOffsetStore(); @Deprecated void setOffsetStore(OffsetStore offsetStore); String getConsumeTimestamp(); void setConsumeTimestamp(String consumeTimestamp); boolean isPostSubscriptionWhenPull(); void setPostSubscriptionWhenPull(boolean postSubscriptionWhenPull); boolean isUnitMode(); void setUnitMode(boolean isUnitMode); long getAdjustThreadPoolNumsThreshold(); void setAdjustThreadPoolNumsThreshold(long adjustThreadPoolNumsThreshold); int getMaxReconsumeTimes(); void setMaxReconsumeTimes(final int maxReconsumeTimes); long getSuspendCurrentQueueTimeMillis(); void setSuspendCurrentQueueTimeMillis(final long suspendCurrentQueueTimeMillis); long getConsumeTimeout(); void setConsumeTimeout(final long consumeTimeout); long getAwaitTerminationMillisWhenShutdown(); void setAwaitTerminationMillisWhenShutdown(long awaitTerminationMillisWhenShutdown); TraceDispatcher getTraceDispatcher(); }
DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer { @Deprecated public OffsetStore getOffsetStore() { return offsetStore; } DefaultMQPushConsumer();  DefaultMQPushConsumer(final String consumerGroup);  DefaultMQPushConsumer(final String namespace, final String consumerGroup);  DefaultMQPushConsumer(RPCHook rpcHook);  DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook);  DefaultMQPushConsumer(final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy);  DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy);  DefaultMQPushConsumer(final String consumerGroup, boolean enableMsgTrace);  DefaultMQPushConsumer(final String consumerGroup, boolean enableMsgTrace, final String customizedTraceTopic);  DefaultMQPushConsumer(final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy, boolean enableMsgTrace, final String customizedTraceTopic);  DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook,
        AllocateMessageQueueStrategy allocateMessageQueueStrategy, boolean enableMsgTrace, final String customizedTraceTopic); @Deprecated @Override void createTopic(String key, String newTopic, int queueNum); @Deprecated @Override void createTopic(String key, String newTopic, int queueNum, int topicSysFlag); @Deprecated @Override long searchOffset(MessageQueue mq, long timestamp); @Deprecated @Override long maxOffset(MessageQueue mq); @Deprecated @Override long minOffset(MessageQueue mq); @Deprecated @Override long earliestMsgStoreTime(MessageQueue mq); @Deprecated @Override MessageExt viewMessage(
        String offsetMsgId); @Deprecated @Override QueryResult queryMessage(String topic, String key, int maxNum, long begin, long end); @Deprecated @Override MessageExt viewMessage(String topic,
        String msgId); AllocateMessageQueueStrategy getAllocateMessageQueueStrategy(); void setAllocateMessageQueueStrategy(AllocateMessageQueueStrategy allocateMessageQueueStrategy); int getConsumeConcurrentlyMaxSpan(); void setConsumeConcurrentlyMaxSpan(int consumeConcurrentlyMaxSpan); ConsumeFromWhere getConsumeFromWhere(); void setConsumeFromWhere(ConsumeFromWhere consumeFromWhere); int getConsumeMessageBatchMaxSize(); void setConsumeMessageBatchMaxSize(int consumeMessageBatchMaxSize); String getConsumerGroup(); void setConsumerGroup(String consumerGroup); int getConsumeThreadMax(); void setConsumeThreadMax(int consumeThreadMax); int getConsumeThreadMin(); void setConsumeThreadMin(int consumeThreadMin); @Deprecated DefaultMQPushConsumerImpl getDefaultMQPushConsumerImpl(); MessageListener getMessageListener(); void setMessageListener(MessageListener messageListener); MessageModel getMessageModel(); void setMessageModel(MessageModel messageModel); int getPullBatchSize(); void setPullBatchSize(int pullBatchSize); long getPullInterval(); void setPullInterval(long pullInterval); int getPullThresholdForQueue(); void setPullThresholdForQueue(int pullThresholdForQueue); int getPullThresholdForTopic(); void setPullThresholdForTopic(final int pullThresholdForTopic); int getPullThresholdSizeForQueue(); void setPullThresholdSizeForQueue(final int pullThresholdSizeForQueue); int getPullThresholdSizeForTopic(); void setPullThresholdSizeForTopic(final int pullThresholdSizeForTopic); Map<String, String> getSubscription(); @Deprecated void setSubscription(Map<String, String> subscription); @Deprecated @Override void sendMessageBack(MessageExt msg, int delayLevel); @Deprecated @Override void sendMessageBack(MessageExt msg, int delayLevel, String brokerName); @Override Set<MessageQueue> fetchSubscribeMessageQueues(String topic); @Override void start(); @Override void shutdown(); @Override @Deprecated void registerMessageListener(MessageListener messageListener); @Override void registerMessageListener(MessageListenerConcurrently messageListener); @Override void registerMessageListener(MessageListenerOrderly messageListener); @Override void subscribe(String topic, String subExpression); @Override void subscribe(String topic, String fullClassName, String filterClassSource); @Override void subscribe(final String topic, final MessageSelector messageSelector); @Override void unsubscribe(String topic); @Override void updateCorePoolSize(int corePoolSize); @Override void suspend(); @Override void resume(); @Deprecated OffsetStore getOffsetStore(); @Deprecated void setOffsetStore(OffsetStore offsetStore); String getConsumeTimestamp(); void setConsumeTimestamp(String consumeTimestamp); boolean isPostSubscriptionWhenPull(); void setPostSubscriptionWhenPull(boolean postSubscriptionWhenPull); boolean isUnitMode(); void setUnitMode(boolean isUnitMode); long getAdjustThreadPoolNumsThreshold(); void setAdjustThreadPoolNumsThreshold(long adjustThreadPoolNumsThreshold); int getMaxReconsumeTimes(); void setMaxReconsumeTimes(final int maxReconsumeTimes); long getSuspendCurrentQueueTimeMillis(); void setSuspendCurrentQueueTimeMillis(final long suspendCurrentQueueTimeMillis); long getConsumeTimeout(); void setConsumeTimeout(final long consumeTimeout); long getAwaitTerminationMillisWhenShutdown(); void setAwaitTerminationMillisWhenShutdown(long awaitTerminationMillisWhenShutdown); TraceDispatcher getTraceDispatcher();  }