Cleaning up logging in RestAPI
parent
0e90043cf8
commit
429f55e423
|
@ -13,6 +13,7 @@
|
|||
|
||||
<logger name="org.bff.javampd.server.Status" level="ERROR" />
|
||||
<logger name="net.okennedy.shingle.component.Mqtt$" level="WARN" />
|
||||
<logger name="net.okennedy.shingle.component.RestAPI" level="INFO" />
|
||||
|
||||
<root level="WARN">
|
||||
<appender-ref ref="STDOUT" />
|
||||
|
|
|
@ -11,15 +11,16 @@ import net.okennedy.shingle.cron.Cron
|
|||
import scala.concurrent.duration._
|
||||
import requests.RequestFailedException
|
||||
import net.okennedy.shingle.stream._
|
||||
import com.typesafe.scalalogging.LazyLogging
|
||||
|
||||
case class RestAPI(
|
||||
val url: String,
|
||||
val headers: Iterable[(String, String)] = Seq.empty,
|
||||
)
|
||||
) extends LazyLogging
|
||||
{
|
||||
def get: Try[String] =
|
||||
{
|
||||
println(s"Fetching $url")
|
||||
logger.info(s"Fetching $url")
|
||||
try {
|
||||
val result = requests.get(
|
||||
url = url,
|
||||
|
@ -35,7 +36,7 @@ case class RestAPI(
|
|||
|
||||
def poll(interval: FiniteDuration = 1.hour)(implicit owner: Owner): StringStream =
|
||||
Timer.every(interval)
|
||||
.flatMap { _ => print("Poll!"); get match {
|
||||
.flatMap { _ => get match {
|
||||
case Success(r) =>
|
||||
Some(r)
|
||||
case Failure(err) =>
|
||||
|
|
Loading…
Reference in New Issue