Skip to content

Add message_store pattern in IntegrationPatternType #10978

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

Open
mjd507 wants to merge 1 commit into
base: main
Choose a base branch
from
+15 −2
Open

Add message_store pattern in IntegrationPatternType #10978

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.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion ...ntegration-core/src/main/java/org/springframework/integration/IntegrationPatternType.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
* Used to indicate which pattern a target component implements.
*
* @author Artem Bilan
* @author Jiandong Ma
*
* @since 5.3
*/
Expand Down Expand Up @@ -84,6 +85,8 @@ public enum IntegrationPatternType { // NOSONAR Initialization circularity is us

control_bus(IntegrationPatternCategory.system_management),

message_store(IntegrationPatternCategory.system_management),

router(IntegrationPatternCategory.message_routing),

recipient_list_router(IntegrationPatternCategory.message_routing);
Expand Down Expand Up @@ -140,7 +143,9 @@ public enum IntegrationPatternCategory {
claim_check_in,
claim_check_out),

system_management(control_bus);
system_management(
control_bus,
message_store);

private final IntegrationPatternType[] patternTypes;

Expand Down
10 changes: 9 additions & 1 deletion ...ng-integration-core/src/main/java/org/springframework/integration/store/MessageStore.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,8 @@

import org.jspecify.annotations.Nullable;

import org.springframework.integration.IntegrationPattern;
import org.springframework.integration.IntegrationPatternType;
import org.springframework.jmx.export.annotation.ManagedAttribute;
import org.springframework.messaging.Message;

Expand All @@ -30,10 +32,11 @@
* @author Iwein Fuld
* @author Dave Syer
* @author Artem Bilan
* @author Jiandong Ma
*
* @since 2.0
*/
public interface MessageStore {
public interface MessageStore extends IntegrationPattern {

/**
* @param id The message identifier.
Expand Down Expand Up @@ -86,4 +89,9 @@ public interface MessageStore {
@ManagedAttribute
long getMessageCount();

@Override
default IntegrationPatternType getIntegrationPatternType() {
return IntegrationPatternType.message_store;
}

}