You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by la...@apache.org on 2013/12/23 03:00:25 UTC
git commit: making MessageProcessorChain abstract
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 <la...@apache.org>
Authored: Mon Dec 23 07:34:58 2013 +0530
Committer: Lahiru Sandaruwan <la...@apache.org>
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) {