Gap
Our skill has no module for migrating messaging code (Kafka, RabbitMQ, JMS). Projects using Spring Kafka (@KafkaListener), Spring AMQP (@RabbitListener), or Spring JMS (@JmsListener) have no migration path.
Proposal
Add a new modules/messaging.md module with a gate condition and add it to the Decision Gate Table.
Gate condition
@KafkaListener, @RabbitListener, @JmsListener, @SendTo, KafkaTemplate, JmsTemplate, or RabbitTemplate found in Java sources.
What it should cover
| Spring |
Quarkus |
@KafkaListener |
@Incoming (SmallRye Reactive Messaging) |
@RabbitListener |
@Incoming (SmallRye Reactive Messaging) |
@JmsListener |
@Incoming (SmallRye Reactive Messaging) |
KafkaTemplate.send() |
@Channel Emitter or @Outgoing |
JmsTemplate / RabbitTemplate |
@Channel Emitter or @Outgoing |
spring.kafka.* properties |
kafka.* / mp.messaging.* properties |
Dependencies
| Spring |
Quarkus (Full) |
spring-kafka |
quarkus-smallrye-reactive-messaging-kafka |
spring-boot-starter-amqp |
quarkus-smallrye-reactive-messaging-amqp |
spring-boot-starter-activemq / artemis |
quarkus-smallrye-reactive-messaging-jms |
Should also add these mappings to references/dependency-map.md and references/annotation-map.md.
Reference
Gap
Our skill has no module for migrating messaging code (Kafka, RabbitMQ, JMS). Projects using Spring Kafka (
@KafkaListener), Spring AMQP (@RabbitListener), or Spring JMS (@JmsListener) have no migration path.Proposal
Add a new
modules/messaging.mdmodule with a gate condition and add it to the Decision Gate Table.Gate condition
@KafkaListener,@RabbitListener,@JmsListener,@SendTo,KafkaTemplate,JmsTemplate, orRabbitTemplatefound in Java sources.What it should cover
@KafkaListener@Incoming(SmallRye Reactive Messaging)@RabbitListener@Incoming(SmallRye Reactive Messaging)@JmsListener@Incoming(SmallRye Reactive Messaging)KafkaTemplate.send()@Channel Emitteror@OutgoingJmsTemplate/RabbitTemplate@Channel Emitteror@Outgoingspring.kafka.*propertieskafka.*/mp.messaging.*propertiesDependencies
spring-kafkaquarkus-smallrye-reactive-messaging-kafkaspring-boot-starter-amqpquarkus-smallrye-reactive-messaging-amqpspring-boot-starter-activemq/artemisquarkus-smallrye-reactive-messaging-jmsShould also add these mappings to
references/dependency-map.mdandreferences/annotation-map.md.Reference
agents/07-messaging-migration.prompt.mdMessagingValidator.java