Skip to content

Commit e3119b4

Browse files
authored
reverted required code for payload object of the message
1 parent b81e5ed commit e3119b4

1 file changed

Lines changed: 7 additions & 0 deletions

File tree

partials/KafkaPublisherImpl.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,13 @@
66
import org.springframework.messaging.Message;
77
import org.springframework.messaging.support.MessageBuilder;
88
import org.springframework.stereotype.Service;
9+
{% for channelName, channel in asyncapi.channels() %}
10+
{%- if channel.hasSubscribe() %}
11+
{%- for message in channel.subscribe().messages() %}
12+
import {{params['userJavaPackage']}}.model.{{message.payload().uid() | camelCase | upperFirst}};
13+
{%- endfor -%}
14+
{% endif -%}
15+
{% endfor %}
916

1017
import javax.annotation.processing.Generated;
1118
import java.util.HashMap;

0 commit comments

Comments
 (0)