1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package org.apache.logging.log4j.core.selector;
18
19 import java.net.URI;
20 import java.util.ArrayList;
21 import java.util.Collections;
22 import java.util.List;
23 import java.util.Map;
24 import java.util.concurrent.ConcurrentHashMap;
25 import java.util.concurrent.ConcurrentMap;
26 import javax.naming.NamingException;
27
28 import org.apache.logging.log4j.core.LoggerContext;
29 import org.apache.logging.log4j.core.impl.ContextAnchor;
30 import org.apache.logging.log4j.core.net.JndiManager;
31 import org.apache.logging.log4j.core.util.Constants;
32 import org.apache.logging.log4j.status.StatusLogger;
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 public class JndiContextSelector implements NamedContextSelector {
87
88 private static final LoggerContext CONTEXT = new LoggerContext("Default");
89
90 private static final ConcurrentMap<String, LoggerContext> CONTEXT_MAP =
91 new ConcurrentHashMap<String, LoggerContext>();
92
93 private static final StatusLogger LOGGER = StatusLogger.getLogger();
94
95 public JndiContextSelector() {
96 if (!JndiManager.isJndiContextSelectorEnabled()) {
97 throw new IllegalStateException("JNDI must be enabled by setting log4j2.enableJndiContextSelector=true");
98 }
99 }
100
101 @Override
102 public LoggerContext getContext(final String fqcn, final ClassLoader loader, final boolean currentContext) {
103 return getContext(fqcn, loader, currentContext, null);
104 }
105
106 @Override
107 public LoggerContext getContext(final String fqcn, final ClassLoader loader, final boolean currentContext,
108 final URI configLocation) {
109
110 final LoggerContext lc = ContextAnchor.THREAD_CONTEXT.get();
111 if (lc != null) {
112 return lc;
113 }
114
115 String loggingContextName = null;
116
117 final JndiManager jndiManager = JndiManager.getDefaultManager();
118 try {
119 loggingContextName = jndiManager.lookup(Constants.JNDI_CONTEXT_NAME);
120 } catch (final NamingException ne) {
121 LOGGER.error("Unable to lookup {}", Constants.JNDI_CONTEXT_NAME, ne);
122 } finally {
123 jndiManager.release();
124 }
125
126 return loggingContextName == null ? CONTEXT : locateContext(loggingContextName, null, configLocation);
127 }
128
129 @Override
130 public LoggerContext locateContext(final String name, final Object externalContext, final URI configLocation) {
131 if (name == null) {
132 LOGGER.error("A context name is required to locate a LoggerContext");
133 return null;
134 }
135 if (!CONTEXT_MAP.containsKey(name)) {
136 final LoggerContext ctx = new LoggerContext(name, externalContext, configLocation);
137 CONTEXT_MAP.putIfAbsent(name, ctx);
138 }
139 return CONTEXT_MAP.get(name);
140 }
141
142 @Override
143 public void removeContext(final LoggerContext context) {
144
145 for (final Map.Entry<String, LoggerContext> entry : CONTEXT_MAP.entrySet()) {
146 if (entry.getValue().equals(context)) {
147 CONTEXT_MAP.remove(entry.getKey());
148 }
149 }
150 }
151
152 @Override
153 public LoggerContext removeContext(final String name) {
154 return CONTEXT_MAP.remove(name);
155 }
156
157 @Override
158 public List<LoggerContext> getLoggerContexts() {
159 final List<LoggerContext> list = new ArrayList<LoggerContext>(CONTEXT_MAP.values());
160 return Collections.unmodifiableList(list);
161 }
162
163 }