blockingqueue#add -> offer

yue9944882 · yue9944882 · commit b18dbfdc9820 · 2019-08-23T20:58:26.000+08:00
diff --git a/util/src/main/java/io/kubernetes/client/informer/cache/ProcessorListener.java b/util/src/main/java/io/kubernetes/client/informer/cache/ProcessorListener.java
@@ -90,7 +90,9 @@ public void add(Notification<ApiType> obj) {
     if (obj == null) {
       return;
     }
-    this.queue.add(obj);
+    if (!this.queue.offer(obj)) {
+      log.warn("notification queue full!");
+    }
   }
 
   public void determineNextResync(DateTime now) {

Original file line number	Diff line number	Diff line change
`@@ -90,7 +90,9 @@ public void add(Notification<ApiType> obj) {`
`90`	`90`	`if (obj == null) {`
`91`	`91`	`return;`
`92`	`92`	`}`
`93`		`- this.queue.add(obj);`
	`93`	`+ if (!this.queue.offer(obj)) {`
	`94`	`+ log.warn("notification queue full!");`
	`95`	`+ }`
`94`	`96`	`}`
`95`	`97`
`96`	`98`	`public void determineNextResync(DateTime now) {`