AbhishekKumar2244 commented on issue #6525:
URL: https://github.com/apache/rocketmq/issues/6525#issuecomment-1493236005
public abstract class FileQueueLifeCycle {
// Existing functionality that was previously duplicated in
ConsumeQueueInterface
public void start() {
// Start the file queue lifecycle
}
public void stop() {
// Stop the file queue lifecycle
}
// Additional functionality that may be required
}
public interface ConsumeQueueInterface extends FileQueueLifeCycle {
// Existing functionality that was previously in ConsumeQueueInterface
// No need to redefine any methods already defined in FileQueueLifeCycle
}
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
