jadewang-db commented on PR #3218: URL: https://github.com/apache/arrow-adbc/pull/3218#issuecomment-3137801323
> > So the idea is to be able to do something like this? `ShouldListenTo = (activitySource) => activitySource.Tags["Hosturl"] = "abc.databricks.com"` If there are mulitple instances of DatabricksConnection with the same combination of tags, wouldn't all the listeners pick up on all the activities? > > @jeremytang-db > > One option is to start a new Listeners for each connection - in which case, you would just use a new Guid for each connection/listener combo. > > Or, more complicated is that you hash the connection/token to produce a unique reproduceable value that represents the Id and only start a new Listener when that Id doesn't already exist. But this will be more complicated in the Dispose() code to ensure the last source won't send any more messages. > > ```cs > this.SourceId = CalculateSourceId(properties); > ... > ShouldListenTo = (activitySource) => > activitySource.Tags.Any(t => t.Key == "DatabricksSourceId" && t.Value?.Equals(this.SourceId) == true) > ``` can we have a global singleton for this lister? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: github-unsubscr...@arrow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
