blob: d2e75b1ac18e891aeef76b5108c6e6e77d9d5840 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
/*
* Copyright © 2016-2017 European Support Limited
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.openecomp.sdc.logging;
import ch.qos.logback.classic.Level;
import ch.qos.logback.classic.Logger;
import ch.qos.logback.classic.sift.SiftingAppender;
import ch.qos.logback.classic.spi.ILoggingEvent;
import ch.qos.logback.core.AppenderBase;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Predicate;
import org.junit.Assert;
import org.junit.BeforeClass;
import org.junit.Test;
import org.openecomp.sdc.logging.logback.EventTypeDiscriminator;
import org.openecomp.sdc.logging.slf4j.Markers;
import org.slf4j.LoggerFactory;
/**
* Routing of events to the correct appender.
*
* @author EVITALIY
* @since 17/08/2016.
*/
public class RoutingTest {
private static final String ERROR = "Error";
private static final String DEBUG = "Debug";
private static final String AUDIT = "Audit";
private static final String METRICS = "Metrics";
private static final Map<String, TestAppender> result = new ConcurrentHashMap<>();
private static Logger logger;
@BeforeClass
public static void setUp() {
SiftingAppender appender = new SiftingAppender();
EventTypeDiscriminator discriminator = new EventTypeDiscriminator();
discriminator.start();
appender.setDiscriminator(discriminator);
appender.setAppenderFactory((context,
discriminatingValue) -> result.computeIfAbsent(discriminatingValue, f -> {
TestAppender tmp = new TestAppender();
tmp.start();
return tmp;
}));
appender.start();
logger = (Logger) LoggerFactory.getLogger(RoutingTest.class.getName());
// prevent from writing into appenders attached via parent loggers
logger.setAdditive(false);
logger.addAppender(appender);
logger.setLevel(Level.DEBUG);
}
@Test
public void testWarning() {
String msg = "This is a test warning";
logger.warn(msg);
TestAppender appender = result.get(ERROR);
Assert.assertTrue(appender.contains(
(event) -> Level.WARN.equals(event.getLevel()) && msg.equals(event.getFormattedMessage())));
}
@Test
public void testError() {
String msg = "This is a test error";
logger.error(msg);
TestAppender appender = result.get(ERROR);
Assert.assertTrue(appender.contains(
(event) -> Level.ERROR.equals(event.getLevel()) && msg.equals(event.getFormattedMessage())));
}
@Test
public void testDebug() {
String msg = "This is a test debug";
logger.debug(msg);
TestAppender appender = result.get(DEBUG);
Assert.assertTrue(appender.contains(
(event) -> Level.DEBUG.equals(event.getLevel()) && msg.equals(event.getFormattedMessage())));
}
@Test
public void testInfo() {
String msg = "This is a test info";
logger.info(msg);
TestAppender appender = result.get(ERROR);
Assert.assertTrue(appender.contains(
(event) -> Level.INFO.equals(event.getLevel()) && msg.equals(event.getFormattedMessage())));
}
@Test
public void testAudit() {
String msg = "This is a test audit";
logger.info(Markers.EXIT, msg);
TestAppender appender = result.get(AUDIT);
Assert.assertTrue(appender.contains(
(event) -> Level.INFO.equals(event.getLevel()) && msg.equals(event.getFormattedMessage())));
}
@Test
public void testMetrics() {
String msg = "This is a test metrics";
logger.info(Markers.METRICS, msg);
TestAppender appender = result.get(METRICS);
Assert.assertTrue(appender.contains(
(event) -> Level.INFO.equals(event.getLevel()) && msg.equals(event.getFormattedMessage())));
}
/**
* An appender that just accumulates messages in a list and enables to inspect them.
*
* @author EVITALIY
* @since 17/08/2016.
*/
private static class TestAppender extends AppenderBase<ILoggingEvent> {
private final List<ILoggingEvent> events = Collections.synchronizedList(new ArrayList<>(10));
@Override
protected void append(ILoggingEvent event) {
this.events.add(event);
}
boolean contains(Predicate<ILoggingEvent> predicate) {
return events.stream().anyMatch(predicate);
}
}
}
|
