Package org.springframework.cloud.appbroker.logging.streaming.endpoint

Class StreamingLogWebSocketHandler

java.lang.Object

org.springframework.cloud.appbroker.logging.streaming.endpoint.StreamingLogWebSocketHandler

All Implemented Interfaces:

EventListener, org.springframework.context.ApplicationListener<ServiceInstanceLogEvent>, org.springframework.web.reactive.socket.WebSocketHandler

public class StreamingLogWebSocketHandler
extends Object
implements org.springframework.web.reactive.socket.WebSocketHandler, org.springframework.context.ApplicationListener<ServiceInstanceLogEvent>

Constructor Summary

Constructors

Constructor	Description
StreamingLogWebSocketHandler(org.springframework.context.ApplicationEventPublisher eventPublisher)

Method Summary

Modifier and Type	Method	Description
void	broadcastLogMessage(ServiceInstanceLogEvent event)
reactor.core.publisher.Mono<Void>	handle(org.springframework.web.reactive.socket.WebSocketSession session)
void	onApplicationEvent(ServiceInstanceLogEvent event)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.context.ApplicationListener

supportsAsyncExecution

Methods inherited from interface org.springframework.web.reactive.socket.WebSocketHandler

getSubProtocols

Constructor Details

StreamingLogWebSocketHandler

public StreamingLogWebSocketHandler(org.springframework.context.ApplicationEventPublisher eventPublisher)

Method Details

handle

public reactor.core.publisher.Mono<Void> handle(org.springframework.web.reactive.socket.WebSocketSession session)

Specified by:

handle in interface org.springframework.web.reactive.socket.WebSocketHandler

onApplicationEvent

public void onApplicationEvent(ServiceInstanceLogEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<ServiceInstanceLogEvent>

broadcastLogMessage

public void broadcastLogMessage(ServiceInstanceLogEvent event)