You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@slider.apache.org by st...@apache.org on 2014/05/20 16:02:46 UTC
svn commit: r1596253 -
/incubator/slider/trunk/slider-core/src/main/java/org/apache/slider/server/services/utility/ClosingService.java
Author: stevel
Date: Tue May 20 14:02:46 2014
New Revision: 1596253
URL: http://svn.apache.org/r1596253
Log:
SLIDER-94 templatize closing service
Modified:
incubator/slider/trunk/slider-core/src/main/java/org/apache/slider/server/services/utility/ClosingService.java
Modified: incubator/slider/trunk/slider-core/src/main/java/org/apache/slider/server/services/utility/ClosingService.java
URL: http://svn.apache.org/viewvc/incubator/slider/trunk/slider-core/src/main/java/org/apache/slider/server/services/utility/ClosingService.java?rev=1596253&r1=1596252&r2=1596253&view=diff
==============================================================================
--- incubator/slider/trunk/slider-core/src/main/java/org/apache/slider/server/services/utility/ClosingService.java (original)
+++ incubator/slider/trunk/slider-core/src/main/java/org/apache/slider/server/services/utility/ClosingService.java Tue May 20 14:02:46 2014
@@ -26,13 +26,13 @@ import java.io.Closeable;
/**
* Service that closes the closeable supplied during shutdown, if not null.
*/
-public class ClosingService extends AbstractService {
+public class ClosingService<C extends Closeable> extends AbstractService {
- private Closeable closeable;
+ private volatile C closeable;
public ClosingService(String name,
- Closeable closeable) {
+ C closeable) {
super(name);
this.closeable = closeable;
}
@@ -42,7 +42,7 @@ public class ClosingService extends Abst
return closeable;
}
- public void setCloseable(Closeable closeable) {
+ public void setCloseable(C closeable) {
this.closeable = closeable;
}
@@ -55,6 +55,5 @@ public class ClosingService extends Abst
protected void serviceStop() throws Exception {
IOUtils.closeStream(closeable);
closeable = null;
-
}
}