You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tomee.apache.org by rm...@apache.org on 2014/08/10 13:08:20 UTC
svn commit: r1617089 -
/tomee/tomee/trunk/container/openejb-core/src/main/java/org/apache/openejb/threads/impl/ManagedScheduledExecutorServiceImpl.java
Author: rmannibucau
Date: Sun Aug 10 11:08:19 2014
New Revision: 1617089
URL: http://svn.apache.org/r1617089
Log:
some java generic
Modified:
tomee/tomee/trunk/container/openejb-core/src/main/java/org/apache/openejb/threads/impl/ManagedScheduledExecutorServiceImpl.java
Modified: tomee/tomee/trunk/container/openejb-core/src/main/java/org/apache/openejb/threads/impl/ManagedScheduledExecutorServiceImpl.java
URL: http://svn.apache.org/viewvc/tomee/tomee/trunk/container/openejb-core/src/main/java/org/apache/openejb/threads/impl/ManagedScheduledExecutorServiceImpl.java?rev=1617089&r1=1617088&r2=1617089&view=diff
==============================================================================
--- tomee/tomee/trunk/container/openejb-core/src/main/java/org/apache/openejb/threads/impl/ManagedScheduledExecutorServiceImpl.java (original)
+++ tomee/tomee/trunk/container/openejb-core/src/main/java/org/apache/openejb/threads/impl/ManagedScheduledExecutorServiceImpl.java Sun Aug 10 11:08:19 2014
@@ -60,7 +60,7 @@ public class ManagedScheduledExecutorSer
public <V> ScheduledFuture<V> schedule(final Callable<V> vCallable, final Trigger trigger) {
final Date taskScheduledTime = new Date();
final AtomicReference<Future<V>> futureHandle = new AtomicReference<Future<V>>();
- final TriggerCallable<V> wrapper = new TriggerCallable<V>(this, vCallable, new CUCallable<V>(vCallable), trigger, taskScheduledTime, getTaskId(vCallable), futureHandle);
+ final TriggerCallable<V> wrapper = new TriggerCallable<>(this, vCallable, new CUCallable<>(vCallable), trigger, taskScheduledTime, getTaskId(vCallable), futureHandle);
final ScheduledFuture<V> future = delegate.schedule(wrapper, trigger.getNextRunTime(wrapper.getLastExecution(), taskScheduledTime).getTime() - nowMs(), TimeUnit.MILLISECONDS);
return initTriggerScheduledFuture(vCallable, futureHandle, wrapper, future);
}
@@ -69,7 +69,7 @@ public class ManagedScheduledExecutorSer
final TriggerTask<V> wrapper, final ScheduledFuture<V> future) {
futureHandle.set(future);
wrapper.taskSubmitted(future, this, original);
- return new CUScheduleFuture<V>(ScheduledFutureFacade.<V>newProxy(futureHandle), wrapper);
+ return new CUScheduleFuture<>(ScheduledFutureFacade.newProxy(futureHandle), wrapper);
}
@Override
@@ -85,7 +85,7 @@ public class ManagedScheduledExecutorSer
final CUCallable<V> wrapper = new CUCallable<V>(callable);
final ScheduledFuture<V> future = delegate.schedule(wrapper, delay, unit);
wrapper.taskSubmitted(future, this, callable);
- return new CUScheduleFuture<V>(future, wrapper);
+ return new CUScheduleFuture<>(future, wrapper);
}
@Override