[sling-org-apache-sling-testing-osgi-mock] 02/05: SLING-5544 osgi-mock: Catch RejectedExecutionException in MockEventAdmin

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rombert pushed a commit to annotated tag org.apache.sling.testing.osgi-mock-2.0.4
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-testing-osgi-mock.git

commit 8a090aa2620dc8186afa00a709b9be6147e01531
Author: Stefan Seifert <ss...@apache.org>
AuthorDate: Mon Feb 22 23:56:17 2016 +0000

    SLING-5544 osgi-mock: Catch RejectedExecutionException in MockEventAdmin
    
    git-svn-id: https://svn.apache.org/repos/asf/sling/trunk/testing/mocks/osgi-mock@1731758 13f79535-47bb-0310-9956-ffa450edef68
---
 .../sling/testing/mock/osgi/MockEventAdmin.java       | 19 +++++++++++++------
 1 file changed, 13 insertions(+), 6 deletions(-)

diff --git a/src/main/java/org/apache/sling/testing/mock/osgi/MockEventAdmin.java b/src/main/java/org/apache/sling/testing/mock/osgi/MockEventAdmin.java
index 55628da..d182d1f 100644
--- a/src/main/java/org/apache/sling/testing/mock/osgi/MockEventAdmin.java
+++ b/src/main/java/org/apache/sling/testing/mock/osgi/MockEventAdmin.java
@@ -22,6 +22,7 @@ import java.util.Map;
 import java.util.TreeMap;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.RejectedExecutionException;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
@@ -69,12 +70,18 @@ public final class MockEventAdmin implements EventAdmin {
 
     @Override
     public void postEvent(final Event event) {
-        asyncHandler.execute(new Runnable() {
-            @Override
-            public void run() {
-                distributeEvent(event);
-            }
-        });
+        try {
+            asyncHandler.execute(new Runnable() {
+                @Override
+                public void run() {
+                    distributeEvent(event);
+                }
+            });
+        }
+        catch (RejectedExecutionException ex) {
+            // ignore
+            log.debug("Ignore rejected execution: " + ex.getMessage(), ex);;
+        }
     }
 
     @Override

-- 
To stop receiving notification emails like this one, please contact
"commits@sling.apache.org" <co...@sling.apache.org>.