001
014
015 package com.liferay.portal.fabric.netty.agent;
016
017 import com.liferay.portal.fabric.netty.rpc.RPCUtil;
018 import com.liferay.portal.fabric.netty.rpc.SyncProcessRPCCallable;
019 import com.liferay.portal.fabric.status.JMXProxyUtil.ProcessCallableExecutor;
020 import com.liferay.portal.kernel.concurrent.NoticeableFuture;
021 import com.liferay.portal.kernel.process.ProcessCallable;
022
023 import io.netty.channel.Channel;
024
025 import java.io.Serializable;
026
027
030 public class NettyFabricAgentProcessCallableExecutor
031 implements ProcessCallableExecutor {
032
033 public NettyFabricAgentProcessCallableExecutor(Channel channel) {
034 _channel = channel;
035 }
036
037 @Override
038 public <V extends Serializable> NoticeableFuture<V> execute(
039 ProcessCallable<V> processCallable) {
040
041 return RPCUtil.execute(
042 _channel, new SyncProcessRPCCallable<V>(processCallable));
043 }
044
045 private final Channel _channel;
046
047 }