ReactorRunner Class

  • Reference
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

Applies to