Error “Deflater has been closed” when logging response body with akka-http
I am using Akka-Http to make a rest server and i want to log requests and results, however I'm getting an exception whenever i try to do runReduce on the response entity. The exception says java.lang.NullPointerException: Deflater has been closed. The exception does not prevent me from logging the body, but i only get gibberish in the log: ��]D�O!�c�?�%{�GY��>������t. Can someone explain why this is happening? I suspect its because the stream that stores the response-body is closed or not opened but i don't know how to solve it.
The set-up for logging is shown below. The logging happens in the logResponse-method inside RequestResponseLogWriter. I use akkas own directives for getting the request and response entities. Logging is done with slf4j.
trait RouteBuilder extends Directives {
val logWriter = new RequestResponseLogWriter()
val routes: Route =
extractRequestContext { context =>
logRequestResult(LoggingMagnet(_ => logWriter.responseLogging(context))) {
ComponentRegistry.searchRestApi.routes
}
}
}
class RequestResponseLogWriter extends LazyLogging {
val responseLogging = (context: RequestContext) => (request: HttpRequest) =>
(result: RouteResult) =>
result match {
case RouteResult.Complete(response) => logResponse(context, request, response)
case RouteResult.Rejected(_) =>
}
private def logResponse(context: RequestContext, request: HttpRequest,
response: HttpResponse): Unit = {
implicit val ec: ExecutionContext = context.executionContext
implicit val mat: Materializer = context.materializer
response.entity.dataBytes.runReduce(_ ++ _)
.foreach(bytes => logger.info(s"Body ${bytes.utf8String}"))
}
}
scala akka-http
asked Jan 18 at 15:54
Eirik ThonEirik Thon
415
add a comment |
I am using Akka-Http to make a rest server and i want to log requests and results, however I'm getting an exception whenever i try to do runReduce on the response entity. The exception says java.lang.NullPointerException: Deflater has been closed. The exception does not prevent me from logging the body, but i only get gibberish in the log: ��]D�O!�c�?�%{�GY��>������t. Can someone explain why this is happening? I suspect its because the stream that stores the response-body is closed or not opened but i don't know how to solve it.
The set-up for logging is shown below. The logging happens in the logResponse-method inside RequestResponseLogWriter. I use akkas own directives for getting the request and response entities. Logging is done with slf4j.
trait RouteBuilder extends Directives {
val logWriter = new RequestResponseLogWriter()
val routes: Route =
extractRequestContext { context =>
logRequestResult(LoggingMagnet(_ => logWriter.responseLogging(context))) {
ComponentRegistry.searchRestApi.routes
}
}
}
class RequestResponseLogWriter extends LazyLogging {
val responseLogging = (context: RequestContext) => (request: HttpRequest) =>
(result: RouteResult) =>
result match {
case RouteResult.Complete(response) => logResponse(context, request, response)
case RouteResult.Rejected(_) =>
}
private def logResponse(context: RequestContext, request: HttpRequest,
response: HttpResponse): Unit = {
implicit val ec: ExecutionContext = context.executionContext
implicit val mat: Materializer = context.materializer
response.entity.dataBytes.runReduce(_ ++ _)
.foreach(bytes => logger.info(s"Body ${bytes.utf8String}"))
}
}
scala akka-http
asked Jan 18 at 15:54
Eirik ThonEirik Thon
415
add a comment |
I am using Akka-Http to make a rest server and i want to log requests and results, however I'm getting an exception whenever i try to do runReduce on the response entity. The exception says java.lang.NullPointerException: Deflater has been closed. The exception does not prevent me from logging the body, but i only get gibberish in the log: ��]D�O!�c�?�%{�GY��>������t. Can someone explain why this is happening? I suspect its because the stream that stores the response-body is closed or not opened but i don't know how to solve it.
The set-up for logging is shown below. The logging happens in the logResponse-method inside RequestResponseLogWriter. I use akkas own directives for getting the request and response entities. Logging is done with slf4j.
trait RouteBuilder extends Directives {
val logWriter = new RequestResponseLogWriter()
val routes: Route =
extractRequestContext { context =>
logRequestResult(LoggingMagnet(_ => logWriter.responseLogging(context))) {
ComponentRegistry.searchRestApi.routes
}
}
}
class RequestResponseLogWriter extends LazyLogging {
val responseLogging = (context: RequestContext) => (request: HttpRequest) =>
(result: RouteResult) =>
result match {
case RouteResult.Complete(response) => logResponse(context, request, response)
case RouteResult.Rejected(_) =>
}
private def logResponse(context: RequestContext, request: HttpRequest,
response: HttpResponse): Unit = {
implicit val ec: ExecutionContext = context.executionContext
implicit val mat: Materializer = context.materializer
response.entity.dataBytes.runReduce(_ ++ _)
.foreach(bytes => logger.info(s"Body ${bytes.utf8String}"))
}
}
scala akka-http
asked Jan 18 at 15:54
Eirik ThonEirik Thon
415
I am using Akka-Http to make a rest server and i want to log requests and results, however I'm getting an exception whenever i try to do runReduce on the response entity. The exception says java.lang.NullPointerException: Deflater has been closed. The exception does not prevent me from logging the body, but i only get gibberish in the log: ��]D�O!�c�?�%{�GY��>������t. Can someone explain why this is happening? I suspect its because the stream that stores the response-body is closed or not opened but i don't know how to solve it.
The set-up for logging is shown below. The logging happens in the logResponse-method inside RequestResponseLogWriter. I use akkas own directives for getting the request and response entities. Logging is done with slf4j.
trait RouteBuilder extends Directives {
val logWriter = new RequestResponseLogWriter()
val routes: Route =
extractRequestContext { context =>
logRequestResult(LoggingMagnet(_ => logWriter.responseLogging(context))) {
ComponentRegistry.searchRestApi.routes
}
}
}
class RequestResponseLogWriter extends LazyLogging {
val responseLogging = (context: RequestContext) => (request: HttpRequest) =>
(result: RouteResult) =>
result match {
case RouteResult.Complete(response) => logResponse(context, request, response)
case RouteResult.Rejected(_) =>
}
private def logResponse(context: RequestContext, request: HttpRequest,
response: HttpResponse): Unit = {
implicit val ec: ExecutionContext = context.executionContext
implicit val mat: Materializer = context.materializer
response.entity.dataBytes.runReduce(_ ++ _)
.foreach(bytes => logger.info(s"Body ${bytes.utf8String}"))
}
}
scala akka-http
scala akka-http
asked Jan 18 at 15:54
Eirik ThonEirik Thon
415
asked Jan 18 at 15:54
Eirik ThonEirik Thon
415
edited 2 days ago
Eirik Thon
asked Jan 18 at 15:54
Eirik ThonEirik Thon
415
asked Jan 18 at 15:54
Eirik ThonEirik Thon
415
asked Jan 18 at 15:54
Eirik ThonEirik Thon
415
415
add a comment |
add a comment |
0
active
oldest
votes
Your Answer
StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");
StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});
function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});
}
});
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f54257372%2ferror-deflater-has-been-closed-when-logging-response-body-with-akka-http%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
0
active
oldest
votes
0
active
oldest
votes
active
oldest
votes
active
oldest
votes
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f54257372%2ferror-deflater-has-been-closed-when-logging-response-body-with-akka-http%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
