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