You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Presence of Single Consumer is forcing other producers exposed under output-bindings property to be treated as BindableFunctionProxyFactory bean with "functionExist" parameter set to TRUE, even when Streambridge is used instead of Supplier
#3034
Open
Saumrit opened this issue
Nov 7, 2024
· 0 comments
In one of the microservice , i am having one Producer, for which StreamBridge is used instead of Supplier and a consumer which is backed up by Consumer Functional interface. Because of the presence of only one consumer , i see the producer which is exposed under spring.cloud.stream.output-bindings application property , is registered as BindableFunctionProxyFactory bean with "functionExist" parameter set to TRUE . [While debugging i see normalizeFunctionDefinition() from org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry is doing this explicitely when only one consumer is pressent]
I was expecting this to be false since there is no Supplier backing it up for my producer. Now i am confused if its a BUG or any purpose is there behind it .
What to do so that "functionExist" will set to FALSE for the producer in my case since i have only one consumer backed UP by Consumer interface and exposed under spring.cloud.function.definition property.
Please let me know if in this scenario i should avoid output-bindings property.
And what is the real use of output-bindings apart from pre-creating the bindings ? Is it mandatory to use when i go with Streambridge?
The text was updated successfully, but these errors were encountered:
In one of the microservice , i am having one Producer, for which StreamBridge is used instead of Supplier and a consumer which is backed up by Consumer Functional interface. Because of the presence of only one consumer , i see the producer which is exposed under spring.cloud.stream.output-bindings application property , is registered as BindableFunctionProxyFactory bean with "functionExist" parameter set to TRUE . [While debugging i see normalizeFunctionDefinition() from org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry is doing this explicitely when only one consumer is pressent]
The text was updated successfully, but these errors were encountered: