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 testWriteScheduleMsg() throws Exception {
          long totalMsgs = 60000;
          QUEUE_TOTAL = 10;
          MessageBody = StoreMessage.getBytes();
          for (long i = 0; i < totalMsgs; i++) {
          		MessageExtBrokerInner msgInner=buildScheduleMessage(i);
              messageStore.putMessage(msgInner);
          }
          System.err.println(System.currentTimeMillis());
          Thread.sleep(200000);
          
      }
test_case.class_method_signature: DefaultMessageStoreTest.testWriteScheduleMsg()
test_case.full_signature: @Test public void testWriteScheduleMsg()
test_case.identifier: testWriteScheduleMsg
test_case.invocations: getBytes buildScheduleMessage putMessage println currentTimeMillis sleep
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testWriteScheduleMsg()
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 PutMessageResult putMessage(MessageExtBrokerInner msg) {
          if (this.shutdown) {
              log.warn("message store has shutdown, so putMessage is forbidden");
              return new PutMessageResult(PutMessageStatus.SERVICE_NOT_AVAILABLE, null);
          }
  
          if (BrokerRole.SLAVE == this.messageStoreConfig.getBrokerRole()) {
              long value = this.printTimes.getAndIncrement();
              if ((value % 50000) == 0) {
                  log.warn("message store is slave mode, so putMessage is forbidden ");
              }
  
              return new PutMessageResult(PutMessageStatus.SERVICE_NOT_AVAILABLE, null);
          }
  
          if (!this.runningFlags.isWriteable()) {
              long value = this.printTimes.getAndIncrement();
              if ((value % 50000) == 0) {
                  log.warn("message store is not writeable, so putMessage is forbidden " + this.runningFlags.getFlagBits());
              }
  
              return new PutMessageResult(PutMessageStatus.SERVICE_NOT_AVAILABLE, null);
          } else {
              this.printTimes.set(0);
          }
  
          if (msg.getTopic().length() > Byte.MAX_VALUE) {
              log.warn("putMessage message topic length too long " + msg.getTopic().length());
              return new PutMessageResult(PutMessageStatus.MESSAGE_ILLEGAL, null);
          }
  
          if (msg.getPropertiesString() != null && msg.getPropertiesString().length() > Short.MAX_VALUE) {
              log.warn("putMessage message properties length too long " + msg.getPropertiesString().length());
              return new PutMessageResult(PutMessageStatus.PROPERTIES_SIZE_EXCEEDED, null);
          }
  
          if (this.isOSPageCacheBusy()) {
              return new PutMessageResult(PutMessageStatus.OS_PAGECACHE_BUSY, null);
          }
  
          long beginTime = this.getSystemClock().now();
          PutMessageResult result = this.commitLog.putMessage(msg);
  
          long eclipseTime = this.getSystemClock().now() - beginTime;
          if (eclipseTime > 500) {
              log.warn("putMessage not in lock eclipse time(ms)={}, bodyLength={}", eclipseTime, msg.getBody().length);
          }
          this.storeStatsService.setPutMessageEntireTimeMax(eclipseTime);
  
          if (null == result || !result.isOk()) {
              this.storeStatsService.getPutMessageFailedTimes().incrementAndGet();
          }
  
          return result;
      }
focal_method.class_method_signature: DefaultMessageStore.putMessage(MessageExtBrokerInner msg)
focal_method.full_signature: public PutMessageResult putMessage(MessageExtBrokerInner msg)
focal_method.identifier: putMessage
focal_method.invocations: warn getBrokerRole getAndIncrement warn isWriteable getAndIncrement warn getFlagBits set length getTopic warn length getTopic getPropertiesString length getPropertiesString warn length getPropertiesString isOSPageCacheBusy now getSystemClock putMessage now getSystemClock warn getBody setPutMessageEntireTimeMax isOk incrementAndGet getPutMessageFailedTimes
focal_method.modifiers: public
focal_method.parameters: (MessageExtBrokerInner msg)
focal_method.return: PutMessageResult
focal_method.signature: PutMessageResult putMessage(MessageExtBrokerInner msg)