Class PubSubExternalApiPublisher

java.lang.Object

org.chenile.pubsub.logging.PubSubExternalApiPublisher

All Implemented Interfaces:

ExternalApiPublisher

Direct Known Subclasses:

PubSubExternalApiLogPublisher

public class PubSubExternalApiPublisher
extends Object
implements ExternalApiPublisher

Field Summary

Fields

Modifier and Type	Field	Description
private final ObjectProvider<ChenilePub>	chenilePubProvider
private static final org.slf4j.Logger	logger
private final ObjectMapper	objectMapper
private final ExternalApiProperties	properties

Constructor Summary

Constructors

Constructor	Description
PubSubExternalApiPublisher(ObjectProvider<ChenilePub> chenilePubProvider, ExternalApiProperties properties)

Method Summary

Modifier and Type	Method	Description
private String	fallbackPayload(LogRecord record, Exception serializationException)
private String	payload(LogRecord record)
void	publish(LogRecord record)
private Map<String,Object>	safeHeaders(Map<String,Object> headers)
private Optional<Object>	safeHeaderValue(String key, Object value)
private LogRecord	safeRecord(LogRecord record)

Methods inherited from class Object

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

Field Details

logger

private static final org.slf4j.Logger logger

chenilePubProvider

private final ObjectProvider<ChenilePub> chenilePubProvider

properties

private final ExternalApiProperties properties

objectMapper

private final ObjectMapper objectMapper

Constructor Details

PubSubExternalApiPublisher

public PubSubExternalApiPublisher(ObjectProvider<ChenilePub> chenilePubProvider,
 ExternalApiProperties properties)

Method Details

publish

public void publish(LogRecord record)

Specified by:

publish in interface ExternalApiPublisher

payload

private String payload(LogRecord record)
                throws Exception

Throws:

Exception

safeRecord

private LogRecord safeRecord(LogRecord record)

safeHeaders

private Map<String,Object> safeHeaders(Map<String,Object> headers)

safeHeaderValue

private Optional<Object> safeHeaderValue(String key,
 Object value)

fallbackPayload

private String fallbackPayload(LogRecord record,
 Exception serializationException)
                        throws Exception

Throws:

Exception