From 4056ef4ade20a8e3e715525d9c0ac2faaa5faa96 Mon Sep 17 00:00:00 2001
From: Ninad Sinha <ninad@metlo.com>
Date: Wed, 2 Nov 2022 03:27:27 +0530
Subject: [PATCH] Add metlo endpoint to address

---
 ingestors/java/spring/pom.xml                                  | 2 +-
 .../java/spring/src/main/java/com/metlo/spring/Metlo.java      | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/ingestors/java/spring/pom.xml b/ingestors/java/spring/pom.xml
index fc89bd6a..fa9c35de 100644
--- a/ingestors/java/spring/pom.xml
+++ b/ingestors/java/spring/pom.xml
@@ -104,7 +104,7 @@
 
     <groupId>com.metlo</groupId>
     <artifactId>spring</artifactId>
-    <version>0.2</version>
+    <version>0.2.2</version>
 
     <dependencies>
         <dependency>
diff --git a/ingestors/java/spring/src/main/java/com/metlo/spring/Metlo.java b/ingestors/java/spring/src/main/java/com/metlo/spring/Metlo.java
index 51630699..a5a34992 100644
--- a/ingestors/java/spring/src/main/java/com/metlo/spring/Metlo.java
+++ b/ingestors/java/spring/src/main/java/com/metlo/spring/Metlo.java
@@ -24,6 +24,7 @@
 
 public class Metlo extends OncePerRequestFilter {
     private static final int DEFAULT_THREAD_POOL_SIZE = 8;
+    private final static String endpoint = "/api/v1/log-request/single";
     private final ThreadPoolExecutor pool;
     private final String METLO_KEY;
     private final String METLO_ADDR;
@@ -34,7 +35,7 @@ public Metlo(String host, String api_key) {
 
     public Metlo(int pool_size, String host, String api_key) {
         this.METLO_KEY = api_key;
-        this.METLO_ADDR = host;
+        this.METLO_ADDR = host + Metlo.endpoint;
         this.pool = new ThreadPoolExecutor(0, pool_size,
                 60L, TimeUnit.SECONDS,
                 new SynchronousQueue<Runnable>());