Skip to content

INT-3339: Add priority to the JdbcChannelMS #1106

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

Closed
wants to merge 5 commits into from
Closed

INT-3339: Add priority to the JdbcChannelMS #1106

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
72233b3
INT-3339: Add `priority` to the `JdbcChannelMS`
Apr 7, 2014
9db3122
INT-3339: Improve `priority` logic
Apr 8, 2014
db8bc71
INT-3339: Add `MESSAGE_SEQUENCE` stuff
Apr 8, 2014
a9725f9
INT-3339: Docs
Apr 9, 2014
f021e10
INT-3339: Polishing and PR comments
Apr 9, 2014
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 6 additions & 0 deletions ...tion-core/src/main/java/org/springframework/integration/store/BasicMessageGroupStore.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -63,4 +63,10 @@ public interface BasicMessageGroupStore {
*/
Message<?> pollMessageFromGroup(Object groupId);

/**
* Remove the message group with this id.
*
* @param groupId The id of the group to remove.
*/
void removeMessageGroup(Object groupId);
}
Copy link
Contributor

@garyrussell garyrussell Apr 9, 2014

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why did you need to promote this method? ChannelMessageStores don't need to remove their groups.

Copy link
Member Author

@artembilan artembilan Apr 9, 2014

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

No, It's really useful - purge in terms of AMQP

7 changes: 0 additions & 7 deletions ...tegration-core/src/main/java/org/springframework/integration/store/MessageGroupStore.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -59,13 +59,6 @@ public interface MessageGroupStore extends BasicMessageGroupStore {
*/
MessageGroup removeMessageFromGroup(Object key, Message<?> messageToRemove);

/**
* Remove the message group with this id.
*
* @param groupId The id of the group to remove.
*/
void removeMessageGroup(Object groupId);

/**
* Register a callback for when a message group is expired through {@link #expireMessageGroups(long)}.
*
Expand Down
Loading