001
014
015 package com.liferay.portal.fabric.local.worker;
016
017 import com.liferay.portal.fabric.status.JMXProxyUtil.ProcessCallableExecutor;
018 import com.liferay.portal.kernel.concurrent.NoticeableFuture;
019 import com.liferay.portal.kernel.process.ProcessCallable;
020 import com.liferay.portal.kernel.process.ProcessChannel;
021
022 import java.io.Serializable;
023
024
027 public class LocalFabricWorkerProcessCallableExecutor
028 implements ProcessCallableExecutor {
029
030 public LocalFabricWorkerProcessCallableExecutor(
031 ProcessChannel<? extends Serializable> processChannel) {
032
033 _processChannel = processChannel;
034 }
035
036 @Override
037 public <V extends Serializable> NoticeableFuture<V> execute(
038 ProcessCallable<V> processCallable) {
039
040 return _processChannel.write(processCallable);
041 }
042
043 private final ProcessChannel<? extends Serializable> _processChannel;
044
045 }