From 9b0cfbafbf5abafc8a0933203c15496b9c164941 Mon Sep 17 00:00:00 2001 From: k0l0ssus Date: Wed, 12 Oct 2016 05:43:04 +0200 Subject: [PATCH] Added Service Activator (cherry picked from commit 94c6cac) --- .../baeldung/samples/endpoints/Activator.java | 7 +++++++ .../samples/endpoints/ActivatorImpl.java | 20 +++++++++++++++++++ 2 files changed, 27 insertions(+) create mode 100644 Baeldung%20Spring%20Intro/src/main/java/com/baeldung/samples/endpoints/Activator.java create mode 100644 Baeldung%20Spring%20Intro/src/main/java/com/baeldung/samples/endpoints/ActivatorImpl.java diff --git a/Baeldung%20Spring%20Intro/src/main/java/com/baeldung/samples/endpoints/Activator.java b/Baeldung%20Spring%20Intro/src/main/java/com/baeldung/samples/endpoints/Activator.java new file mode 100644 index 0000000000..4b6ee5d03a --- /dev/null +++ b/Baeldung%20Spring%20Intro/src/main/java/com/baeldung/samples/endpoints/Activator.java @@ -0,0 +1,7 @@ +package com.baeldung.samples.endpoints; + +public interface Activator { + + public void handleMessage(T input); + +} diff --git a/Baeldung%20Spring%20Intro/src/main/java/com/baeldung/samples/endpoints/ActivatorImpl.java b/Baeldung%20Spring%20Intro/src/main/java/com/baeldung/samples/endpoints/ActivatorImpl.java new file mode 100644 index 0000000000..9b7c2763fc --- /dev/null +++ b/Baeldung%20Spring%20Intro/src/main/java/com/baeldung/samples/endpoints/ActivatorImpl.java @@ -0,0 +1,20 @@ +package com.baeldung.samples.endpoints; + +import java.io.File; +import java.util.logging.Logger; + +import org.springframework.integration.IntegrationMessageHeaderAccessor; +import org.springframework.messaging.Message; + +public class ActivatorImpl implements Activator> { + + @Override + public void handleMessage(Message input) { + File filePayload = input.getPayload(); + IntegrationMessageHeaderAccessor accessor = new IntegrationMessageHeaderAccessor(input); + Logger.getAnonymousLogger().info("The file size "+filePayload.length()); + Logger.getAnonymousLogger().info("The time of the message "+accessor.getTimestamp()); + + } + +}