[Engine-patches] Change in ovirt-engine[master]: engine: Added Quartz clean up listener

[mkublin]

Michael Kublin has uploaded a new change for review.

Change subject: engine: Added Quartz clean up listener
......................................................................

engine: Added Quartz clean up listener

This listener should be added in order to clean thread context for Quartz 
threads

Change-Id: I97dcf3797853469411173602f8eb64ef0b05d35d
Signed-off-by: Michael Kublin <mkub...@redhat.com>
---
A 
backend/manager/modules/scheduler/src/main/java/org/ovirt/engine/core/utils/timer/CleanUpThreadJobListener.java
M 
backend/manager/modules/scheduler/src/main/java/org/ovirt/engine/core/utils/timer/SchedulerUtilQuartzImpl.java
2 files changed, 32 insertions(+), 0 deletions(-)


  git pull ssh://gerrit.ovirt.org:29418/ovirt-engine refs/changes/43/14543/1

diff --git 
a/backend/manager/modules/scheduler/src/main/java/org/ovirt/engine/core/utils/timer/CleanUpThreadJobListener.java
 
b/backend/manager/modules/scheduler/src/main/java/org/ovirt/engine/core/utils/timer/CleanUpThreadJobListener.java
new file mode 100644
index 0000000..e12c98f
--- /dev/null
+++ 
b/backend/manager/modules/scheduler/src/main/java/org/ovirt/engine/core/utils/timer/CleanUpThreadJobListener.java
@@ -0,0 +1,31 @@
+package org.ovirt.engine.core.utils.timer;
+
+import org.ovirt.engine.core.utils.ThreadLocalParamsContainer;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.quartz.JobListener;
+
+public class CleanUpThreadJobListener implements JobListener {
+
+    private static final String CLEAN_UP_LISTENER_NAME = 
"CleanUpJobListenerName";
+
+    @Override
+    public String getName() {
+        return CLEAN_UP_LISTENER_NAME;
+    }
+
+    @Override
+    public void jobToBeExecuted(JobExecutionContext context) {
+
+    }
+
+    @Override
+    public void jobExecutionVetoed(JobExecutionContext context) {
+
+    }
+
+    @Override
+    public void jobWasExecuted(JobExecutionContext context, 
JobExecutionException jobException) {
+        ThreadLocalParamsContainer.clean();
+    }
+}
diff --git 
a/backend/manager/modules/scheduler/src/main/java/org/ovirt/engine/core/utils/timer/SchedulerUtilQuartzImpl.java
 
b/backend/manager/modules/scheduler/src/main/java/org/ovirt/engine/core/utils/timer/SchedulerUtilQuartzImpl.java
index 0a5bb7e..10b6852 100644
--- 
a/backend/manager/modules/scheduler/src/main/java/org/ovirt/engine/core/utils/timer/SchedulerUtilQuartzImpl.java
+++ 
b/backend/manager/modules/scheduler/src/main/java/org/ovirt/engine/core/utils/timer/SchedulerUtilQuartzImpl.java
@@ -83,6 +83,7 @@
             sched = sf.getScheduler();
             sched.start();
             sched.getListenerManager().addJobListener(new 
FixedDelayJobListener(this), jobGroupEquals(Scheduler.DEFAULT_GROUP));
+            sched.getListenerManager().addJobListener(new 
CleanUpThreadJobListener(), jobGroupEquals(Scheduler.DEFAULT_GROUP));
         } catch (SchedulerException se) {
             log.error("there is a problem with the underlying Scheduler.", se);
         }


--
To view, visit http://gerrit.ovirt.org/14543
To unsubscribe, visit http://gerrit.ovirt.org/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: I97dcf3797853469411173602f8eb64ef0b05d35d
Gerrit-PatchSet: 1
Gerrit-Project: ovirt-engine
Gerrit-Branch: master
Gerrit-Owner: Michael Kublin <mkub...@redhat.com>
_______________________________________________
Engine-patches mailing list
Engine-patches@ovirt.org
http://lists.ovirt.org/mailman/listinfo/engine-patches