@@ -254,18 +254,9 @@ public void channelRead(final ChannelHandlerContext ctx, final Object msg) {
254
254
255
255
evalFuture .exceptionally (t -> {
256
256
257
- if (t .getMessage () != null ) {
258
- sendError (ctx , INTERNAL_SERVER_ERROR ,
259
- String .format ("Error encountered evaluating script: %s\n Execution Interrupted by %s\n Message: %s" ,
260
- requestArguments .getValue0 (), t .getClass ().getName (), t .getMessage ()),
261
- Optional .of (t ));
262
- } else {
263
- sendError (ctx , INTERNAL_SERVER_ERROR ,
264
- String .format ("Error encountered evaluating script: %s\n Execution Interrupted by %s" ,
265
- requestArguments .getValue0 (), t .getClass ().getName ()),
266
- Optional .of (t ));
267
- }
268
-
257
+ String errorMessage = (t .getMessage () != null ) ? t .getMessage () :
258
+ String .format ("Error encountered evaluating script: %s" , requestArguments .getValue0 ());
259
+ sendError (ctx , INTERNAL_SERVER_ERROR , errorMessage , Optional .of (t ));
269
260
promise .setFailure (t );
270
261
return null ;
271
262
});
@@ -465,6 +456,11 @@ private static void sendError(final ChannelHandlerContext ctx, final HttpRespons
465
456
errorMeter .mark ();
466
457
final ObjectNode node = mapper .createObjectNode ();
467
458
node .put ("message" , message );
459
+ if (t .isPresent ()){
460
+ node .put ("Exception-Class" , t .get ().getClass ().getName ());
461
+ }
462
+
463
+
468
464
final FullHttpResponse response = new DefaultFullHttpResponse (
469
465
HTTP_1_1 , status , Unpooled .copiedBuffer (node .toString (), CharsetUtil .UTF_8 ));
470
466
response .headers ().set (CONTENT_TYPE , "application/json" );
0 commit comments