Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[ISSUE #3604] Some important interface methods add comment #3606

Merged
merged 1 commit into from
Dec 8, 2021
Merged

[ISSUE #3604] Some important interface methods add comment #3606

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
4 changes: 4 additions & 0 deletions store/src/main/java/org/apache/rocketmq/store/CommitLogDispatcher.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,5 +22,9 @@
*/
public interface CommitLogDispatcher {

/**
* Dispatch messages from store to build consume queues, indexes, and filter data
* @param request dispatch message request
*/
void dispatch(final DispatchRequest request);
}
11 changes: 11 additions & 0 deletions store/src/main/java/org/apache/rocketmq/store/MessageArrivingListener.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,17 @@
import java.util.Map;

public interface MessageArrivingListener {

/**
* Notify that a new message arrives in a consume queue
* @param topic topic name
* @param queueId consume queue id
* @param logicOffset consume queue offset
* @param tagsCode message tags hash code
* @param msgStoreTime message store time
* @param filterBitMap message bloom filter
* @param properties message properties
*/
void arriving(String topic, int queueId, long logicOffset, long tagsCode,
long msgStoreTime, byte[] filterBitMap, Map<String, String> properties);
}