Outbound channel InterruptedException treatment

Hi all,

Checking the outbound channel code, I`ve verified that if we have an InterruptedException being thrown Flowable will continue the execution without raising any further exception, thus, the message sent will be considered as successfully delivered when it might not.

How did you establish that? The current thread gets interrupted, so I assume this propagates upwards and marks the current operation as invalid?

I had a deeper look and indeed interrupting the thread is not enough. The transaction won’t be rollbacked if we do that. Therefore, I’ve just pushed Throw an exception if the thread was interrupted while sending a Kafk… · flowable/flowable-engine@6ee746c · GitHub which will throw an exception if the sending was interrupted. We are doing a similar thing for other InterruptedException(s).

1 Like