Exception now properly thrown when a message cannot be sent.
This commit is contained in:
parent
f68418c27c
commit
7aaf06c7a5
@ -41,7 +41,12 @@ import io.aeron.Publication
|
|||||||
import io.aeron.driver.MediaDriver
|
import io.aeron.driver.MediaDriver
|
||||||
import io.aeron.logbuffer.Header
|
import io.aeron.logbuffer.Header
|
||||||
import kotlinx.atomicfu.atomic
|
import kotlinx.atomicfu.atomic
|
||||||
import kotlinx.coroutines.*
|
import kotlinx.coroutines.CoroutineScope
|
||||||
|
import kotlinx.coroutines.CoroutineStart
|
||||||
|
import kotlinx.coroutines.Dispatchers
|
||||||
|
import kotlinx.coroutines.Job
|
||||||
|
import kotlinx.coroutines.launch
|
||||||
|
import kotlinx.coroutines.runBlocking
|
||||||
import mu.KLogger
|
import mu.KLogger
|
||||||
import mu.KotlinLogging
|
import mu.KotlinLogging
|
||||||
import org.agrona.DirectBuffer
|
import org.agrona.DirectBuffer
|
||||||
@ -554,6 +559,7 @@ internal constructor(val type: Class<*>,
|
|||||||
|
|
||||||
logger.error("Aeron error!", exception)
|
logger.error("Aeron error!", exception)
|
||||||
listenerManager.notifyError(connection, exception)
|
listenerManager.notifyError(connection, exception)
|
||||||
|
throw exception
|
||||||
}
|
}
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
if (message is MethodResponse && message.result is Exception) {
|
if (message is MethodResponse && message.result is Exception) {
|
||||||
|
Loading…
Reference in New Issue
Block a user