001
014
015 package com.liferay.portal.fabric.netty.rpc;
016
017 import com.liferay.portal.kernel.util.CentralizedThreadLocal;
018
019 import io.netty.channel.Channel;
020
021
024 public class ChannelThreadLocal {
025
026 public static Channel getChannel() {
027 Channel channel = _channelThreadLocal.get();
028
029 if (channel == null) {
030 throw new IllegalStateException("Channel is null");
031 }
032
033 return channel;
034 }
035
036 public static void removeChannel() {
037 _channelThreadLocal.remove();
038 }
039
040 public static void setChannel(Channel channel) {
041 _channelThreadLocal.set(channel);
042 }
043
044 private static final ThreadLocal<Channel> _channelThreadLocal =
045 new CentralizedThreadLocal<>(false);
046
047 }