diff options
author | Jakub Dudycz <jakub.dudycz@nokia.com> | 2018-03-15 14:46:35 +0100 |
---|---|---|
committer | Takamune Cho <tc012c@att.com> | 2018-03-15 15:06:06 +0000 |
commit | 286ef6e7dc5baea219a29bd5f81ea3eabf96e7b4 (patch) | |
tree | ea909b7c915c8a43f899ebc85e0a9add70a31a72 /appc-event-listener/appc-event-listener-bundle/src/main | |
parent | 1275e425d9064fed66532aa2fddb34023dfd99b6 (diff) |
AbstractListener unit tests
Improved code coverage.
Change-Id: I131f8bbbc72e0587572baa340d10fb56f6a1c5bc
Issue-ID: APPC-747
Signed-off-by: Jakub Dudycz <jakub.dudycz@nokia.com>
Diffstat (limited to 'appc-event-listener/appc-event-listener-bundle/src/main')
-rw-r--r-- | appc-event-listener/appc-event-listener-bundle/src/main/java/org/onap/appc/listener/AbstractListener.java | 6 |
1 files changed, 0 insertions, 6 deletions
diff --git a/appc-event-listener/appc-event-listener-bundle/src/main/java/org/onap/appc/listener/AbstractListener.java b/appc-event-listener/appc-event-listener-bundle/src/main/java/org/onap/appc/listener/AbstractListener.java index 89c75a357..be19cf3aa 100644 --- a/appc-event-listener/appc-event-listener-bundle/src/main/java/org/onap/appc/listener/AbstractListener.java +++ b/appc-event-listener/appc-event-listener-bundle/src/main/java/org/onap/appc/listener/AbstractListener.java @@ -43,18 +43,13 @@ public abstract class AbstractListener implements Listener { private final EELFLogger LOG = EELFManager.getInstance().getLogger(AbstractListener.class); protected AtomicBoolean run = new AtomicBoolean(false); - protected int QUEUED_MIN = 1; protected int QUEUED_MAX = 10; - protected int THREAD_MIN = 4; protected int THREAD_MAX = THREAD_MIN; // Fixed thread pool protected int THREAD_SCALE_DOWN_SEC = 10; // Number of seconds to wait until we remove idle threads - protected ThreadPoolExecutor executor; - protected EventHandler dmaap; - protected ListenerProperties props; private String listenerId; @@ -157,6 +152,5 @@ public abstract class AbstractListener implements Listener { public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { LOG.error(String.format("A job was rejected. [%s]", r)); } - } } |