Class SseRenderer
- java.lang.Object
-
- org.nuxeo.lib.stream.tools.renderer.Renderer
-
- org.nuxeo.ecm.restapi.server.jaxrs.management.SseRenderer
-
-
Field Summary
Fields Modifier and Type Field Description protected javax.servlet.http.HttpServletResponseresponseprotected AvroSchemaStoreschemaStoreprotected PrintWriterwriter-
Fields inherited from class org.nuxeo.lib.stream.tools.renderer.Renderer
AVRO_MESSAGE_V1_HEADER, dataSize
-
-
Constructor Summary
Constructors Constructor Description SseRenderer(javax.servlet.http.HttpServletResponse response)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaccept(LogRecord<Record> record)protected StringasValidJson(String data)voidclose()voidflush()voidfooter()voidheader()protected StringwatermarkString(long watermark)voidwriteJson(String json)-
Methods inherited from class org.nuxeo.lib.stream.tools.renderer.Renderer
getFingerPrint, isAvroMessage, renderAvroMessage, tryToRenderAvroData
-
-
-
-
Field Detail
-
writer
protected final PrintWriter writer
-
schemaStore
protected final AvroSchemaStore schemaStore
-
response
protected final javax.servlet.http.HttpServletResponse response
-
-
Constructor Detail
-
SseRenderer
public SseRenderer(javax.servlet.http.HttpServletResponse response) throws IOException- Throws:
IOException
-
-
Method Detail
-
flush
public void flush() throws IOException- Throws:
IOException
-
writeJson
public void writeJson(String json)
-
watermarkString
protected String watermarkString(long watermark)
- Overrides:
watermarkStringin classRenderer
-
close
public void close() throws IOException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-
-