Skip to main content

Find messaging connections

io.moderne.prethink.calm.FindMessagingConnections

Identify message queue producers and consumers. Detects Kafka, RabbitMQ, JMS, Spring Cloud Stream, and AWS SQS messaging.

Recipe source​

This recipe is only available to users of Moderne.

This recipe is available under the Moderne Proprietary License.

Used by​

This recipe is used as part of the following composite recipes:

Usage​

This recipe has no required configuration options. Users of Moderne can run it via the Moderne CLI.

You will need to have configured the Moderne CLI on your machine before you can run the following command.

shell
mod run . --recipe FindMessagingConnections

If the recipe is not available locally, then you can install it using:

mod config recipes jar install io.moderne.recipe:rewrite-prethink:0.3.3

See how this recipe works across multiple open-source repositories​

Run this recipe on OSS repos at scale with the Moderne SaaS.

The community edition of the Moderne platform enables you to easily run recipes across thousands of open-source repositories.

Please contact Moderne for more information about safely running the recipes on your own codebase in a private SaaS.

Data Tables​

Messaging connections​

org.openrewrite.prethink.table.MessagingConnections

Message queue producers and consumers in the application.

Column NameDescription
Entity IDUnique identifier for this messaging entity (format: messaging:{className}#{methodName}:{role}).
Source pathThe path to the source file containing the messaging component.
Class nameThe fully qualified name of the class containing the listener/producer.
Method nameThe name of the method that handles or sends messages.
DestinationThe topic or queue name.
RoleWhether this is a producer, consumer, or both.
Messaging typeThe messaging system (Kafka, RabbitMQ, JMS, etc.).
Method signatureThe full method signature for linking to method descriptions.