Provide us with the following info:
I have enabled ABP framework to post message to Kafka using the builtin mechanism (not PublishAsync()
). The message gets posted correctly. But sometimes I may want to publish the message only if say the status = "ACTIVE"
or IsExpired = false
. Is there any way like overriding a class method or dependency injection that I can introduce this check in the publish pipeline which will publish the message only if certain conditions are met?
I know PublishAsync()
can achieve it for me, but then I will end up writing the PublishAsync()
for about 95% of the entities just because I want to send the message only when status = "ACTIVE"
.
Let me know what additional information do you need ?
Provide us with the following info:
I have enabled ABP framework to post message to Kafka using the builtin mechanism (not PublishAsync()
). The message gets posted correctly. But for the CREATED event, the ID = 0. I expected the newly assigned ID to be available in the message. The newly assigned application is available to the code after CreateAsync()
call in the AppService. I expected this ID to be available in the message also. Am I missing any configuration?
Example:
Let me know what additional information do you need ?