ReactorRunner Class

Reference

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

Maven Artifact:: com.microsoft.azure.sdk.iot:iot-service-client:1.30.0

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

public class ReactorRunner

Field Summary

Modifier and Type	Field and Description
static final int	CLOSE_REACTOR_GRACEFULLY_TIMEOUT
static final int	REACTOR_TIMEOUT

Constructor Summary

Constructor	Description
ReactorRunner(BaseHandler baseHandler, String threadNamePostfix)

Method Summary

Modifier and Type	Method and Description
void	run()
void	run(long timeoutMs)

Methods inherited from java.lang.Object

java.lang.Object.clone java.lang.Object.equals java.lang.Object.finalize java.lang.Object.getClass java.lang.Object.hashCode java.lang.Object.notify java.lang.Object.notifyAll java.lang.Object.toString java.lang.Object.wait java.lang.Object.wait java.lang.Object.wait

Field Details

CLOSE_REACTOR_GRACEFULLY_TIMEOUT

public static final int CLOSE_REACTOR_GRACEFULLY_TIMEOUT

REACTOR_TIMEOUT

public static final int REACTOR_TIMEOUT

Constructor Details

ReactorRunner

public ReactorRunner(BaseHandler baseHandler, String threadNamePostfix)

Parameters:

baseHandler

threadNamePostfix

Throws:

java.io.IOException

Method Details

run

public void run()

run

public void run(long timeoutMs)