Skip to content

Commit 75cd34c

Browse files
committed
Update ResourceProvider to use anonymous class
Signed-off-by: Daniel Widdis <[email protected]>
1 parent bb8caa9 commit 75cd34c

File tree

1 file changed

+21
-4
lines changed

1 file changed

+21
-4
lines changed

src/main/java/org/opensearch/flowframework/FlowFrameworkResourceSharingExtension.java

Lines changed: 21 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,27 @@
2222
public class FlowFrameworkResourceSharingExtension implements ResourceSharingExtension {
2323
@Override
2424
public Set<ResourceProvider> getResourceProviders() {
25-
return Set.of(
26-
new ResourceProvider(CommonValue.WORKFLOW_RESOURCE_TYPE, GLOBAL_CONTEXT_INDEX),
27-
new ResourceProvider(CommonValue.WORKFLOW_STATE_RESOURCE_TYPE, WORKFLOW_STATE_INDEX)
28-
);
25+
return Set.of(new ResourceProvider() {
26+
@Override
27+
public String resourceType() {
28+
return CommonValue.WORKFLOW_RESOURCE_TYPE;
29+
}
30+
31+
@Override
32+
public String resourceIndexName() {
33+
return GLOBAL_CONTEXT_INDEX;
34+
}
35+
}, new ResourceProvider() {
36+
@Override
37+
public String resourceType() {
38+
return CommonValue.WORKFLOW_STATE_RESOURCE_TYPE;
39+
}
40+
41+
@Override
42+
public String resourceIndexName() {
43+
return WORKFLOW_STATE_INDEX;
44+
}
45+
});
2946
}
3047

3148
@Override

0 commit comments

Comments
 (0)