diff options
Diffstat (limited to 'src/org/traccar/WrapperContext.java')
-rw-r--r-- | src/org/traccar/WrapperContext.java | 255 |
1 files changed, 0 insertions, 255 deletions
diff --git a/src/org/traccar/WrapperContext.java b/src/org/traccar/WrapperContext.java deleted file mode 100644 index 372d3c60d..000000000 --- a/src/org/traccar/WrapperContext.java +++ /dev/null @@ -1,255 +0,0 @@ -/* - * Copyright 2018 Anton Tananaev (anton@traccar.org) - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.traccar; - -import io.netty.buffer.ByteBufAllocator; -import io.netty.channel.Channel; -import io.netty.channel.ChannelFuture; -import io.netty.channel.ChannelHandler; -import io.netty.channel.ChannelHandlerContext; -import io.netty.channel.ChannelPipeline; -import io.netty.channel.ChannelProgressivePromise; -import io.netty.channel.ChannelPromise; -import io.netty.util.Attribute; -import io.netty.util.AttributeKey; -import io.netty.util.concurrent.EventExecutor; - -import java.net.SocketAddress; - -public class WrapperContext implements ChannelHandlerContext { - - private ChannelHandlerContext context; - private SocketAddress remoteAddress; - - public WrapperContext(ChannelHandlerContext context, SocketAddress remoteAddress) { - this.context = context; - this.remoteAddress = remoteAddress; - } - - @Override - public Channel channel() { - return context.channel(); - } - - @Override - public EventExecutor executor() { - return context.executor(); - } - - @Override - public String name() { - return context.name(); - } - - @Override - public ChannelHandler handler() { - return context.handler(); - } - - @Override - public boolean isRemoved() { - return context.isRemoved(); - } - - @Override - public ChannelHandlerContext fireChannelRegistered() { - return context.fireChannelRegistered(); - } - - @Override - public ChannelHandlerContext fireChannelUnregistered() { - return context.fireChannelUnregistered(); - } - - @Override - public ChannelHandlerContext fireChannelActive() { - return context.fireChannelActive(); - } - - @Override - public ChannelHandlerContext fireChannelInactive() { - return context.fireChannelInactive(); - } - - @Override - public ChannelHandlerContext fireExceptionCaught(Throwable cause) { - return context.fireExceptionCaught(cause); - } - - @Override - public ChannelHandlerContext fireUserEventTriggered(Object evt) { - return context.fireUserEventTriggered(evt); - } - - @Override - public ChannelHandlerContext fireChannelRead(Object msg) { - if (!(msg instanceof NetworkMessage)) { - msg = new NetworkMessage(msg, remoteAddress); - } - return context.fireChannelRead(msg); - } - - @Override - public ChannelHandlerContext fireChannelReadComplete() { - return context.fireChannelReadComplete(); - } - - @Override - public ChannelHandlerContext fireChannelWritabilityChanged() { - return context.fireChannelWritabilityChanged(); - } - - @Override - public ChannelFuture bind(SocketAddress localAddress) { - return context.bind(localAddress); - } - - @Override - public ChannelFuture connect(SocketAddress remoteAddress) { - return context.connect(remoteAddress); - } - - @Override - public ChannelFuture connect(SocketAddress remoteAddress, SocketAddress localAddress) { - return context.connect(remoteAddress, localAddress); - } - - @Override - public ChannelFuture disconnect() { - return context.disconnect(); - } - - @Override - public ChannelFuture close() { - return context.close(); - } - - @Override - public ChannelFuture deregister() { - return context.deregister(); - } - - @Override - public ChannelFuture bind(SocketAddress localAddress, ChannelPromise promise) { - return context.bind(localAddress, promise); - } - - @Override - public ChannelFuture connect(SocketAddress remoteAddress, ChannelPromise promise) { - return context.connect(remoteAddress, promise); - } - - @Override - public ChannelFuture connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) { - return context.connect(remoteAddress, localAddress, promise); - } - - @Override - public ChannelFuture disconnect(ChannelPromise promise) { - return context.disconnect(promise); - } - - @Override - public ChannelFuture close(ChannelPromise promise) { - return context.close(promise); - } - - @Override - public ChannelFuture deregister(ChannelPromise promise) { - return context.deregister(promise); - } - - @Override - public ChannelHandlerContext read() { - return context.read(); - } - - @Override - public ChannelFuture write(Object msg) { - return context.write(msg); - } - - @Override - public ChannelFuture write(Object msg, ChannelPromise promise) { - if (!(msg instanceof NetworkMessage)) { - msg = new NetworkMessage(msg, remoteAddress); - } - return context.write(msg, promise); - } - - @Override - public ChannelHandlerContext flush() { - return context.flush(); - } - - @Override - public ChannelFuture writeAndFlush(Object msg, ChannelPromise promise) { - return context.writeAndFlush(msg, promise); - } - - @Override - public ChannelFuture writeAndFlush(Object msg) { - return context.writeAndFlush(msg); - } - - @Override - public ChannelPromise newPromise() { - return context.newPromise(); - } - - @Override - public ChannelProgressivePromise newProgressivePromise() { - return context.newProgressivePromise(); - } - - @Override - public ChannelFuture newSucceededFuture() { - return context.newSucceededFuture(); - } - - @Override - public ChannelFuture newFailedFuture(Throwable cause) { - return context.newFailedFuture(cause); - } - - @Override - public ChannelPromise voidPromise() { - return context.voidPromise(); - } - - @Override - public ChannelPipeline pipeline() { - return context.pipeline(); - } - - @Override - public ByteBufAllocator alloc() { - return context.alloc(); - } - - @SuppressWarnings("deprecation") - @Override - public <T> Attribute<T> attr(AttributeKey<T> key) { - return context.attr(key); - } - - @SuppressWarnings("deprecation") - @Override - public <T> boolean hasAttr(AttributeKey<T> key) { - return context.hasAttr(key); - } - -} |