Log remote address in case of unauthorized tenant

EinsamHauer · Dec 12, 2021 · efa371e · efa371e
1 parent d8ef888
commit efa371e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -4,7 +4,7 @@
     <groupId>net.iponweb.disthene</groupId>
     <artifactId>disthene</artifactId>
     <packaging>jar</packaging>
-    <version>1.0.11</version>
+    <version>1.0.12</version>
     <name>disthene</name>
     <url>http://maven.apache.org</url>
     <dependencies>

diff --git a/src/main/java/net/iponweb/disthene/carbon/CarbonServerHandler.java b/src/main/java/net/iponweb/disthene/carbon/CarbonServerHandler.java
@@ -14,6 +14,8 @@
 import org.apache.commons.codec.binary.Hex;
 import org.apache.log4j.Logger;
 
+import java.net.InetSocketAddress;
+
 /**
  * @author Andrei Ivanov
  */
@@ -53,7 +55,7 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
 
             if (!tenantService.isTenantAllowed(metric.getTenant())) {
                 isValid = false;
-                logger.warn("Unauthorized tenant: " + metric.getTenant() + ". Discarding metric: " + metric);
+                logger.warn("Unauthorized tenant: " + metric.getTenant() + ". Discarding metric: " + metric + ". Source ip: " + ((InetSocketAddress)ctx.channel().remoteAddress()).getAddress());
             }
 
             //noinspection UnstableApiUsage