public class StreamingLogWebSocketHandler extends Object implements WebSocketHandler, ApplicationListener<ServiceInstanceLogEvent>
| Constructor and Description |
|---|
StreamingLogWebSocketHandler(ApplicationEventPublisher eventPublisher) |
| Modifier and Type | Method and Description |
|---|---|
void |
broadcastLogMessage(ServiceInstanceLogEvent event) |
reactor.core.publisher.Mono<Void> |
handle(WebSocketSession session) |
void |
onApplicationEvent(ServiceInstanceLogEvent event) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetSubProtocolspublic StreamingLogWebSocketHandler(ApplicationEventPublisher eventPublisher)
public reactor.core.publisher.Mono<Void> handle(WebSocketSession session)
handle in interface WebSocketHandlerpublic void onApplicationEvent(ServiceInstanceLogEvent event)
onApplicationEvent in interface ApplicationListener<ServiceInstanceLogEvent>public void broadcastLogMessage(ServiceInstanceLogEvent event)