File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -60,17 +60,17 @@ public void clear() {
60
60
61
61
@ SuppressWarnings ("unchecked" )
62
62
public <R > EventSource <R , P > existingEventSourceOfSameNameAndType (EventSource <R , P > source ) {
63
- return (EventSource <R , P >) existingEventSourceOfSameType (source ).get (source .name ());
63
+ return (EventSource <R , P >) existingEventSourcesOfSameType (source ).get (source .name ());
64
64
}
65
65
66
- private <R > Map <String , EventSource <?, P >> existingEventSourceOfSameType (
66
+ private <R > Map <String , EventSource <?, P >> existingEventSourcesOfSameType (
67
67
EventSource <R , P > source ) {
68
68
return sources .getOrDefault (keyFor (source ), Collections .emptyMap ());
69
69
}
70
70
71
71
public <R > void add (EventSource <R , P > eventSource ) {
72
72
final var name = eventSource .name ();
73
- final var existing = existingEventSourceOfSameType (eventSource );
73
+ final var existing = existingEventSourcesOfSameType (eventSource );
74
74
if (existing .get (name ) != null ) {
75
75
throw new IllegalArgumentException ("Event source " + existing
76
76
+ " is already registered with name: " + name );
You can’t perform that action at this time.
0 commit comments