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<T> {
+	
+	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<Message<File>>  {
+
+	@Override
+	public void handleMessage(Message<File> 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());
+		
+	}
+
+}