org.springframework.cloud.stream.app.websocket.sink

Class WebsocketSinkServer

java.lang.Object

org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkServer

public class WebsocketSinkServer
extends Object

Bootstraps a Netty server using the WebsocketSinkServerInitializer. Also adds a LoggingHandler and uses the logLevel from WebsocketSinkProperties.logLevel.

Author:

Oliver Moser, Gary Russell

Constructor Summary

Constructors

Constructor and Description
WebsocketSinkServer()

Method Summary

Modifier and Type	Method and Description
int	getPort()
void	init()
void	run()
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

WebsocketSinkServer

public WebsocketSinkServer()

Method Detail

getPort

public int getPort()

init

@PostConstruct
public void init()

shutdown

@PreDestroy
public void shutdown()

run

public void run()
         throws InterruptedException

Throws:

InterruptedException