Package org.apache.hadoop.ozone.container.stream

Class StreamingServer

java.lang.Object

org.apache.hadoop.ozone.container.stream.StreamingServer

All Implemented Interfaces:

AutoCloseable

public class StreamingServer
extends Object
implements AutoCloseable

Netty based streaming server to replicate files from a directory.

Constructor Summary

Constructors

Constructor	Description
StreamingServer(StreamingSource source, int port)
StreamingServer(StreamingSource source, int port, io.netty.handler.ssl.SslContext sslContext)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getPort()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

StreamingServer

public StreamingServer(StreamingSource source,
 int port)

StreamingServer

public StreamingServer(StreamingSource source,
 int port,
 io.netty.handler.ssl.SslContext sslContext)

Method Details

start

public void start()

stop

public void stop()

getPort

public int getPort()

close

public void close()

Specified by:

close in interface AutoCloseable