@@ -53,9 +53,9 @@ public class PublisherServiceImpl implements PublisherService {
5353
5454 future .whenComplete ((result , ex ) -> {
5555 if (ex == null ) {
56- System .out .println ("✅ Message successfully sent to topic: " + get {{methodName | upperFirst }}Topic ({% if hasParameters %}{%for parameterName , parameter in channel .parameters () %}{{parameterName | camelCase }}{% if not loop .last %}, {% endif %}{% endfor %}{% endif %}) + " with key: " + key );
56+ System .out .println ("Message successfully sent to topic: " + get {{methodName | upperFirst }}Topic ({% if hasParameters %}{%for parameterName , parameter in channel .parameters () %}{{parameterName | camelCase }}{% if not loop .last %}, {% endif %}{% endfor %}{% endif %}) + " with key: " + key );
5757 } else {
58- System .err .println ("❌ Failed to send message to topic: " + get {{methodName | upperFirst }}Topic ({% if hasParameters %}{%for parameterName , parameter in channel .parameters () %}{{parameterName | camelCase }}{% if not loop .last %}, {% endif %}{% endfor %}{% endif %}) + " with key: " + key );
58+ System .err .println ("Failed to send message to topic: " + get {{methodName | upperFirst }}Topic ({% if hasParameters %}{%for parameterName , parameter in channel .parameters () %}{{parameterName | camelCase }}{% if not loop .last %}, {% endif %}{% endfor %}{% endif %}) + " with key: " + key );
5959 ex .printStackTrace ();
6060 }
6161 });
@@ -69,9 +69,9 @@ public class PublisherServiceImpl implements PublisherService {
6969
7070 try {
7171 kafkaTemplate .send (message ).get (10 , TimeUnit .SECONDS );
72- System .out .println ("✅ Message successfully sent synchronously to topic: " + get {{methodName | upperFirst }}Topic ({% if hasParameters %}{%for parameterName , parameter in channel .parameters () %}{{parameterName | camelCase }}{% if not loop .last %}, {% endif %}{% endfor %}{% endif %}) + " with key: " + key );
72+ System .out .println ("Message successfully sent synchronously to topic: " + get {{methodName | upperFirst }}Topic ({% if hasParameters %}{%for parameterName , parameter in channel .parameters () %}{{parameterName | camelCase }}{% if not loop .last %}, {% endif %}{% endfor %}{% endif %}) + " with key: " + key );
7373 } catch (InterruptedException | ExecutionException | TimeoutException e ) {
74- System .err .println ("❌ Failed to send message synchronously to topic: " + get {{methodName | upperFirst }}Topic ({% if hasParameters %}{%for parameterName , parameter in channel .parameters () %}{{parameterName | camelCase }}{% if not loop .last %}, {% endif %}{% endfor %}{% endif %}) + " with key: " + key );
74+ System .err .println ("Failed to send message synchronously to topic: " + get {{methodName | upperFirst }}Topic ({% if hasParameters %}{%for parameterName , parameter in channel .parameters () %}{{parameterName | camelCase }}{% if not loop .last %}, {% endif %}{% endfor %}{% endif %}) + " with key: " + key );
7575 e .printStackTrace ();
7676 }
7777 }
0 commit comments