From c6f4bd910d4428f29744fc68f90fafab4f51e827 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Thu, 28 Aug 2008 18:13:04 +0000 Subject: [PATCH] Added @MessageEndpoint annotations for samples. --- .../springframework/integration/samples/oddeven/EvenLogger.java | 2 ++ .../springframework/integration/samples/oddeven/OddLogger.java | 2 ++ .../integration/samples/quartzoddeven/EvenLogger.java | 2 ++ .../integration/samples/quartzoddeven/OddLogger.java | 2 ++ .../springframework/integration/samples/quote/TickerStream.java | 2 ++ 5 files changed, 10 insertions(+) diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/oddeven/EvenLogger.java b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/oddeven/EvenLogger.java index 49a22fb6bb..871adcb7cc 100644 --- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/oddeven/EvenLogger.java +++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/oddeven/EvenLogger.java @@ -17,10 +17,12 @@ package org.springframework.integration.samples.oddeven; import org.springframework.integration.annotation.Handler; +import org.springframework.integration.annotation.MessageEndpoint; /** * @author Mark Fisher */ +@MessageEndpoint public class EvenLogger { @Handler diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/oddeven/OddLogger.java b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/oddeven/OddLogger.java index 3ffa3c7e57..c9d8a47f3e 100644 --- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/oddeven/OddLogger.java +++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/oddeven/OddLogger.java @@ -17,10 +17,12 @@ package org.springframework.integration.samples.oddeven; import org.springframework.integration.annotation.Handler; +import org.springframework.integration.annotation.MessageEndpoint; /** * @author Mark Fisher */ +@MessageEndpoint public class OddLogger { @Handler diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quartzoddeven/EvenLogger.java b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quartzoddeven/EvenLogger.java index f7971c448d..068991f443 100644 --- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quartzoddeven/EvenLogger.java +++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quartzoddeven/EvenLogger.java @@ -20,11 +20,13 @@ import java.text.SimpleDateFormat; import java.util.Date; import org.springframework.integration.annotation.Handler; +import org.springframework.integration.annotation.MessageEndpoint; /** * @author Mark Fisher * @author Marius Bogoevici */ +@MessageEndpoint public class EvenLogger { @Handler diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quartzoddeven/OddLogger.java b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quartzoddeven/OddLogger.java index 7bf4916bf3..c880e96dfc 100644 --- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quartzoddeven/OddLogger.java +++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quartzoddeven/OddLogger.java @@ -20,11 +20,13 @@ import java.text.SimpleDateFormat; import java.util.Date; import org.springframework.integration.annotation.Handler; +import org.springframework.integration.annotation.MessageEndpoint; /** * @author Mark Fisher * @author Marius Bogoevici */ +@MessageEndpoint public class OddLogger { @Handler diff --git a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quote/TickerStream.java b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quote/TickerStream.java index 72ff8da5de..825a530fe0 100644 --- a/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quote/TickerStream.java +++ b/org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/quote/TickerStream.java @@ -19,12 +19,14 @@ package org.springframework.integration.samples.quote; import java.util.Random; import org.springframework.integration.annotation.ChannelAdapter; +import org.springframework.integration.annotation.MessageEndpoint; import org.springframework.integration.annotation.Pollable; import org.springframework.integration.annotation.Poller; /** * @author Mark Fisher */ +@MessageEndpoint @ChannelAdapter("tickers") @Poller(period = 300) public class TickerStream {