Skip to content

Commit 0d90f8c

Browse files
committed
Added Request ID
1 parent ec3edad commit 0d90f8c

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

src/main/java/in/erail/route/OpenAPI3RouteBuilder.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
import com.codahale.metrics.Metered;
55
import com.codahale.metrics.MetricRegistry;
66
import com.codahale.metrics.Timer;
7+
import com.google.common.base.Strings;
78
import com.google.common.net.HttpHeaders;
89
import com.google.common.net.MediaType;
910
import java.io.File;
@@ -31,6 +32,7 @@
3132
import java.util.Arrays;
3233
import java.util.HashMap;
3334
import java.util.Optional;
35+
import java.util.UUID;
3436
import org.apache.commons.lang3.exception.ExceptionUtils;
3537

3638
/**
@@ -39,6 +41,7 @@
3941
*/
4042
public class OpenAPI3RouteBuilder extends AbstractRouterBuilderImpl {
4143

44+
private static final String HEADER_X_REQUEST_ID = "X-Request-ID";
4245
private static final String FAIL_SUFFIX = ".fail";
4346
private RESTService[] mServices;
4447
private File mOpenAPI3File;
@@ -83,6 +86,15 @@ public void process(RoutingContext pRequestContext, String pServiceUniqueId) {
8386

8487
Timer.Context timerCtx = ((Timer) getMetrics().get(pServiceUniqueId)).time();
8588

89+
String requestId = pRequestContext.request().getHeader(HEADER_X_REQUEST_ID);
90+
91+
if (Strings.isNullOrEmpty(requestId)) {
92+
requestId = UUID.randomUUID().toString();
93+
pRequestContext.request().headers().add(HEADER_X_REQUEST_ID, UUID.randomUUID().toString());
94+
}
95+
96+
pRequestContext.response().putHeader(HEADER_X_REQUEST_ID, requestId);
97+
8698
getVertx()
8799
.eventBus()
88100
.send(pServiceUniqueId,

0 commit comments

Comments
 (0)