mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-01 15:47:01 +08:00
1fe5d62334
* add new interface for searching offset with boundary type * format code * fix failed test * unify two BoundaryType class * add interface getOffsetInQueueByTime(long timestamp, BoundaryType boundaryTYpe) in ConsumeQueueInterface * fix AdminBrokerProcessorTest unnecessary Mockito stubbings