diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/annotation/StreamListener.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/annotation/StreamListener.java index 172396f43..fcd825cde 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/annotation/StreamListener.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/annotation/StreamListener.java @@ -60,27 +60,23 @@ import org.springframework.messaging.handler.annotation.MessageMapping; * * An example of declarative method signature using the former idiom is as follows: * - *
- * {@code
- * @StreamListener
- * public @Output("joined") Flux join(
- * @Input("input1") Flux input1,
- * @Input("input2") Flux input2) {
+ *
+ * @StreamListener
+ * public @Output("joined") Flux join(
+ * @Input("input1") Flux input1,
+ * @Input("input2") Flux input2) {
* // ... join the two input streams via functional operators
* }
- * }
*
*
* An example of declarative method signature using the latter idiom is as follows:
*
- *
- * {@code
- * @StreamListener(Processor.INPUT)
- * @SendTo(Processor.OUTPUT)
+ *
+ * @StreamListener(Processor.INPUT)
+ * @SendTo(Processor.OUTPUT)
* public Flux convert(Flux input) {
* return input.map(String::toUppercase);
* }
- * }
*
*
* Declarative methods are invoked only once, when the context is refreshed.
@@ -112,16 +108,19 @@ import org.springframework.messaging.handler.annotation.MessageMapping;
*
* An example of individual message handler signature is as follows:
*
- *
- * {@code
- * @StreamListener(Processor.INPUT) @SendTo(Processor.OUTPUT) public String convert(String
- * input) { return input.toUppercase(); } }
+ *
+ * @StreamListener(Processor.INPUT)
+ * @SendTo(Processor.OUTPUT)
+ * public String convert(String input) {
+ * return input.toUppercase();
+ * }
+ *
*
* @author Marius Bogoevici
* @author Ilayaperumal Gopinathan
- * @see {@link MessageMapping}
- * @see {@link EnableBinding}
- * @see {@link org.springframework.messaging.handler.annotation.SendTo}
+ * @see MessageMapping
+ * @see EnableBinding
+ * @see org.springframework.messaging.handler.annotation.SendTo
*/
@Target({ ElementType.METHOD, ElementType.ANNOTATION_TYPE })
@Retention(RetentionPolicy.RUNTIME)