fixes #284: Core srever will not rejoin cluster if Kakfa plugin is enabled. (#287)

conker84 · web-flow · commit 82678ddd200b · 2020-02-26T07:31:03.000-05:00
diff --git a/producer/src/main/kotlin/streams/StreamsExtensionFactory.kt b/producer/src/main/kotlin/streams/StreamsExtensionFactory.kt
@@ -72,7 +72,7 @@ class StreamsEventRouterLifecycle(val db: GraphDatabaseAPI, val configuration: C
     private fun unregisterTransactionEventHandler() {
         if (streamsEventRouterConfiguration.enabled) {
             StreamsUtils.ignoreExceptions({ streamsConstraintsService.close() }, UninitializedPropertyAccessException::class.java)
-            db.unregisterTransactionEventHandler(txHandler)
+            StreamsUtils.ignoreExceptions({ db.unregisterTransactionEventHandler(txHandler) }, UninitializedPropertyAccessException::class.java)
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ class StreamsEventRouterLifecycle(val db: GraphDatabaseAPI, val configuration: C`
`72`	`72`	`private fun unregisterTransactionEventHandler() {`
`73`	`73`	`if (streamsEventRouterConfiguration.enabled) {`
`74`	`74`	`StreamsUtils.ignoreExceptions({ streamsConstraintsService.close() }, UninitializedPropertyAccessException::class.java)`
`75`		`- db.unregisterTransactionEventHandler(txHandler)`
	`75`	`+ StreamsUtils.ignoreExceptions({ db.unregisterTransactionEventHandler(txHandler) }, UninitializedPropertyAccessException::class.java)`
`76`	`76`	`}`
`77`	`77`	`}`
`78`	`78`