@Test public void testGettersSetters() { @SuppressWarnings("unchecked") final Layout<ILoggingEvent> layout = mock(Layout.class); final AWSLogs awsLogs = mock(AWSLogs.class); final String logGroupName = "myGroup"; final String logStreamName = "myStream"; final CloudWatchAppender appender = new CloudWatchAppender(); appender.setLayout(layout); appender.setAwsLogs(awsLogs); appender.setLogGroupName(logGroupName); appender.setLogStreamName(logStreamName); assertEquals(layout, appender.getLayout()); assertEquals(awsLogs, appender.getAwsLogs()); assertEquals(logGroupName, appender.getLogGroupName()); assertEquals(logStreamName, appender.getLogStreamName()); }
@Override public Appender<ILoggingEvent> build(LoggerContext context, String s, Layout<ILoggingEvent> layout) { Preconditions.checkNotNull(context); WiretapAppender appender = new WiretapAppender(); final PatternLayoutEncoder patternEncoder = new PatternLayoutEncoder(); patternEncoder.setContext(context); patternEncoder.setPattern("%-5p [%thread] [%d] %c: %m%n%rEx"); patternEncoder.start(); appender.setContext(context); appender.setName("wiretap-appender"); appender.setEncoder(patternEncoder); addThresholdFilter(appender, threshold); appender.start(); return wrapAsync(appender); }
@Override public Appender<ILoggingEvent> build(LoggerContext context, String applicationName, Layout<ILoggingEvent> layout) { final GelfAppender<ILoggingEvent> appender = new GelfAppender<>(); appender.setName("gelf-appender"); appender.setContext(context); appender.getConfig().setHost(server.getHostText()); if (server.hasPort()) { appender.getConfig().setPort(server.getPort()); } appender.getConfig().getDefaultFields().put(GelfTargetConfig.FIELD_FACILITY, applicationName); appender.getConfig().getDefaultFields().putAll(defaultFields); if(!additionalFields.isEmpty()) { appender.getConfig().getAdditionalFields().clear(); appender.getConfig().getAdditionalFields().putAll(additionalFields); } addThresholdFilter(appender, threshold); appender.start(); return wrapAsync(appender); }
@Override public Appender<ILoggingEvent> build(LoggerContext context, String applicationName, Layout<ILoggingEvent> layout) { final LogglyAppender<ILoggingEvent> appender = new LogglyAppender<>(); final String tagName = tag.or(applicationName); appender.setName("loggly-appender"); appender.setContext(context); appender.setEndpointUrl(String.format(ENDPOINT_URL_TEMPLATE, server, token, tagName)); appender.setLayout(layout == null ? buildLayout(context) : layout); addThresholdFilter(appender, threshold); appender.start(); return wrapAsync(appender); }
/** * レイアウトの設定<br> * 通常は {@link #setEncoder(Encoder)}を利用する * * @param layout {@code <layout>} */ public void setLayout(Layout<E> layout) { LayoutWrappingEncoder<E> lwe = new LayoutWrappingEncoder<>(); lwe.setLayout(layout); lwe.setContext(this.context); this.encoder = lwe; }
private String createText(ILoggingEvent event) { Layout<ILoggingEvent> layout = this.layout; if (layout == null) { return event.getFormattedMessage(); } else { return layout.doLayout(event); } }
public Layout<ILoggingEvent> buildLayout() { PatternLayout layout = new PatternLayout(); layout.getInstanceConverterMap().put("syslogStart", SyslogStartConverter.class.getName()); if (suffixPattern == null) { suffixPattern = DEFAULT_SUFFIX_PATTERN; } layout.setPattern(getPrefixPattern() + suffixPattern); layout.setContext(getContext()); layout.start(); return layout; }
@Override protected Layout<ILoggingEvent> makeSubjectLayout(String subjectStr) { if(subjectStr == null) { subjectStr = DEFAULT_SUBJECT_PATTERN; } PatternLayout pl = new PatternLayout(); pl.setContext(getContext()); pl.setPattern(subjectStr); // we don't want a ThrowableInformationConverter appended // to the end of the converter chain // This fixes issue LBCLASSIC-67 pl.setPostCompileProcessor(null); pl.start(); return pl; }
private Layout<ILoggingEvent> buildPatternLayout(LoggerContext lc) { PatternLayout layout = new PatternLayout(); layout.setContext(lc); layout.setFileHeader(HEADER); layout.setPattern("%-4relative [%thread] %-5level %logger %class - %msg%n"); layout.setFileFooter(FOOTER); layout.start(); return layout; }
private Layout<ILoggingEvent> buildHTMLLayout(LoggerContext lc) { HTMLLayout layout = new HTMLLayout(); layout.setContext(lc); // layout.setFileHeader(HEADER); layout.setPattern("%level%class%msg"); // layout.setFileFooter(FOOTER); layout.start(); return layout; }
private static Layout<ILoggingEvent> buildLayout(LoggerContext lc) { PatternLayout layout = new PatternLayout(); layout.setContext(lc); layout.setFileHeader("Some header\n"); layout.setPattern("%-4relative [%thread] %-5level %class - %msg%n"); layout.setFileFooter("Some footer"); layout.start(); return layout; }
private Layout<ILoggingEvent> buildPatternLayout(String pattern) { PatternLayout layout = new PatternLayout(); layout.setContext(loggerContext); layout.setFileHeader(HEADER); layout.setOutputPatternAsHeader(false); layout.setPattern(pattern); layout.setFileFooter(FOOTER); layout.start(); return layout; }
private Layout<ILoggingEvent> buildHTMLLayout() { HTMLLayout layout = new HTMLLayout(); layout.setContext(loggerContext); layout.setPattern("%level%class%msg"); layout.start(); return layout; }
@Override protected Layout<IAccessEvent> makeSubjectLayout(String subjectStr) { if(subjectStr == null) { subjectStr = DEFAULT_SUBJECT_PATTERN; } PatternLayout pl = new PatternLayout(); pl.setPattern(subjectStr); pl.start(); return pl; }
FluentDaemonAppender(String tag, String label, String remoteHost, int port, Layout<E> layout, int maxQueueSize) { super(maxQueueSize); this.tag = tag; this.label = label; this.remoteHost = remoteHost; this.port = port; this.layout = layout; }
FluentDaemonAppender(String tag, String label, String remoteHost, int port, Layout<ILoggingEvent> layout, int maxQueueSize) { super(maxQueueSize); this.tag =tag; this.label = label; this.remoteHost = remoteHost; this.port = port; this.layout = layout; }
@Override public Appender<ILoggingEvent> build(LoggerContext context, String applicationName, Layout<ILoggingEvent> layout) { SMTPAppender appender = new SMTPAppender(); appender.setLayout(buildLayout(context, TimeZone.getTimeZone(ZoneId.systemDefault()))); appender.setContext(context); appender.setSMTPHost(host); appender.setSMTPPort(port); appender.setUsername(username); appender.setPassword(password); appender.setFrom(from); appender.setIncludeCallerData(includeCallerData); to.forEach(appender::addTo); // it only makes sense to set SSL or TLS, but not both // favor SSL over TLS since its preferable to start the connect // secure instead of having to switch during the process if (ssl) { appender.setSSL(true); } else if (tls) { appender.setSTARTTLS(true); } // only set the subject if its specified, since the SMTPAppender has a sensible default if (subject != null) { appender.setSubject(subject); } appender.start(); return appender; }
@Override public Layout<ILoggingEvent> buildLayout() { final PatternLayout layout = new PatternLayout(); layout.getInstanceConverterMap().put("syslogStart", MillisecondPrecisionSyslogStartConverter.class.getName()); if (suffixPattern == null) { suffixPattern = DEFAULT_SUFFIX_PATTERN; } layout.setPattern(getPrefixPattern() + suffixPattern); layout.setContext(getContext()); layout.start(); return layout; }
protected Layout<ILoggingEvent> buildLayout(LoggerContext context) { JsonLayout formatter = new JsonLayout(); formatter.setJsonFormatter(new JacksonJsonFormatter()); formatter.setAppendLineSeparator(true); formatter.setContext(context); formatter.setTimestampFormat(ISO_8601_FORMAT); //as per https://www.loggly.com/docs/automated-parsing/#json formatter.setTimestampFormatTimezoneId("UTC"); formatter.start(); return formatter; }
@Override public void append(ILoggingEvent event) { if (!isStarted()) { return; } Layout<ILoggingEvent> layout = encoder.getLayout(); if (nonNull(layout)) { doAppendMessage(encoder.getLayout().doLayout(event), event); } }
public void setLayout(Layout<ILoggingEvent> layout) { this.layout = layout; }
public Layout getLayout() { return this.layout; }
/** * Set the pattern layout to format the log. */ public void setLayout(Layout layout) { this.layout = layout; }
public Layout<E> getLayout() { return layout; }
public void setLayout(Layout<E> layout) { this.layout = layout; }
public LayoutKafkaMessageEncoder(Layout<E> layout, Charset charset) { this.layout = layout; this.charset = charset; }
public PatternLayoutKafkaMessageEncoder(Layout<E> layout, Charset charset) { super(layout, charset); }
@Test public void testGetLayout() { assertThat(unit.getLayout(), Matchers.<Layout<?>>equalTo(layout)); }
public Layout<ILoggingEvent> getLayout() { return layout; }
public void setLayout(final Layout<ILoggingEvent> layout) { this.layout = layout; }