test_class.declarator: StoreMessage = "Once, there was a chance for me!"
test_class.modifier: private final
test_class.original_string: private final String StoreMessage = "Once, there was a chance for me!";
test_class.type: String
test_class.var_name: StoreMessage
test_class.declarator: QUEUE_TOTAL = 100
test_class.modifier: private
test_class.original_string: private int QUEUE_TOTAL = 100;
test_class.type: int
test_class.var_name: QUEUE_TOTAL
test_class.declarator: QueueId = new AtomicInteger(0)
test_class.modifier: private
test_class.original_string: private AtomicInteger QueueId = new AtomicInteger(0);
test_class.type: AtomicInteger
test_class.var_name: QueueId
test_class.declarator: BornHost
test_class.modifier: private
test_class.original_string: private SocketAddress BornHost;
test_class.type: SocketAddress
test_class.var_name: BornHost
test_class.declarator: StoreHost
test_class.modifier: private
test_class.original_string: private SocketAddress StoreHost;
test_class.type: SocketAddress
test_class.var_name: StoreHost
test_class.declarator: MessageBody
test_class.modifier: private
test_class.original_string: private byte[] MessageBody;
test_class.type: byte[]
test_class.var_name: MessageBody
test_class.declarator: messageStore
test_class.modifier: private
test_class.original_string: private MessageStore messageStore;
test_class.type: MessageStore
test_class.var_name: messageStore
test_class.file: store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java
test_class.identifier: DefaultMessageStoreTest
test_case.body: @Test
      public void testReadOneScheduleMsg() throws Exception {
          long totalMsgs = 60000;
          QUEUE_TOTAL = 10;
          MessageExt msgExt =
                  messageStore.lookMessageByOffset(
                  		9677008);
          System.err.println(msgExt);
          System.err.println(System.currentTimeMillis());
          
      }
test_case.class_method_signature: DefaultMessageStoreTest.testReadOneScheduleMsg()
test_case.full_signature: @Test public void testReadOneScheduleMsg()
test_case.identifier: testReadOneScheduleMsg
test_case.invocations: lookMessageByOffset println println currentTimeMillis
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testReadOneScheduleMsg()
focal_class.declarator: log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
focal_class.type: Logger
focal_class.var_name: log
focal_class.declarator: messageStoreConfig
focal_class.modifier: private final
focal_class.original_string: private final MessageStoreConfig messageStoreConfig;
focal_class.type: MessageStoreConfig
focal_class.var_name: messageStoreConfig
focal_class.declarator: commitLog
focal_class.modifier: private final
focal_class.original_string: private final CommitLog commitLog;
focal_class.type: CommitLog
focal_class.var_name: commitLog
focal_class.declarator: consumeQueueTable
focal_class.modifier: private final
focal_class.original_string: private final ConcurrentMap<String/* topic */, ConcurrentMap<Integer/* queueId */, ConsumeQueue>> consumeQueueTable;
focal_class.type: ConcurrentMap<String/* topic */, ConcurrentMap<Integer/* queueId */, ConsumeQueue>>
focal_class.var_name: consumeQueueTable
focal_class.declarator: flushConsumeQueueService
focal_class.modifier: private final
focal_class.original_string: private final FlushConsumeQueueService flushConsumeQueueService;
focal_class.type: FlushConsumeQueueService
focal_class.var_name: flushConsumeQueueService
focal_class.declarator: cleanCommitLogService
focal_class.modifier: private final
focal_class.original_string: private final CleanCommitLogService cleanCommitLogService;
focal_class.type: CleanCommitLogService
focal_class.var_name: cleanCommitLogService
focal_class.declarator: cleanConsumeQueueService
focal_class.modifier: private final
focal_class.original_string: private final CleanConsumeQueueService cleanConsumeQueueService;
focal_class.type: CleanConsumeQueueService
focal_class.var_name: cleanConsumeQueueService
focal_class.declarator: indexService
focal_class.modifier: private final
focal_class.original_string: private final IndexService indexService;
focal_class.type: IndexService
focal_class.var_name: indexService
focal_class.declarator: allocateMappedFileService
focal_class.modifier: private final
focal_class.original_string: private final AllocateMappedFileService allocateMappedFileService;
focal_class.type: AllocateMappedFileService
focal_class.var_name: allocateMappedFileService
focal_class.declarator: reputMessageService
focal_class.modifier: private final
focal_class.original_string: private final ReputMessageService reputMessageService;
focal_class.type: ReputMessageService
focal_class.var_name: reputMessageService
focal_class.declarator: haService
focal_class.modifier: private final
focal_class.original_string: private final HAService haService;
focal_class.type: HAService
focal_class.var_name: haService
focal_class.declarator: scheduleMessageService
focal_class.modifier: private final
focal_class.original_string: private final ScheduleMessageService scheduleMessageService;
focal_class.type: ScheduleMessageService
focal_class.var_name: scheduleMessageService
focal_class.declarator: storeStatsService
focal_class.modifier: private final
focal_class.original_string: private final StoreStatsService storeStatsService;
focal_class.type: StoreStatsService
focal_class.var_name: storeStatsService
focal_class.declarator: transientStorePool
focal_class.modifier: private final
focal_class.original_string: private final TransientStorePool transientStorePool;
focal_class.type: TransientStorePool
focal_class.var_name: transientStorePool
focal_class.declarator: runningFlags = new RunningFlags()
focal_class.modifier: private final
focal_class.original_string: private final RunningFlags runningFlags = new RunningFlags();
focal_class.type: RunningFlags
focal_class.var_name: runningFlags
focal_class.declarator: systemClock = new SystemClock()
focal_class.modifier: private final
focal_class.original_string: private final SystemClock systemClock = new SystemClock();
focal_class.type: SystemClock
focal_class.var_name: systemClock
focal_class.declarator: scheduledExecutorService =
          Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl("StoreScheduledThread"))
focal_class.modifier: private final
focal_class.original_string: private final ScheduledExecutorService scheduledExecutorService =
          Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl("StoreScheduledThread"));
focal_class.type: ScheduledExecutorService
focal_class.var_name: scheduledExecutorService
focal_class.declarator: brokerStatsManager
focal_class.modifier: private final
focal_class.original_string: private final BrokerStatsManager brokerStatsManager;
focal_class.type: BrokerStatsManager
focal_class.var_name: brokerStatsManager
focal_class.declarator: messageArrivingListener
focal_class.modifier: private final
focal_class.original_string: private final MessageArrivingListener messageArrivingListener;
focal_class.type: MessageArrivingListener
focal_class.var_name: messageArrivingListener
focal_class.declarator: brokerConfig
focal_class.modifier: private final
focal_class.original_string: private final BrokerConfig brokerConfig;
focal_class.type: BrokerConfig
focal_class.var_name: brokerConfig
focal_class.declarator: shutdown = true
focal_class.modifier: private volatile
focal_class.original_string: private volatile boolean shutdown = true;
focal_class.type: boolean
focal_class.var_name: shutdown
focal_class.declarator: storeCheckpoint
focal_class.modifier: private
focal_class.original_string: private StoreCheckpoint storeCheckpoint;
focal_class.type: StoreCheckpoint
focal_class.var_name: storeCheckpoint
focal_class.declarator: printTimes = new AtomicLong(0)
focal_class.modifier: private
focal_class.original_string: private AtomicLong printTimes = new AtomicLong(0);
focal_class.type: AtomicLong
focal_class.var_name: printTimes
focal_class.declarator: dispatcherList
focal_class.modifier: private final
focal_class.original_string: private final LinkedList<CommitLogDispatcher> dispatcherList;
focal_class.type: LinkedList<CommitLogDispatcher>
focal_class.var_name: dispatcherList
focal_class.declarator: lockFile
focal_class.modifier: private
focal_class.original_string: private RandomAccessFile lockFile;
focal_class.type: RandomAccessFile
focal_class.var_name: lockFile
focal_class.declarator: lock
focal_class.modifier: private
focal_class.original_string: private FileLock lock;
focal_class.type: FileLock
focal_class.var_name: lock
focal_class.declarator: shutDownNormal = false
focal_class.original_string: boolean shutDownNormal = false;
focal_class.type: boolean
focal_class.var_name: shutDownNormal
focal_class.file: store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
focal_class.identifier: DefaultMessageStore
focal_class.interfaces: implements MessageStore
focal_class.class_method_signature: DefaultMessageStore.DefaultMessageStore(final MessageStoreConfig messageStoreConfig, final BrokerStatsManager brokerStatsManager,
          final MessageArrivingListener messageArrivingListener, final BrokerConfig brokerConfig)
focal_class.full_signature: public  DefaultMessageStore(final MessageStoreConfig messageStoreConfig, final BrokerStatsManager brokerStatsManager,
          final MessageArrivingListener messageArrivingListener, final BrokerConfig brokerConfig)
focal_class.identifier: DefaultMessageStore
focal_class.modifiers: public
focal_class.parameters: (final MessageStoreConfig messageStoreConfig, final BrokerStatsManager brokerStatsManager,
          final MessageArrivingListener messageArrivingListener, final BrokerConfig brokerConfig)
focal_class.signature:  DefaultMessageStore(final MessageStoreConfig messageStoreConfig, final BrokerStatsManager brokerStatsManager,
          final MessageArrivingListener messageArrivingListener, final BrokerConfig brokerConfig)
focal_class.class_method_signature: DefaultMessageStore.truncateDirtyLogicFiles(long phyOffset)
focal_class.full_signature: public void truncateDirtyLogicFiles(long phyOffset)
focal_class.identifier: truncateDirtyLogicFiles
focal_class.modifiers: public
focal_class.parameters: (long phyOffset)
focal_class.return: void
focal_class.signature: void truncateDirtyLogicFiles(long phyOffset)
focal_class.class_method_signature: DefaultMessageStore.load()
focal_class.full_signature: public boolean load()
focal_class.identifier: load
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean load()
focal_class.class_method_signature: DefaultMessageStore.start()
focal_class.full_signature: public void start()
focal_class.identifier: start
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void start()
focal_class.class_method_signature: DefaultMessageStore.shutdown()
focal_class.full_signature: public void shutdown()
focal_class.identifier: shutdown
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void shutdown()
focal_class.class_method_signature: DefaultMessageStore.destroy()
focal_class.full_signature: public void destroy()
focal_class.identifier: destroy
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void destroy()
focal_class.class_method_signature: DefaultMessageStore.destroyLogics()
focal_class.full_signature: public void destroyLogics()
focal_class.identifier: destroyLogics
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void destroyLogics()
focal_class.class_method_signature: DefaultMessageStore.putMessage(MessageExtBrokerInner msg)
focal_class.full_signature: public PutMessageResult putMessage(MessageExtBrokerInner msg)
focal_class.identifier: putMessage
focal_class.modifiers: public
focal_class.parameters: (MessageExtBrokerInner msg)
focal_class.return: PutMessageResult
focal_class.signature: PutMessageResult putMessage(MessageExtBrokerInner msg)
focal_class.class_method_signature: DefaultMessageStore.putMessages(MessageExtBatch messageExtBatch)
focal_class.full_signature: public PutMessageResult putMessages(MessageExtBatch messageExtBatch)
focal_class.identifier: putMessages
focal_class.modifiers: public
focal_class.parameters: (MessageExtBatch messageExtBatch)
focal_class.return: PutMessageResult
focal_class.signature: PutMessageResult putMessages(MessageExtBatch messageExtBatch)
focal_class.class_method_signature: DefaultMessageStore.isOSPageCacheBusy()
focal_class.full_signature: @Override public boolean isOSPageCacheBusy()
focal_class.identifier: isOSPageCacheBusy
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isOSPageCacheBusy()
focal_class.class_method_signature: DefaultMessageStore.lockTimeMills()
focal_class.full_signature: @Override public long lockTimeMills()
focal_class.identifier: lockTimeMills
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long lockTimeMills()
focal_class.class_method_signature: DefaultMessageStore.getSystemClock()
focal_class.full_signature: public SystemClock getSystemClock()
focal_class.identifier: getSystemClock
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: SystemClock
focal_class.signature: SystemClock getSystemClock()
focal_class.class_method_signature: DefaultMessageStore.getCommitLog()
focal_class.full_signature: public CommitLog getCommitLog()
focal_class.identifier: getCommitLog
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: CommitLog
focal_class.signature: CommitLog getCommitLog()
focal_class.class_method_signature: DefaultMessageStore.getMessage(final String group, final String topic, final int queueId, final long offset,
          final int maxMsgNums,
          final MessageFilter messageFilter)
focal_class.full_signature: public GetMessageResult getMessage(final String group, final String topic, final int queueId, final long offset,
          final int maxMsgNums,
          final MessageFilter messageFilter)
focal_class.identifier: getMessage
focal_class.modifiers: public
focal_class.parameters: (final String group, final String topic, final int queueId, final long offset,
          final int maxMsgNums,
          final MessageFilter messageFilter)
focal_class.return: GetMessageResult
focal_class.signature: GetMessageResult getMessage(final String group, final String topic, final int queueId, final long offset,
          final int maxMsgNums,
          final MessageFilter messageFilter)
focal_class.class_method_signature: DefaultMessageStore.getMaxOffsetInQueue(String topic, int queueId)
focal_class.full_signature: public long getMaxOffsetInQueue(String topic, int queueId)
focal_class.identifier: getMaxOffsetInQueue
focal_class.modifiers: public
focal_class.parameters: (String topic, int queueId)
focal_class.return: long
focal_class.signature: long getMaxOffsetInQueue(String topic, int queueId)
focal_class.class_method_signature: DefaultMessageStore.getMinOffsetInQueue(String topic, int queueId)
focal_class.full_signature: public long getMinOffsetInQueue(String topic, int queueId)
focal_class.identifier: getMinOffsetInQueue
focal_class.modifiers: public
focal_class.parameters: (String topic, int queueId)
focal_class.return: long
focal_class.signature: long getMinOffsetInQueue(String topic, int queueId)
focal_class.class_method_signature: DefaultMessageStore.getCommitLogOffsetInQueue(String topic, int queueId, long consumeQueueOffset)
focal_class.full_signature: @Override public long getCommitLogOffsetInQueue(String topic, int queueId, long consumeQueueOffset)
focal_class.identifier: getCommitLogOffsetInQueue
focal_class.modifiers: @Override public
focal_class.parameters: (String topic, int queueId, long consumeQueueOffset)
focal_class.return: long
focal_class.signature: long getCommitLogOffsetInQueue(String topic, int queueId, long consumeQueueOffset)
focal_class.class_method_signature: DefaultMessageStore.getOffsetInQueueByTime(String topic, int queueId, long timestamp)
focal_class.full_signature: public long getOffsetInQueueByTime(String topic, int queueId, long timestamp)
focal_class.identifier: getOffsetInQueueByTime
focal_class.modifiers: public
focal_class.parameters: (String topic, int queueId, long timestamp)
focal_class.return: long
focal_class.signature: long getOffsetInQueueByTime(String topic, int queueId, long timestamp)
focal_class.class_method_signature: DefaultMessageStore.lookMessageByOffset(long commitLogOffset)
focal_class.full_signature: public MessageExt lookMessageByOffset(long commitLogOffset)
focal_class.identifier: lookMessageByOffset
focal_class.modifiers: public
focal_class.parameters: (long commitLogOffset)
focal_class.return: MessageExt
focal_class.signature: MessageExt lookMessageByOffset(long commitLogOffset)
focal_class.class_method_signature: DefaultMessageStore.selectOneMessageByOffset(long commitLogOffset)
focal_class.full_signature: @Override public SelectMappedBufferResult selectOneMessageByOffset(long commitLogOffset)
focal_class.identifier: selectOneMessageByOffset
focal_class.modifiers: @Override public
focal_class.parameters: (long commitLogOffset)
focal_class.return: SelectMappedBufferResult
focal_class.signature: SelectMappedBufferResult selectOneMessageByOffset(long commitLogOffset)
focal_class.class_method_signature: DefaultMessageStore.selectOneMessageByOffset(long commitLogOffset, int msgSize)
focal_class.full_signature: @Override public SelectMappedBufferResult selectOneMessageByOffset(long commitLogOffset, int msgSize)
focal_class.identifier: selectOneMessageByOffset
focal_class.modifiers: @Override public
focal_class.parameters: (long commitLogOffset, int msgSize)
focal_class.return: SelectMappedBufferResult
focal_class.signature: SelectMappedBufferResult selectOneMessageByOffset(long commitLogOffset, int msgSize)
focal_class.class_method_signature: DefaultMessageStore.getRunningDataInfo()
focal_class.full_signature: public String getRunningDataInfo()
focal_class.identifier: getRunningDataInfo
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getRunningDataInfo()
focal_class.class_method_signature: DefaultMessageStore.getRuntimeInfo()
focal_class.full_signature: @Override public HashMap<String, String> getRuntimeInfo()
focal_class.identifier: getRuntimeInfo
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: HashMap<String, String>
focal_class.signature: HashMap<String, String> getRuntimeInfo()
focal_class.class_method_signature: DefaultMessageStore.getMaxPhyOffset()
focal_class.full_signature: @Override public long getMaxPhyOffset()
focal_class.identifier: getMaxPhyOffset
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getMaxPhyOffset()
focal_class.class_method_signature: DefaultMessageStore.getMinPhyOffset()
focal_class.full_signature: @Override public long getMinPhyOffset()
focal_class.identifier: getMinPhyOffset
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getMinPhyOffset()
focal_class.class_method_signature: DefaultMessageStore.getEarliestMessageTime(String topic, int queueId)
focal_class.full_signature: @Override public long getEarliestMessageTime(String topic, int queueId)
focal_class.identifier: getEarliestMessageTime
focal_class.modifiers: @Override public
focal_class.parameters: (String topic, int queueId)
focal_class.return: long
focal_class.signature: long getEarliestMessageTime(String topic, int queueId)
focal_class.class_method_signature: DefaultMessageStore.getStoreTime(SelectMappedBufferResult result)
focal_class.full_signature: private long getStoreTime(SelectMappedBufferResult result)
focal_class.identifier: getStoreTime
focal_class.modifiers: private
focal_class.parameters: (SelectMappedBufferResult result)
focal_class.return: long
focal_class.signature: long getStoreTime(SelectMappedBufferResult result)
focal_class.class_method_signature: DefaultMessageStore.getEarliestMessageTime()
focal_class.full_signature: @Override public long getEarliestMessageTime()
focal_class.identifier: getEarliestMessageTime
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getEarliestMessageTime()
focal_class.class_method_signature: DefaultMessageStore.getMessageStoreTimeStamp(String topic, int queueId, long consumeQueueOffset)
focal_class.full_signature: @Override public long getMessageStoreTimeStamp(String topic, int queueId, long consumeQueueOffset)
focal_class.identifier: getMessageStoreTimeStamp
focal_class.modifiers: @Override public
focal_class.parameters: (String topic, int queueId, long consumeQueueOffset)
focal_class.return: long
focal_class.signature: long getMessageStoreTimeStamp(String topic, int queueId, long consumeQueueOffset)
focal_class.class_method_signature: DefaultMessageStore.getMessageTotalInQueue(String topic, int queueId)
focal_class.full_signature: @Override public long getMessageTotalInQueue(String topic, int queueId)
focal_class.identifier: getMessageTotalInQueue
focal_class.modifiers: @Override public
focal_class.parameters: (String topic, int queueId)
focal_class.return: long
focal_class.signature: long getMessageTotalInQueue(String topic, int queueId)
focal_class.class_method_signature: DefaultMessageStore.getCommitLogData(final long offset)
focal_class.full_signature: @Override public SelectMappedBufferResult getCommitLogData(final long offset)
focal_class.identifier: getCommitLogData
focal_class.modifiers: @Override public
focal_class.parameters: (final long offset)
focal_class.return: SelectMappedBufferResult
focal_class.signature: SelectMappedBufferResult getCommitLogData(final long offset)
focal_class.class_method_signature: DefaultMessageStore.appendToCommitLog(long startOffset, byte[] data)
focal_class.full_signature: @Override public boolean appendToCommitLog(long startOffset, byte[] data)
focal_class.identifier: appendToCommitLog
focal_class.modifiers: @Override public
focal_class.parameters: (long startOffset, byte[] data)
focal_class.return: boolean
focal_class.signature: boolean appendToCommitLog(long startOffset, byte[] data)
focal_class.class_method_signature: DefaultMessageStore.executeDeleteFilesManually()
focal_class.full_signature: @Override public void executeDeleteFilesManually()
focal_class.identifier: executeDeleteFilesManually
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void executeDeleteFilesManually()
focal_class.class_method_signature: DefaultMessageStore.queryMessage(String topic, String key, int maxNum, long begin, long end)
focal_class.full_signature: @Override public QueryMessageResult queryMessage(String topic, String key, int maxNum, long begin, long end)
focal_class.identifier: queryMessage
focal_class.modifiers: @Override public
focal_class.parameters: (String topic, String key, int maxNum, long begin, long end)
focal_class.return: QueryMessageResult
focal_class.signature: QueryMessageResult queryMessage(String topic, String key, int maxNum, long begin, long end)
focal_class.class_method_signature: DefaultMessageStore.updateHaMasterAddress(String newAddr)
focal_class.full_signature: @Override public void updateHaMasterAddress(String newAddr)
focal_class.identifier: updateHaMasterAddress
focal_class.modifiers: @Override public
focal_class.parameters: (String newAddr)
focal_class.return: void
focal_class.signature: void updateHaMasterAddress(String newAddr)
focal_class.class_method_signature: DefaultMessageStore.slaveFallBehindMuch()
focal_class.full_signature: @Override public long slaveFallBehindMuch()
focal_class.identifier: slaveFallBehindMuch
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long slaveFallBehindMuch()
focal_class.class_method_signature: DefaultMessageStore.now()
focal_class.full_signature: @Override public long now()
focal_class.identifier: now
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long now()
focal_class.class_method_signature: DefaultMessageStore.cleanUnusedTopic(Set<String> topics)
focal_class.full_signature: @Override public int cleanUnusedTopic(Set<String> topics)
focal_class.identifier: cleanUnusedTopic
focal_class.modifiers: @Override public
focal_class.parameters: (Set<String> topics)
focal_class.return: int
focal_class.signature: int cleanUnusedTopic(Set<String> topics)
focal_class.class_method_signature: DefaultMessageStore.cleanExpiredConsumerQueue()
focal_class.full_signature: public void cleanExpiredConsumerQueue()
focal_class.identifier: cleanExpiredConsumerQueue
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cleanExpiredConsumerQueue()
focal_class.class_method_signature: DefaultMessageStore.getMessageIds(final String topic, final int queueId, long minOffset, long maxOffset,
          SocketAddress storeHost)
focal_class.full_signature: public Map<String, Long> getMessageIds(final String topic, final int queueId, long minOffset, long maxOffset,
          SocketAddress storeHost)
focal_class.identifier: getMessageIds
focal_class.modifiers: public
focal_class.parameters: (final String topic, final int queueId, long minOffset, long maxOffset,
          SocketAddress storeHost)
focal_class.return: Map<String, Long>
focal_class.signature: Map<String, Long> getMessageIds(final String topic, final int queueId, long minOffset, long maxOffset,
          SocketAddress storeHost)
focal_class.class_method_signature: DefaultMessageStore.checkInDiskByConsumeOffset(final String topic, final int queueId, long consumeOffset)
focal_class.full_signature: @Override public boolean checkInDiskByConsumeOffset(final String topic, final int queueId, long consumeOffset)
focal_class.identifier: checkInDiskByConsumeOffset
focal_class.modifiers: @Override public
focal_class.parameters: (final String topic, final int queueId, long consumeOffset)
focal_class.return: boolean
focal_class.signature: boolean checkInDiskByConsumeOffset(final String topic, final int queueId, long consumeOffset)
focal_class.class_method_signature: DefaultMessageStore.dispatchBehindBytes()
focal_class.full_signature: public long dispatchBehindBytes()
focal_class.identifier: dispatchBehindBytes
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long dispatchBehindBytes()
focal_class.class_method_signature: DefaultMessageStore.flush()
focal_class.full_signature: @Override public long flush()
focal_class.identifier: flush
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long flush()
focal_class.class_method_signature: DefaultMessageStore.resetWriteOffset(long phyOffset)
focal_class.full_signature: @Override public boolean resetWriteOffset(long phyOffset)
focal_class.identifier: resetWriteOffset
focal_class.modifiers: @Override public
focal_class.parameters: (long phyOffset)
focal_class.return: boolean
focal_class.signature: boolean resetWriteOffset(long phyOffset)
focal_class.class_method_signature: DefaultMessageStore.getConfirmOffset()
focal_class.full_signature: @Override public long getConfirmOffset()
focal_class.identifier: getConfirmOffset
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getConfirmOffset()
focal_class.class_method_signature: DefaultMessageStore.setConfirmOffset(long phyOffset)
focal_class.full_signature: @Override public void setConfirmOffset(long phyOffset)
focal_class.identifier: setConfirmOffset
focal_class.modifiers: @Override public
focal_class.parameters: (long phyOffset)
focal_class.return: void
focal_class.signature: void setConfirmOffset(long phyOffset)
focal_class.class_method_signature: DefaultMessageStore.lookMessageByOffset(long commitLogOffset, int size)
focal_class.full_signature: public MessageExt lookMessageByOffset(long commitLogOffset, int size)
focal_class.identifier: lookMessageByOffset
focal_class.modifiers: public
focal_class.parameters: (long commitLogOffset, int size)
focal_class.return: MessageExt
focal_class.signature: MessageExt lookMessageByOffset(long commitLogOffset, int size)
focal_class.class_method_signature: DefaultMessageStore.findConsumeQueue(String topic, int queueId)
focal_class.full_signature: public ConsumeQueue findConsumeQueue(String topic, int queueId)
focal_class.identifier: findConsumeQueue
focal_class.modifiers: public
focal_class.parameters: (String topic, int queueId)
focal_class.return: ConsumeQueue
focal_class.signature: ConsumeQueue findConsumeQueue(String topic, int queueId)
focal_class.class_method_signature: DefaultMessageStore.nextOffsetCorrection(long oldOffset, long newOffset)
focal_class.full_signature: private long nextOffsetCorrection(long oldOffset, long newOffset)
focal_class.identifier: nextOffsetCorrection
focal_class.modifiers: private
focal_class.parameters: (long oldOffset, long newOffset)
focal_class.return: long
focal_class.signature: long nextOffsetCorrection(long oldOffset, long newOffset)
focal_class.class_method_signature: DefaultMessageStore.checkInDiskByCommitOffset(long offsetPy, long maxOffsetPy)
focal_class.full_signature: private boolean checkInDiskByCommitOffset(long offsetPy, long maxOffsetPy)
focal_class.identifier: checkInDiskByCommitOffset
focal_class.modifiers: private
focal_class.parameters: (long offsetPy, long maxOffsetPy)
focal_class.return: boolean
focal_class.signature: boolean checkInDiskByCommitOffset(long offsetPy, long maxOffsetPy)
focal_class.class_method_signature: DefaultMessageStore.isTheBatchFull(int sizePy, int maxMsgNums, int bufferTotal, int messageTotal, boolean isInDisk)
focal_class.full_signature: private boolean isTheBatchFull(int sizePy, int maxMsgNums, int bufferTotal, int messageTotal, boolean isInDisk)
focal_class.identifier: isTheBatchFull
focal_class.modifiers: private
focal_class.parameters: (int sizePy, int maxMsgNums, int bufferTotal, int messageTotal, boolean isInDisk)
focal_class.return: boolean
focal_class.signature: boolean isTheBatchFull(int sizePy, int maxMsgNums, int bufferTotal, int messageTotal, boolean isInDisk)
focal_class.class_method_signature: DefaultMessageStore.deleteFile(final String fileName)
focal_class.full_signature: private void deleteFile(final String fileName)
focal_class.identifier: deleteFile
focal_class.modifiers: private
focal_class.parameters: (final String fileName)
focal_class.return: void
focal_class.signature: void deleteFile(final String fileName)
focal_class.class_method_signature: DefaultMessageStore.createTempFile()
focal_class.full_signature: private void createTempFile()
focal_class.identifier: createTempFile
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void createTempFile()
focal_class.class_method_signature: DefaultMessageStore.addScheduleTask()
focal_class.full_signature: private void addScheduleTask()
focal_class.identifier: addScheduleTask
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void addScheduleTask()
focal_class.class_method_signature: DefaultMessageStore.cleanFilesPeriodically()
focal_class.full_signature: private void cleanFilesPeriodically()
focal_class.identifier: cleanFilesPeriodically
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cleanFilesPeriodically()
focal_class.class_method_signature: DefaultMessageStore.checkSelf()
focal_class.full_signature: private void checkSelf()
focal_class.identifier: checkSelf
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void checkSelf()
focal_class.class_method_signature: DefaultMessageStore.isTempFileExist()
focal_class.full_signature: private boolean isTempFileExist()
focal_class.identifier: isTempFileExist
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isTempFileExist()
focal_class.class_method_signature: DefaultMessageStore.loadConsumeQueue()
focal_class.full_signature: private boolean loadConsumeQueue()
focal_class.identifier: loadConsumeQueue
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean loadConsumeQueue()
focal_class.class_method_signature: DefaultMessageStore.recover(final boolean lastExitOK)
focal_class.full_signature: private void recover(final boolean lastExitOK)
focal_class.identifier: recover
focal_class.modifiers: private
focal_class.parameters: (final boolean lastExitOK)
focal_class.return: void
focal_class.signature: void recover(final boolean lastExitOK)
focal_class.class_method_signature: DefaultMessageStore.getMessageStoreConfig()
focal_class.full_signature: public MessageStoreConfig getMessageStoreConfig()
focal_class.identifier: getMessageStoreConfig
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: MessageStoreConfig
focal_class.signature: MessageStoreConfig getMessageStoreConfig()
focal_class.class_method_signature: DefaultMessageStore.getTransientStorePool()
focal_class.full_signature: public TransientStorePool getTransientStorePool()
focal_class.identifier: getTransientStorePool
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: TransientStorePool
focal_class.signature: TransientStorePool getTransientStorePool()
focal_class.class_method_signature: DefaultMessageStore.putConsumeQueue(final String topic, final int queueId, final ConsumeQueue consumeQueue)
focal_class.full_signature: private void putConsumeQueue(final String topic, final int queueId, final ConsumeQueue consumeQueue)
focal_class.identifier: putConsumeQueue
focal_class.modifiers: private
focal_class.parameters: (final String topic, final int queueId, final ConsumeQueue consumeQueue)
focal_class.return: void
focal_class.signature: void putConsumeQueue(final String topic, final int queueId, final ConsumeQueue consumeQueue)
focal_class.class_method_signature: DefaultMessageStore.recoverConsumeQueue()
focal_class.full_signature: private void recoverConsumeQueue()
focal_class.identifier: recoverConsumeQueue
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void recoverConsumeQueue()
focal_class.class_method_signature: DefaultMessageStore.recoverTopicQueueTable()
focal_class.full_signature: private void recoverTopicQueueTable()
focal_class.identifier: recoverTopicQueueTable
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void recoverTopicQueueTable()
focal_class.class_method_signature: DefaultMessageStore.getAllocateMappedFileService()
focal_class.full_signature: public AllocateMappedFileService getAllocateMappedFileService()
focal_class.identifier: getAllocateMappedFileService
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: AllocateMappedFileService
focal_class.signature: AllocateMappedFileService getAllocateMappedFileService()
focal_class.class_method_signature: DefaultMessageStore.getStoreStatsService()
focal_class.full_signature: public StoreStatsService getStoreStatsService()
focal_class.identifier: getStoreStatsService
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: StoreStatsService
focal_class.signature: StoreStatsService getStoreStatsService()
focal_class.class_method_signature: DefaultMessageStore.getAccessRights()
focal_class.full_signature: public RunningFlags getAccessRights()
focal_class.identifier: getAccessRights
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: RunningFlags
focal_class.signature: RunningFlags getAccessRights()
focal_class.class_method_signature: DefaultMessageStore.getConsumeQueueTable()
focal_class.full_signature: public ConcurrentMap<String, ConcurrentMap<Integer, ConsumeQueue>> getConsumeQueueTable()
focal_class.identifier: getConsumeQueueTable
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: ConcurrentMap<String, ConcurrentMap<Integer, ConsumeQueue>>
focal_class.signature: ConcurrentMap<String, ConcurrentMap<Integer, ConsumeQueue>> getConsumeQueueTable()
focal_class.class_method_signature: DefaultMessageStore.getStoreCheckpoint()
focal_class.full_signature: public StoreCheckpoint getStoreCheckpoint()
focal_class.identifier: getStoreCheckpoint
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: StoreCheckpoint
focal_class.signature: StoreCheckpoint getStoreCheckpoint()
focal_class.class_method_signature: DefaultMessageStore.getHaService()
focal_class.full_signature: public HAService getHaService()
focal_class.identifier: getHaService
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: HAService
focal_class.signature: HAService getHaService()
focal_class.class_method_signature: DefaultMessageStore.getScheduleMessageService()
focal_class.full_signature: public ScheduleMessageService getScheduleMessageService()
focal_class.identifier: getScheduleMessageService
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: ScheduleMessageService
focal_class.signature: ScheduleMessageService getScheduleMessageService()
focal_class.class_method_signature: DefaultMessageStore.getRunningFlags()
focal_class.full_signature: public RunningFlags getRunningFlags()
focal_class.identifier: getRunningFlags
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: RunningFlags
focal_class.signature: RunningFlags getRunningFlags()
focal_class.class_method_signature: DefaultMessageStore.doDispatch(DispatchRequest req)
focal_class.full_signature: public void doDispatch(DispatchRequest req)
focal_class.identifier: doDispatch
focal_class.modifiers: public
focal_class.parameters: (DispatchRequest req)
focal_class.return: void
focal_class.signature: void doDispatch(DispatchRequest req)
focal_class.class_method_signature: DefaultMessageStore.putMessagePositionInfo(DispatchRequest dispatchRequest)
focal_class.full_signature: public void putMessagePositionInfo(DispatchRequest dispatchRequest)
focal_class.identifier: putMessagePositionInfo
focal_class.modifiers: public
focal_class.parameters: (DispatchRequest dispatchRequest)
focal_class.return: void
focal_class.signature: void putMessagePositionInfo(DispatchRequest dispatchRequest)
focal_class.class_method_signature: DefaultMessageStore.getBrokerStatsManager()
focal_class.full_signature: public BrokerStatsManager getBrokerStatsManager()
focal_class.identifier: getBrokerStatsManager
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: BrokerStatsManager
focal_class.signature: BrokerStatsManager getBrokerStatsManager()
focal_class.class_method_signature: DefaultMessageStore.remainTransientStoreBufferNumbs()
focal_class.full_signature: public int remainTransientStoreBufferNumbs()
focal_class.identifier: remainTransientStoreBufferNumbs
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int remainTransientStoreBufferNumbs()
focal_class.class_method_signature: DefaultMessageStore.isTransientStorePoolDeficient()
focal_class.full_signature: @Override public boolean isTransientStorePoolDeficient()
focal_class.identifier: isTransientStorePoolDeficient
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isTransientStorePoolDeficient()
focal_class.class_method_signature: DefaultMessageStore.getDispatcherList()
focal_class.full_signature: @Override public LinkedList<CommitLogDispatcher> getDispatcherList()
focal_class.identifier: getDispatcherList
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: LinkedList<CommitLogDispatcher>
focal_class.signature: LinkedList<CommitLogDispatcher> getDispatcherList()
focal_class.class_method_signature: DefaultMessageStore.getConsumeQueue(String topic, int queueId)
focal_class.full_signature: @Override public ConsumeQueue getConsumeQueue(String topic, int queueId)
focal_class.identifier: getConsumeQueue
focal_class.modifiers: @Override public
focal_class.parameters: (String topic, int queueId)
focal_class.return: ConsumeQueue
focal_class.signature: ConsumeQueue getConsumeQueue(String topic, int queueId)
focal_class.class_method_signature: DefaultMessageStore.unlockMappedFile(final MappedFile mappedFile)
focal_class.full_signature: public void unlockMappedFile(final MappedFile mappedFile)
focal_class.identifier: unlockMappedFile
focal_class.modifiers: public
focal_class.parameters: (final MappedFile mappedFile)
focal_class.return: void
focal_class.signature: void unlockMappedFile(final MappedFile mappedFile)
focal_method.body: public MessageExt lookMessageByOffset(long commitLogOffset) {
          SelectMappedBufferResult sbr = this.commitLog.getMessage(commitLogOffset, 4);
          if (null != sbr) {
              try {
                  // 1 TOTALSIZE
                  int size = sbr.getByteBuffer().getInt();
                  return lookMessageByOffset(commitLogOffset, size);
              } finally {
                  sbr.release();
              }
          }
  
          return null;
      }
focal_method.class_method_signature: DefaultMessageStore.lookMessageByOffset(long commitLogOffset)
focal_method.full_signature: public MessageExt lookMessageByOffset(long commitLogOffset)
focal_method.identifier: lookMessageByOffset
focal_method.invocations: getMessage getInt getByteBuffer lookMessageByOffset release
focal_method.modifiers: public
focal_method.parameters: (long commitLogOffset)
focal_method.return: MessageExt
focal_method.signature: MessageExt lookMessageByOffset(long commitLogOffset)