Updated Branches: refs/heads/master 4b3fdc25a -> 2a08828d8
making MessageProcessorChain abstract Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/2a08828d Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/2a08828d Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/2a08828d Branch: refs/heads/master Commit: 2a08828d8f16a57886eaae4e0516bd5893cfa679 Parents: 4b3fdc2 Author: Lahiru Sandaruwan <[email protected]> Authored: Mon Dec 23 07:34:58 2013 +0530 Committer: Lahiru Sandaruwan <[email protected]> Committed: Mon Dec 23 07:34:58 2013 +0530 ---------------------------------------------------------------------- .../messaging/message/processor/MessageProcessorChain.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/2a08828d/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/MessageProcessorChain.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/MessageProcessorChain.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/MessageProcessorChain.java index ba3ccae..a141e94 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/MessageProcessorChain.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/MessageProcessorChain.java @@ -19,12 +19,14 @@ package org.apache.stratos.messaging.message.processor; +import org.apache.stratos.messaging.listener.EventListener; + import java.util.LinkedList; /** * Message processor chain definition. */ -public class MessageProcessorChain { +public abstract class MessageProcessorChain { private LinkedList<MessageProcessor> list; @@ -33,8 +35,8 @@ public class MessageProcessorChain { initialize(); } - protected void initialize() { - } + protected abstract void initialize(); + public abstract void addEventListener(EventListener eventListener); public void add(MessageProcessor messageProcessor) { if(list.size() > 0) {
