Skip to content

Commit 00d713a

Browse files
committed
Cleanup
1 parent 50a3120 commit 00d713a

2 files changed

Lines changed: 12 additions & 13 deletions

File tree

src/main/java/eu/openanalytics/containerproxy/service/UserService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -240,26 +240,26 @@ public void onHttpSessionDestroyedEvent(HttpSessionDestroyedEvent event) {
240240
true
241241
));
242242
} else if (authBackend.getName().equals("none")) {
243+
log.info(String.format("Anonymous user logged out [user: %s]", event.getSession().getId()));
243244
applicationEventPublisher.publishEvent(new UserLogoutEvent(
244245
this,
245246
event.getSession().getId(),
246247
event.getSession().getId(),
247248
true
248249
));
249-
log.info(String.format("Anonymous user logged out [user: %s]", event.getSession().getId()));
250250
}
251251
}
252252
}
253253

254254
@EventListener
255255
public void onHttpSessionCreated(HttpSessionCreatedEvent event) {
256+
log.info(String.format("Anonymous user logged in [user: %s]", event.getSession().getId()));
256257
if (authBackend.getName().equals("none")) {
257258
applicationEventPublisher.publishEvent(new UserLoginEvent(
258259
this,
259260
event.getSession().getId(),
260261
event.getSession().getId()));
261262
}
262-
log.info(String.format("Anonymous user logged in [user: %s]", event.getSession().getId()));
263263
}
264264

265265
}

src/main/java/eu/openanalytics/containerproxy/stat/impl/Micrometer.java

Lines changed: 10 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,8 @@
2626
import eu.openanalytics.containerproxy.stat.IStatCollector;
2727
import io.micrometer.core.instrument.Counter;
2828
import io.micrometer.core.instrument.MeterRegistry;
29+
import org.apache.logging.log4j.LogManager;
30+
import org.apache.logging.log4j.Logger;
2931
import org.springframework.context.event.EventListener;
3032

3133
import javax.annotation.PostConstruct;
@@ -39,6 +41,8 @@ public class Micrometer implements IStatCollector {
3941
@Inject
4042
private ProxyService proxyService;
4143

44+
private final Logger logger = LogManager.getLogger(getClass());
45+
4246
private Counter appStartFailedCounter;
4347

4448
private Counter authFailedCounter;
@@ -65,44 +69,39 @@ public void init() {
6569

6670
@EventListener
6771
public void onUserLogoutEvent(UserLogoutEvent event) {
68-
// TODO in a HA setup this event should only be processed by one server
69-
System.out.printf("UserLogoutEvent %s, %s, %s\n", event.getUserId(), event.getSessionId(), event.getWasExpired());
72+
logger.debug("UserLogoutEvent [user: {}, sessionId: {}, expired: {}]", event.getUserId(), event.getSessionId(), event.getWasExpired());
7073
userLogouts.increment();
7174
}
7275

7376
@EventListener
7477
public void onUserLoginEvent(UserLoginEvent event) {
75-
System.out.printf("UserLoginEvent, %s, %s \n", event.getUserId(), event.getSessionId());
78+
logger.debug("UserLoginEvent [user: {}, sessionId: {}]", event.getUserId(), event.getSessionId());
7679
userLogins.increment();
7780
}
7881

7982
@EventListener
8083
public void onProxyStartEvent(ProxyStartEvent event) {
81-
System.out.printf("ProxyStartEvent %s ,%s\n", event.getUserId(), event.getStartupTime());
82-
84+
logger.debug("ProxyStartEvent [user: {}, startupTime: {}]", event.getUserId(), event.getStartupTime());
8385
registry.counter("appStarts", "spec.id", event.getSpecId()).increment();
8486
registry.timer("startupTime", "spec.id", event.getSpecId()).record(event.getStartupTime());
8587
}
8688

8789
@EventListener
8890
public void onProxyStopEvent(ProxyStopEvent event) {
89-
System.out.printf("ProxyStopEvent %s, %s\n", event.getUserId(), event.getUsageTime());
90-
91+
logger.debug("ProxyStopEvent [user: {}, usageTime: {}]", event.getUserId(), event.getUsageTime());
9192
registry.counter("appStops", "spec.id", event.getSpecId()).increment();
9293
registry.timer("usageTime", "spec.id", event.getSpecId()).record(event.getUsageTime());
9394
}
9495

9596
@EventListener
9697
public void onProxyStartFailedEvent(ProxyStartFailedEvent event) {
97-
System.out.printf("ProxyStartFailedEvent %s, %s\n", event.getUserId(), event.getSpecId());
98-
98+
logger.debug("ProxyStartFailedEvent [user: {}, specId: {}]", event.getUserId(), event.getSpecId());
9999
appStartFailedCounter.increment();
100100
}
101101

102102
@EventListener
103103
public void onAuthFailedEvent(AuthFailedEvent event) {
104-
System.out.printf("AuthFailedEvent %s, %s\n", event.getUserId(), event.getSessionId());
105-
104+
logger.debug("AuthFailedEvent [user: {}, sessionId: {}]", event.getUserId(), event.getSessionId());
106105
authFailedCounter.increment();
107106
}
108107

0 commit comments

Comments
 (0)