ReactorRunner Class

Package:

com.microsoft.azure.sdk.iot.service.transport.amqps

• java.lang.Object
• • com.microsoft.azure.sdk.iot.service.transport.amqps.ReactorRunner

public class ReactorRunner

Constructor Summary

Constructor	Description
ReactorRunner(AmqpConnectionHandler handler)
ReactorRunner(String threadNamePrefix, String threadNamePostfix, AmqpConnectionHandler handler)

Method Summary

Modifier and Type	Method and Description
boolean	isRunning()
void	run()
void	stop(int timeoutMilliseconds)

Constructor Details

ReactorRunner

public ReactorRunner(AmqpConnectionHandler handler)

Parameters:

handler

ReactorRunner

public ReactorRunner(String threadNamePrefix, String threadNamePostfix, AmqpConnectionHandler handler)

Parameters:

threadNamePrefix

threadNamePostfix

handler

Method Details

isRunning

public boolean isRunning()

run

public void run()

stop

public void stop(int timeoutMilliseconds)

Parameters:

timeoutMilliseconds