diff options
author | Anton Tananaev <anton@traccar.org> | 2024-03-30 19:41:51 -0700 |
---|---|---|
committer | Anton Tananaev <anton@traccar.org> | 2024-03-30 19:41:51 -0700 |
commit | 2d366f0ab3d88c635bec0f1f498396cd47557f1d (patch) | |
tree | 63736bf5f7bc659d80c5f1eaf286ba0d71498e5d | |
parent | e7205fa3d1aa6d223cfabfabb32f027415956430 (diff) | |
download | trackermap-server-2d366f0ab3d88c635bec0f1f498396cd47557f1d.tar.gz trackermap-server-2d366f0ab3d88c635bec0f1f498396cd47557f1d.tar.bz2 trackermap-server-2d366f0ab3d88c635bec0f1f498396cd47557f1d.zip |
Fix remote address handler
-rw-r--r-- | src/main/java/org/traccar/BasePipelineFactory.java | 2 | ||||
-rw-r--r-- | src/main/java/org/traccar/handler/network/RemoteAddressHandler.java | 2 |
2 files changed, 3 insertions, 1 deletions
diff --git a/src/main/java/org/traccar/BasePipelineFactory.java b/src/main/java/org/traccar/BasePipelineFactory.java index 6d9431ad6..40360cca7 100644 --- a/src/main/java/org/traccar/BasePipelineFactory.java +++ b/src/main/java/org/traccar/BasePipelineFactory.java @@ -96,7 +96,6 @@ public abstract class BasePipelineFactory extends ChannelInitializer<Channel> { pipeline.addLast(injectMembers(new NetworkForwarderHandler(port))); } pipeline.addLast(new NetworkMessageHandler()); - pipeline.addLast(new RemoteAddressHandler(config)); pipeline.addLast(injectMembers(new StandardLoggingHandler(protocol))); if (!connector.isDatagram() && !config.getBoolean(Keys.SERVER_INSTANT_ACKNOWLEDGEMENT)) { @@ -116,6 +115,7 @@ public abstract class BasePipelineFactory extends ChannelInitializer<Channel> { pipeline.addLast(handler); }); + pipeline.addLast(injector.getInstance(RemoteAddressHandler.class)); pipeline.addLast(injector.getInstance(ProcessingHandler.class)); pipeline.addLast(injector.getInstance(MainEventHandler.class)); } diff --git a/src/main/java/org/traccar/handler/network/RemoteAddressHandler.java b/src/main/java/org/traccar/handler/network/RemoteAddressHandler.java index d545ed799..c52bb2be1 100644 --- a/src/main/java/org/traccar/handler/network/RemoteAddressHandler.java +++ b/src/main/java/org/traccar/handler/network/RemoteAddressHandler.java @@ -19,12 +19,14 @@ import io.netty.channel.ChannelHandler; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; import jakarta.inject.Inject; +import jakarta.inject.Singleton; import org.traccar.config.Config; import org.traccar.config.Keys; import org.traccar.model.Position; import java.net.InetSocketAddress; +@Singleton @ChannelHandler.Sharable public class RemoteAddressHandler extends ChannelInboundHandlerAdapter { |