Package org.nuxeo.ecm.restapi.server.jaxrs.management

Class SseRenderer

java.lang.Object

org.nuxeo.lib.stream.tools.renderer.Renderer

org.nuxeo.ecm.restapi.server.jaxrs.management.SseRenderer

All Implemented Interfaces:

Closeable, AutoCloseable, Consumer<LogRecord<Record>>

public class SseRenderer
extends Renderer
implements Closeable

Since:

2021.22

Field Summary

Fields

Modifier and Type	Field	Description
protected final javax.servlet.http.HttpServletResponse	response
protected final AvroSchemaStore	schemaStore
protected final PrintWriter	writer

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

Modifier and Type	Method	Description
void	accept(LogRecord<Record> record)
protected String	asValidJson(String data)
void	close()
void	flush()
void	footer()
void	header()
protected String	watermarkString(long watermark)
void	writeJson(String json)

Methods inherited from class org.nuxeo.lib.stream.tools.renderer.Renderer

getFingerPrint, isAvroMessage, renderAvroMessage, tryToRenderAvroData

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Field Details

writer

protected final PrintWriter writer

schemaStore

protected final AvroSchemaStore schemaStore

response

protected final javax.servlet.http.HttpServletResponse response

Constructor Details

SseRenderer

public SseRenderer(javax.servlet.http.HttpServletResponse response)
            throws IOException

Throws:

IOException

Method Details

accept

public void accept(LogRecord<Record> record)

Specified by:

accept in interface Consumer<LogRecord<Record>>

asValidJson

protected String asValidJson(String data)

flush

public void flush()
           throws IOException

Throws:

IOException

writeJson

public void writeJson(String json)

watermarkString

protected String watermarkString(long watermark)

Overrides:

watermarkString in class Renderer

header

public void header()

Specified by:

header in class Renderer

footer

public void footer()

Specified by:

footer in class Renderer

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException