aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorvlad <vlad@drivergrp.com>2016-09-23 11:05:17 -0700
committervlad <vlad@drivergrp.com>2016-09-23 11:05:17 -0700
commit40ccc4f46ad521438ad6a208f2002ed252ecd727 (patch)
treeb6f15480c09ea097ae3d21af0cde22569b872dfe
parent2b2d7b3ab03e50c587303ce0fcbe8bcc52900246 (diff)
downloaddriver-core-40ccc4f46ad521438ad6a208f2002ed252ecd727.tar.gz
driver-core-40ccc4f46ad521438ad6a208f2002ed252ecd727.tar.bz2
driver-core-40ccc4f46ad521438ad6a208f2002ed252ecd727.zip
Rest service debug infov0.8.4
-rw-r--r--src/main/scala/com/drivergrp/core/rest.scala6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/main/scala/com/drivergrp/core/rest.scala b/src/main/scala/com/drivergrp/core/rest.scala
index ebfb98e..753fda6 100644
--- a/src/main/scala/com/drivergrp/core/rest.scala
+++ b/src/main/scala/com/drivergrp/core/rest.scala
@@ -59,21 +59,27 @@ object rest {
log.audit(s"Sending to ${request.uri} request $request")
+ Console.print("(((((((((((")
+
val responseEntity = Http()(actorSystem).singleRequest(request)(materializer) map { response =>
if(response.status.isFailure() && response.status != StatusCodes.NotFound) {
+ Console.print(")))))))))")
throw new Exception("Http status is failure " + response.status)
} else {
+ Console.print("OOOOOOOOOOOO")
Unmarshal(response.entity.transformDataBytes(decryptionFlow))
}
}
responseEntity.onComplete {
case Success(r) =>
+ Console.print("1111111111111")
val responseTime = time.currentTime()
log.audit(s"Response from ${request.uri} to request $requestStub is successful")
stats.recordStats(Seq("request", request.uri.toString, "success"), TimeRange(requestTime, responseTime), 1)
case Failure(t: Throwable) =>
+ Console.print("2222222222222")
val responseTime = time.currentTime()
log.audit(s"Failed to receive response from ${request.uri} to request $requestStub")
log.error(s"Failed to receive response from ${request.uri} to request $requestStub", t)