File tree Expand file tree Collapse file tree 2 files changed +7
-13
lines changed
operator-framework-core/src/main/java/io/javaoperatorsdk/operator Expand file tree Collapse file tree 2 files changed +7
-13
lines changed Original file line number Diff line number Diff line change 8
8
import org .slf4j .Logger ;
9
9
import org .slf4j .LoggerFactory ;
10
10
11
- import io .javaoperatorsdk .operator .api .config .ExecutorServiceManager ;
12
11
import io .javaoperatorsdk .operator .processing .Controller ;
13
12
14
13
/**
@@ -33,25 +32,20 @@ public synchronized void shouldStart() {
33
32
}
34
33
35
34
public synchronized void start (boolean startEventProcessor ) {
36
- ExecutorServiceManager .executeAndWaitForCompletion (
37
- () -> controllers ().parallelStream ().forEach (c -> c .start (startEventProcessor )),
38
- "ControllerStart" );
35
+ controllers ().parallelStream ().forEach (c -> c .start (startEventProcessor ));
39
36
started = true ;
40
37
}
41
38
42
39
public synchronized void stop () {
43
- ExecutorServiceManager .executeAndWaitForCompletion (
44
- () -> controllers ().parallelStream ().forEach (closeable -> {
45
- log .debug ("closing {}" , closeable );
46
- closeable .stop ();
47
- }), "ControllerStop" );
40
+ controllers ().parallelStream ().forEach (closeable -> {
41
+ log .debug ("closing {}" , closeable );
42
+ closeable .stop ();
43
+ });
48
44
started = false ;
49
45
}
50
46
51
47
public synchronized void startEventProcessing () {
52
- ExecutorServiceManager .executeAndWaitForCompletion (
53
- () -> controllers ().parallelStream ().forEach (Controller ::startEventProcessing ),
54
- "ControllerEventProcessing" );
48
+ controllers ().parallelStream ().forEach (Controller ::startEventProcessing );
55
49
}
56
50
57
51
@ SuppressWarnings ({"unchecked" , "rawtypes" })
Original file line number Diff line number Diff line change @@ -360,8 +360,8 @@ public void changeNamespaces(Set<String> namespaces) {
360
360
}
361
361
362
362
public synchronized void startEventProcessing () {
363
- log .info ("Started event processing for controller: {}" , configuration .getName ());
364
363
eventProcessor .start ();
364
+ log .info ("Started event processing for controller: {}" , configuration .getName ());
365
365
}
366
366
367
367
private void throwMissingCRDException (String crdName , String specVersion , String controllerName ) {
You can’t perform that action at this time.
0 commit comments