Toggle navigation
Home
java.util.concurrent.Executor to java.util.concurrent.ExecutorService
No. of Instances - 6
No. of Commits - 2
No. of Projects - {'drools'}
Hierarchy/Composition: T_SUPER_R
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
Other
new DaemonThreadFactory()
to
ExecutorHolder.threadFactory
Cascading Type Change (Different)
ExecutorCompletionService<Boolean>
to
ExecutorCompletionService<>
ExecutorCompletionService<Boolean>
to
ExecutorCompletionService<>
Exception
to
Throwable
Rename Variable
workerPool
to
pool
workerPool
to
pool
workerPool
to
pool
workerPool
to
pool
Add or Remove Method invocation
invokeMethod(remoteInterface,requestQueue,request,method,responseName,executor)
to
runMethod(remoteInterface,requestQueue,executor,request,method,responseName)
Update Anonymous class
{ @Override public void operationComplete( Future<Boolean> future) throws Exception { if (!future.isSuccess()) { log.error("Can't send ack for request: " + request,future.cause()); if (future.cause() instanceof RedissonShutdownException) { return; } subscribe(remoteInterface,requestQueue,executor); return; } if (!future.getNow()) { subscribe(remoteInterface,requestQueue,executor); return; } if (executor != null) { executor.execute(new Runnable(){ @Override public void run(){ invokeMethod(remoteInterface,requestQueue,request,method,responseName,executor); } } ); } else { invokeMethod(remoteInterface,requestQueue,request,method,responseName,executor); } } }
to
{ @Override public void operationComplete( Future<Boolean> future) throws Exception { if (!future.isSuccess()) { log.error("Can't send ack for request: " + request,future.cause()); if (future.cause() instanceof RedissonShutdownException) { return; } subscribe(remoteInterface,requestQueue,executor); return; } if (!future.getNow()) { subscribe(remoteInterface,requestQueue,executor); return; } runMethod(remoteInterface,requestQueue,executor,request,method,responseName); } }
Rename Method invocation
execute
to
submit
execute
to
submit