@@ -74,6 +74,8 @@ private Controller buildController(SharedInformerFactory sharedInformerFactory,
74
74
75
75
KubernetesReconcilerWatches watches = kubernetesReconciler .watches ();
76
76
DefaultControllerBuilder builder = ControllerBuilder .defaultBuilder (sharedInformerFactory );
77
+ RateLimitingQueue <Request > workQueue = new DefaultRateLimitingQueue <>();
78
+ builder = builder .withWorkQueue (workQueue );
77
79
for (KubernetesReconcilerWatch watch : watches .value ()) {
78
80
try {
79
81
Predicate addFilter = null ;
@@ -101,8 +103,8 @@ private Controller buildController(SharedInformerFactory sharedInformerFactory,
101
103
final BiPredicate finalDeleteFilter = deleteFilter ;
102
104
builder =
103
105
builder .watch (
104
- (workQueue ) -> {
105
- return ControllerBuilder .controllerWatchBuilder (watch .apiTypeClass (), workQueue )
106
+ (q ) -> {
107
+ return ControllerBuilder .controllerWatchBuilder (watch .apiTypeClass (), q )
106
108
.withOnAddFilter (finalAddFilter )
107
109
.withOnUpdateFilter (finalUpdateFilter )
108
110
.withOnDeleteFilter (finalDeleteFilter )
@@ -124,8 +126,7 @@ private Controller buildController(SharedInformerFactory sharedInformerFactory,
124
126
builder = builder .withWorkerCount (workerCount .value ());
125
127
}
126
128
127
- RateLimitingQueue <Request > workQueue = new DefaultRateLimitingQueue <>();
128
- return builder .withReconciler (r ).withName (reconcilerName ).withWorkQueue (workQueue ).build ();
129
+ return builder .withReconciler (r ).withName (reconcilerName ).build ();
129
130
}
130
131
131
132
private static class AddFilterAdaptor implements Predicate {
0 commit comments