com.amazonaws.greengrass.streammanager.client.connection

Class ConnectionReader

java.lang.Object

com.amazonaws.greengrass.streammanager.client.connection.ConnectionReader

All Implemented Interfaces:

Runnable

public class ConnectionReader
extends Object
implements Runnable

Reader reads the data from the StreamManager connection and distribute to the correct consumer.

Constructor Summary

Constructors

Constructor and Description
ConnectionReader(StreamManagerLogger logger, ExecutorService executor, DecodeMessageFrame decoder, ResponseManager responseManager, DataInputStream in, HandleIOException handleIOException)

Method Summary

Modifier and Type	Method and Description
void	run()
void	start()
Future<Boolean>	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionReader

public ConnectionReader(StreamManagerLogger logger,
                        ExecutorService executor,
                        DecodeMessageFrame decoder,
                        ResponseManager responseManager,
                        DataInputStream in,
                        HandleIOException handleIOException)

Method Detail

start

public void start()

stop

public Future<Boolean> stop()

run

public void run()

Specified by:

run in interface Runnable