X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fconfig%2Fnetty-event-executor-config%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fyang%2Fnetty%2Feventexecutor%2FAutoCloseableEventExecutor.java;h=cb721db67d597cac0efc0ef93341c8b264f1a98f;hp=69ea51f3a50eb5f5c762054e0988bf2cb6ee8fbf;hb=9832745f5d61833705269a0004a83b39e81bddce;hpb=f6b5466e99888936c69e12d732162e9ee4e0e490

diff --git a/opendaylight/config/netty-event-executor-config/src/main/java/org/opendaylight/controller/config/yang/netty/eventexecutor/AutoCloseableEventExecutor.java b/opendaylight/config/netty-event-executor-config/src/main/java/org/opendaylight/controller/config/yang/netty/eventexecutor/AutoCloseableEventExecutor.java
index 69ea51f3a5..cb721db67d 100644
--- a/opendaylight/config/netty-event-executor-config/src/main/java/org/opendaylight/controller/config/yang/netty/eventexecutor/AutoCloseableEventExecutor.java
+++ b/opendaylight/config/netty-event-executor-config/src/main/java/org/opendaylight/controller/config/yang/netty/eventexecutor/AutoCloseableEventExecutor.java
@@ -10,7 +10,8 @@ package org.opendaylight.controller.config.yang.netty.eventexecutor;
 import com.google.common.reflect.AbstractInvocationHandler;
 import com.google.common.reflect.Reflection;
 import io.netty.util.concurrent.EventExecutor;
-
+import io.netty.util.concurrent.GlobalEventExecutor;
+import io.netty.util.concurrent.ImmediateEventExecutor;
 import java.lang.reflect.Method;
 import java.util.concurrent.TimeUnit;
 
@@ -31,7 +32,7 @@ public interface AutoCloseableEventExecutor extends EventExecutor, AutoCloseable
         }
 
 
-        public static AutoCloseable createCloseableProxy(final EventExecutor eventExecutor) {
+        private static AutoCloseableEventExecutor createCloseableProxy(final EventExecutor eventExecutor) {
             final CloseableEventExecutorMixin closeableGlobalEventExecutorMixin =
                     new CloseableEventExecutorMixin(eventExecutor);
             return Reflection.newProxy(AutoCloseableEventExecutor.class, new AbstractInvocationHandler() {
@@ -47,6 +48,12 @@ public interface AutoCloseableEventExecutor extends EventExecutor, AutoCloseable
             });
         }
 
+        public static AutoCloseableEventExecutor globalEventExecutor() {
+            return createCloseableProxy(GlobalEventExecutor.INSTANCE);
+        }
 
+        public static AutoCloseableEventExecutor immediateEventExecutor() {
+            return createCloseableProxy(ImmediateEventExecutor.INSTANCE);
+        }
     }
 }
\ No newline at end of file