Package ch.rswk.meta.engine.rs

Class WatchdogStatusResource

java.lang.Object

ch.rswk.meta.engine.rs.WatchdogStatusResource

@Path("watchdog/status")
@Produces("application/json")
public class WatchdogStatusResource
extends Object

WatchdogStatusResource provides a REST-like API to receive status.

Delegates to WatchdogService.receiveStatus(WatchdogStatus).

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private static final com.fasterxml.jackson.databind.ObjectReader	STATUS_READER
private static final com.fasterxml.jackson.databind.ObjectWriter	STATUS_REPLY_WRITER
private final org.eclipse.jetty.util.thread.QueuedThreadPool	threadPool
private final UserService	userService
private final WatchdogService	watchdogService

Constructor Summary

Constructors

Constructor	Description
WatchdogStatusResource(org.eclipse.jetty.util.thread.QueuedThreadPool threadPool, UserService userService, WatchdogService watchdogService)

Method Summary

Modifier and Type	Method	Description
void	receiveStatus(jakarta.ws.rs.container.AsyncResponse async, String content, jakarta.ws.rs.core.HttpHeaders headers, jakarta.servlet.http.HttpServletRequest request)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

STATUS_READER

private static final com.fasterxml.jackson.databind.ObjectReader STATUS_READER

STATUS_REPLY_WRITER

private static final com.fasterxml.jackson.databind.ObjectWriter STATUS_REPLY_WRITER

threadPool

private final org.eclipse.jetty.util.thread.QueuedThreadPool threadPool

userService

private final UserService userService

watchdogService

private final WatchdogService watchdogService

Constructor Details

WatchdogStatusResource

@Inject
public WatchdogStatusResource(org.eclipse.jetty.util.thread.QueuedThreadPool threadPool,
 UserService userService,
 WatchdogService watchdogService)

Method Details

receiveStatus

@POST
@Consumes("application/json")
public void receiveStatus(@Suspended
 jakarta.ws.rs.container.AsyncResponse async,
 String content,
 @Context
 jakarta.ws.rs.core.HttpHeaders headers,
 @Context
 jakarta.servlet.http.HttpServletRequest request)