Repository: stratos Updated Branches: refs/heads/4.0.0-grouping 4f59f4b8b -> 4e4ba5b38
http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/AppStatusMessageProcessorChain.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/AppStatusMessageProcessorChain.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/AppStatusMessageProcessorChain.java new file mode 100644 index 0000000..14b8bc2 --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/AppStatusMessageProcessorChain.java @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package org.apache.stratos.messaging.message.processor.application.status; + +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.apache.stratos.messaging.listener.EventListener; +import org.apache.stratos.messaging.listener.application.status.*; +import org.apache.stratos.messaging.message.processor.MessageProcessorChain; + +/** + * Application Status processor chain is to handle the list processors to parse the application + * status. + */ +public class AppStatusMessageProcessorChain extends MessageProcessorChain { + private static final Log log = LogFactory.getLog(AppStatusMessageProcessorChain.class); + + private AppStatusClusterActivatedMessageProcessor clusterActivatedMessageProcessor; + private AppStatusClusterInactivateMessageProcessor clusterInActivateMessageProcessor; + private AppStatusClusterTerminatingMessageProcessor clusterTerminatingMessageProcessor; + private AppStatusClusterTerminatedMessageProcessor clusterTerminatedMessageProcessor; + private AppStatusGroupActivatedMessageProcessor groupActivatedMessageProcessor; + private AppStatusGroupInactivatedMessageProcessor groupInActivateMessageProcessor; + private AppStatusApplicationActivatedMessageProcessor appActivatedMessageProcessor; + private AppStatusApplicationCreatedMessageProcessor applicationStatusAppCreatedMessageProcessor; + private AppStatusApplicationInactivatedMessageProcessor applicationStatusAppInActivatedMessageProcessor; + private AppStatusApplicationTerminatedMessageProcessor applicationStatusAppTerminatedMessageProcessor; + private AppStatusApplicationTerminatingMessageProcessor applicationStatusAppTerminatingMessageProcessor; + + private AppStatusGroupTerminatedMessageProcessor groupTerminatedMessageProcessor; + private AppStatusGroupTerminatingMessageProcessor groupTerminatingMessageProcessor; + + public void initialize() { + // Add instance notifier event processors + clusterActivatedMessageProcessor = new AppStatusClusterActivatedMessageProcessor(); + add(clusterActivatedMessageProcessor); + + clusterInActivateMessageProcessor = new AppStatusClusterInactivateMessageProcessor(); + add(clusterInActivateMessageProcessor); + + clusterTerminatingMessageProcessor = new AppStatusClusterTerminatingMessageProcessor(); + add(clusterTerminatingMessageProcessor); + clusterTerminatedMessageProcessor = new AppStatusClusterTerminatedMessageProcessor(); + add(clusterTerminatedMessageProcessor); + + groupActivatedMessageProcessor = new AppStatusGroupActivatedMessageProcessor(); + add(groupActivatedMessageProcessor); + + groupInActivateMessageProcessor = new AppStatusGroupInactivatedMessageProcessor(); + add(groupInActivateMessageProcessor); + + appActivatedMessageProcessor = new AppStatusApplicationActivatedMessageProcessor(); + add(appActivatedMessageProcessor); + + applicationStatusAppCreatedMessageProcessor = new AppStatusApplicationCreatedMessageProcessor(); + this.add(applicationStatusAppCreatedMessageProcessor); + + applicationStatusAppInActivatedMessageProcessor = new AppStatusApplicationInactivatedMessageProcessor(); + this.add(applicationStatusAppInActivatedMessageProcessor); + + applicationStatusAppTerminatedMessageProcessor = new AppStatusApplicationTerminatedMessageProcessor(); + this.add(applicationStatusAppTerminatedMessageProcessor); + + applicationStatusAppTerminatingMessageProcessor = new AppStatusApplicationTerminatingMessageProcessor(); + this.add(applicationStatusAppTerminatingMessageProcessor); + + groupTerminatedMessageProcessor = new AppStatusGroupTerminatedMessageProcessor(); + this.add(groupTerminatedMessageProcessor); + + groupTerminatingMessageProcessor = new AppStatusGroupTerminatingMessageProcessor(); + this.add(groupTerminatingMessageProcessor); + + if (log.isDebugEnabled()) { + log.debug("Instance notifier message processor chain initialized"); + } + } + + public void addEventListener(EventListener eventListener) { + if (eventListener instanceof AppStatusClusterActivatedEventListener) { + clusterActivatedMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof AppStatusClusterInactivateEventListener) { + clusterInActivateMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof AppStatusGroupActivatedEventListener) { + groupActivatedMessageProcessor.addEventListener(eventListener); + } else if(eventListener instanceof AppStatusClusterTerminatedEventListener){ + clusterTerminatedMessageProcessor.addEventListener(eventListener); + } else if(eventListener instanceof AppStatusClusterTerminatingEventListener){ + clusterTerminatingMessageProcessor.addEventListener(eventListener); + }else if (eventListener instanceof AppStatusGroupInactivateEventListener) { + groupInActivateMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof AppStatusApplicationActivatedEventListener) { + appActivatedMessageProcessor.addEventListener(eventListener); + } else if(eventListener instanceof AppStatusApplicationInactivatedEventListener){ + applicationStatusAppInActivatedMessageProcessor.addEventListener(eventListener); + } else if(eventListener instanceof AppStatusApplicationCreatedEventListener){ + applicationStatusAppCreatedMessageProcessor.addEventListener(eventListener); + } else if(eventListener instanceof AppStatusApplicationTerminatingEventListener){ + applicationStatusAppTerminatingMessageProcessor.addEventListener(eventListener); + } else if(eventListener instanceof AppStatusApplicationTerminatedEventListener){ + applicationStatusAppTerminatedMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof AppStatusGroupTerminatingEventListener){ + groupTerminatingMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof AppStatusGroupTerminatedEventListener){ + groupTerminatedMessageProcessor.addEventListener(eventListener); + } else + { + throw new RuntimeException("Unknown event listener " + eventListener.toString()); + } + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppActivatedMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppActivatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppActivatedMessageProcessor.java deleted file mode 100644 index 1a46cdf..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppActivatedMessageProcessor.java +++ /dev/null @@ -1,67 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.application.status.ApplicationActivatedEvent; -import org.apache.stratos.messaging.event.application.status.ClusterActivatedEvent; -import org.apache.stratos.messaging.event.application.status.GroupActivatedEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - -/** - * Created by reka on 9/25/14. - */ -public class ApplicationStatusAppActivatedMessageProcessor extends MessageProcessor { - private static final Log log = - LogFactory.getLog(ApplicationStatusAppActivatedMessageProcessor.class); - - - private MessageProcessor nextProcessor; - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - - } - - @Override - public boolean process(String type, String message, Object object) { - if (ApplicationActivatedEvent.class.getName().equals(type)) { - // Parse complete message and build event - ApplicationActivatedEvent event = - (ApplicationActivatedEvent) Util.jsonToObject(message, ApplicationActivatedEvent.class); - - if (log.isDebugEnabled()) { - log.debug("Received ApplicationActivatedEvent in application status topic: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException( - String.format("Failed to process group activated message " + - "using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppCreatedMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppCreatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppCreatedMessageProcessor.java deleted file mode 100644 index 66448ac..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppCreatedMessageProcessor.java +++ /dev/null @@ -1,63 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.topology.ApplicationCreatedEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - -public class ApplicationStatusAppCreatedMessageProcessor extends MessageProcessor { - private static final Log log = - LogFactory.getLog(ApplicationStatusAppCreatedMessageProcessor.class); - - - private MessageProcessor nextProcessor; - - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - - } - - @Override - public boolean process(String type, String message, Object object) { - if (ApplicationCreatedEvent.class.getName().equals(type)) { - // Parse complete message and build event - ApplicationCreatedEvent event = - (ApplicationCreatedEvent) Util.jsonToObject(message, ApplicationCreatedEvent.class); - - if (log.isDebugEnabled()) { - log.debug("Received ApplicationCreated Event in application status topic: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException( - String.format("Failed to process group activated message " + - "using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppInActivatedMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppInActivatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppInActivatedMessageProcessor.java deleted file mode 100644 index 20e0e12..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppInActivatedMessageProcessor.java +++ /dev/null @@ -1,63 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.application.status.ApplicationInactivatedEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - -public class ApplicationStatusAppInActivatedMessageProcessor extends MessageProcessor { - private static final Log log = - LogFactory.getLog(ApplicationStatusAppInActivatedMessageProcessor.class); - - - private MessageProcessor nextProcessor; - - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - - } - - @Override - public boolean process(String type, String message, Object object) { - if (ApplicationInactivatedEvent.class.getName().equals(type)) { - // Parse complete message and build event - ApplicationInactivatedEvent event = - (ApplicationInactivatedEvent) Util.jsonToObject(message, ApplicationInactivatedEvent.class); - - if (log.isDebugEnabled()) { - log.debug("Received ApplicationInActivatedEvent in application status topic: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException( - String.format("Failed to process group activated message " + - "using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppTerminatedMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppTerminatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppTerminatedMessageProcessor.java deleted file mode 100644 index ad5565a..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppTerminatedMessageProcessor.java +++ /dev/null @@ -1,63 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.application.status.ApplicationTerminatedEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - -public class ApplicationStatusAppTerminatedMessageProcessor extends MessageProcessor { - private static final Log log = - LogFactory.getLog(ApplicationStatusAppTerminatedMessageProcessor.class); - - - private MessageProcessor nextProcessor; - - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - - } - - @Override - public boolean process(String type, String message, Object object) { - if (ApplicationTerminatedEvent.class.getName().equals(type)) { - // Parse complete message and build event - ApplicationTerminatedEvent event = - (ApplicationTerminatedEvent) Util.jsonToObject(message, ApplicationTerminatedEvent.class); - - if (log.isDebugEnabled()) { - log.debug("Received ApplicationTerminatedEvent in application status topic: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException( - String.format("Failed to process group activated message " + - "using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppTerminatingMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppTerminatingMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppTerminatingMessageProcessor.java deleted file mode 100644 index 2ace24b..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusAppTerminatingMessageProcessor.java +++ /dev/null @@ -1,63 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.application.status.ApplicationTerminatingEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - -public class ApplicationStatusAppTerminatingMessageProcessor extends MessageProcessor { - private static final Log log = - LogFactory.getLog(ApplicationStatusAppTerminatingMessageProcessor.class); - - - private MessageProcessor nextProcessor; - - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - - } - - @Override - public boolean process(String type, String message, Object object) { - if (ApplicationTerminatingEvent.class.getName().equals(type)) { - // Parse complete message and build event - ApplicationTerminatingEvent event = - (ApplicationTerminatingEvent) Util.jsonToObject(message, ApplicationTerminatingEvent.class); - - if (log.isDebugEnabled()) { - log.debug("Received ApplicationTerminatingEvent in application status topic: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException( - String.format("Failed to process group activated message " + - "using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusClusterActivatedMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusClusterActivatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusClusterActivatedMessageProcessor.java deleted file mode 100644 index 249a6da..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusClusterActivatedMessageProcessor.java +++ /dev/null @@ -1,57 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.application.status.ClusterActivatedEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - - -public class ApplicationStatusClusterActivatedMessageProcessor extends MessageProcessor { - private static final Log log = LogFactory.getLog(ApplicationStatusClusterActivatedMessageProcessor.class); - private MessageProcessor nextProcessor; - - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - } - - @Override - public boolean process(String type, String message, Object object) { - if (ClusterActivatedEvent.class.getName().equals(type)) { - // Parse complete message and build event - ClusterActivatedEvent event = (ClusterActivatedEvent) Util.jsonToObject(message, ClusterActivatedEvent.class); - - if(log.isDebugEnabled()) { - log.debug("Received ClusterActivatedEvent: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException(String.format("Failed to process cluster activated message using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusClusterInActivateMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusClusterInActivateMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusClusterInActivateMessageProcessor.java deleted file mode 100644 index 4e2fe7c..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusClusterInActivateMessageProcessor.java +++ /dev/null @@ -1,59 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.application.status.ClusterActivatedEvent; -import org.apache.stratos.messaging.event.application.status.ClusterInActivateEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - - -public class ApplicationStatusClusterInActivateMessageProcessor extends MessageProcessor { - private static final Log log = LogFactory.getLog(ApplicationStatusClusterInActivateMessageProcessor.class); - private MessageProcessor nextProcessor; - - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - } - - @Override - public boolean process(String type, String message, Object object) { - if (ClusterInActivateEvent.class.getName().equals(type)) { - // Parse complete message and build event - ClusterInActivateEvent event = (ClusterInActivateEvent) Util. - jsonToObject(message, ClusterInActivateEvent.class); - - if(log.isDebugEnabled()) { - log.debug("Received ClusterInActivateEvent: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException(String.format("Failed to process cluster activated message using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupActivatedMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupActivatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupActivatedMessageProcessor.java deleted file mode 100644 index 01c3fa6..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupActivatedMessageProcessor.java +++ /dev/null @@ -1,62 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.application.status.ClusterActivatedEvent; -import org.apache.stratos.messaging.event.application.status.GroupActivatedEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - -public class ApplicationStatusGroupActivatedMessageProcessor extends MessageProcessor { - private static final Log log = - LogFactory.getLog(ApplicationStatusGroupActivatedMessageProcessor.class); - private MessageProcessor nextProcessor; - - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - } - - @Override - public boolean process(String type, String message, Object object) { - if (GroupActivatedEvent.class.getName().equals(type)) { - // Parse complete message and build event - GroupActivatedEvent event = - (GroupActivatedEvent) Util.jsonToObject(message, GroupActivatedEvent.class); - - if (log.isDebugEnabled()) { - log.debug("Received GroupActivatedEvent: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException( - String.format("Failed to process group activated message " + - "using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupInActivatedMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupInActivatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupInActivatedMessageProcessor.java deleted file mode 100644 index 2f7f231..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupInActivatedMessageProcessor.java +++ /dev/null @@ -1,61 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.application.status.GroupInactivateEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - -public class ApplicationStatusGroupInActivatedMessageProcessor extends MessageProcessor { - private static final Log log = - LogFactory.getLog(ApplicationStatusGroupInActivatedMessageProcessor.class); - private MessageProcessor nextProcessor; - - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - } - - @Override - public boolean process(String type, String message, Object object) { - if (GroupInactivateEvent.class.getName().equals(type)) { - // Parse complete message and build event - GroupInactivateEvent event = - (GroupInactivateEvent) Util.jsonToObject(message, GroupInactivateEvent.class); - - if (log.isDebugEnabled()) { - log.debug("Received GroupInActivateEvent: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException( - String.format("Failed to process group in activated message " + - "using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupTerminatedMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupTerminatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupTerminatedMessageProcessor.java deleted file mode 100644 index 93dd750..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupTerminatedMessageProcessor.java +++ /dev/null @@ -1,61 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.application.status.GroupInTerminatedEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - -public class ApplicationStatusGroupTerminatedMessageProcessor extends MessageProcessor { - private static final Log log = - LogFactory.getLog(ApplicationStatusGroupTerminatedMessageProcessor.class); - private MessageProcessor nextProcessor; - - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - } - - @Override - public boolean process(String type, String message, Object object) { - if (GroupInTerminatedEvent.class.getName().equals(type)) { - // Parse complete message and build event - GroupInTerminatedEvent event = - (GroupInTerminatedEvent) Util.jsonToObject(message, GroupInTerminatedEvent.class); - - if (log.isDebugEnabled()) { - log.debug("Received GroupTerminatingEvent: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException( - String.format("Failed to process group in GroupTerminatingEvent message " + - "using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupTerminatingMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupTerminatingMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupTerminatingMessageProcessor.java deleted file mode 100644 index 493bd6c..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusGroupTerminatingMessageProcessor.java +++ /dev/null @@ -1,61 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.event.topology.GroupTerminatingEvent; -import org.apache.stratos.messaging.message.processor.MessageProcessor; -import org.apache.stratos.messaging.util.Util; - -public class ApplicationStatusGroupTerminatingMessageProcessor extends MessageProcessor { - private static final Log log = - LogFactory.getLog(ApplicationStatusGroupTerminatingMessageProcessor.class); - private MessageProcessor nextProcessor; - - @Override - public void setNext(MessageProcessor nextProcessor) { - this.nextProcessor = nextProcessor; - } - - @Override - public boolean process(String type, String message, Object object) { - if (GroupTerminatingEvent.class.getName().equals(type)) { - // Parse complete message and build event - GroupTerminatingEvent event = - (GroupTerminatingEvent) Util.jsonToObject(message, GroupTerminatingEvent.class); - - if (log.isDebugEnabled()) { - log.debug("Received GroupTerminatingEvent: " + event.toString()); - } - // Notify event listeners - notifyEventListeners(event); - return true; - } else { - if (nextProcessor != null) { - return nextProcessor.process(type, message, object); - } else { - throw new RuntimeException( - String.format("Failed to process group in GroupTerminatingEvent message " + - "using available message processors: [type] %s [body] %s", type, message)); - } - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusMessageProcessorChain.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusMessageProcessorChain.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusMessageProcessorChain.java deleted file mode 100644 index 8d2cdf6..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/application/status/ApplicationStatusMessageProcessorChain.java +++ /dev/null @@ -1,126 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.stratos.messaging.message.processor.application.status; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.listener.EventListener; -import org.apache.stratos.messaging.listener.application.status.*; -import org.apache.stratos.messaging.message.processor.MessageProcessorChain; - -/** - * Application Status processor chain is to handle the list processors to parse the application - * status. - */ -public class ApplicationStatusMessageProcessorChain extends MessageProcessorChain { - private static final Log log = LogFactory.getLog(ApplicationStatusMessageProcessorChain.class); - - private ApplicationStatusClusterActivatedMessageProcessor clusterActivatedMessageProcessor; - private ApplicationStatusClusterInActivateMessageProcessor clusterInActivateMessageProcessor; - private AppStatusClusterTerminatingMessageProcessor clusterTerminatingMessageProcessor; - private AppStatusClusterTerminatedMessageProcessor clusterTerminatedMessageProcessor; - private ApplicationStatusGroupActivatedMessageProcessor groupActivatedMessageProcessor; - private ApplicationStatusGroupInActivatedMessageProcessor groupInActivateMessageProcessor; - private ApplicationStatusAppActivatedMessageProcessor appActivatedMessageProcessor; - private ApplicationStatusAppCreatedMessageProcessor applicationStatusAppCreatedMessageProcessor; - private ApplicationStatusAppInActivatedMessageProcessor applicationStatusAppInActivatedMessageProcessor; - private ApplicationStatusAppTerminatedMessageProcessor applicationStatusAppTerminatedMessageProcessor; - private ApplicationStatusAppTerminatingMessageProcessor applicationStatusAppTerminatingMessageProcessor; - - private ApplicationStatusGroupTerminatedMessageProcessor groupTerminatedMessageProcessor; - private ApplicationStatusGroupTerminatingMessageProcessor groupTerminatingMessageProcessor; - - public void initialize() { - // Add instance notifier event processors - clusterActivatedMessageProcessor = new ApplicationStatusClusterActivatedMessageProcessor(); - add(clusterActivatedMessageProcessor); - - clusterInActivateMessageProcessor = new ApplicationStatusClusterInActivateMessageProcessor(); - add(clusterInActivateMessageProcessor); - - clusterTerminatingMessageProcessor = new AppStatusClusterTerminatingMessageProcessor(); - add(clusterTerminatingMessageProcessor); - clusterTerminatedMessageProcessor = new AppStatusClusterTerminatedMessageProcessor(); - add(clusterTerminatedMessageProcessor); - - groupActivatedMessageProcessor = new ApplicationStatusGroupActivatedMessageProcessor(); - add(groupActivatedMessageProcessor); - - groupInActivateMessageProcessor = new ApplicationStatusGroupInActivatedMessageProcessor(); - add(groupInActivateMessageProcessor); - - appActivatedMessageProcessor = new ApplicationStatusAppActivatedMessageProcessor(); - add(appActivatedMessageProcessor); - - applicationStatusAppCreatedMessageProcessor = new ApplicationStatusAppCreatedMessageProcessor(); - this.add(applicationStatusAppCreatedMessageProcessor); - - applicationStatusAppInActivatedMessageProcessor = new ApplicationStatusAppInActivatedMessageProcessor(); - this.add(applicationStatusAppInActivatedMessageProcessor); - - applicationStatusAppTerminatedMessageProcessor = new ApplicationStatusAppTerminatedMessageProcessor(); - this.add(applicationStatusAppTerminatedMessageProcessor); - - applicationStatusAppTerminatingMessageProcessor = new ApplicationStatusAppTerminatingMessageProcessor(); - this.add(applicationStatusAppTerminatingMessageProcessor); - - groupTerminatedMessageProcessor = new ApplicationStatusGroupTerminatedMessageProcessor(); - this.add(groupTerminatedMessageProcessor); - - groupTerminatingMessageProcessor = new ApplicationStatusGroupTerminatingMessageProcessor(); - this.add(groupTerminatingMessageProcessor); - - if (log.isDebugEnabled()) { - log.debug("Instance notifier message processor chain initialized"); - } - } - - public void addEventListener(EventListener eventListener) { - if (eventListener instanceof ClusterActivatedEventListener) { - clusterActivatedMessageProcessor.addEventListener(eventListener); - } else if (eventListener instanceof ClusterInActivateEventListener) { - clusterInActivateMessageProcessor.addEventListener(eventListener); - } else if (eventListener instanceof GroupActivatedEventListener) { - groupActivatedMessageProcessor.addEventListener(eventListener); - } else if(eventListener instanceof AppStatusClusterTerminatedEventListener){ - clusterTerminatedMessageProcessor.addEventListener(eventListener); - } else if(eventListener instanceof AppStatusClusterTerminatingEventListener){ - clusterTerminatingMessageProcessor.addEventListener(eventListener); - }else if (eventListener instanceof GroupInactivateEventListener) { - groupInActivateMessageProcessor.addEventListener(eventListener); - } else if (eventListener instanceof ApplicationActivatedEventListener) { - appActivatedMessageProcessor.addEventListener(eventListener); - } else if(eventListener instanceof ApplicationInActivatedEventListener){ - applicationStatusAppInActivatedMessageProcessor.addEventListener(eventListener); - } else if(eventListener instanceof ApplicationCreatedEventListener){ - applicationStatusAppCreatedMessageProcessor.addEventListener(eventListener); - } else if(eventListener instanceof ApplicationTerminatingEventListener){ - applicationStatusAppTerminatingMessageProcessor.addEventListener(eventListener); - } else if(eventListener instanceof ApplicationTerminatedEventListener){ - applicationStatusAppTerminatedMessageProcessor.addEventListener(eventListener); - } else if (eventListener instanceof GroupTerminatingEventListener){ - groupTerminatingMessageProcessor.addEventListener(eventListener); - } else if (eventListener instanceof GroupTerminatedEventListener){ - groupTerminatedMessageProcessor.addEventListener(eventListener); - } else - { - throw new RuntimeException("Unknown event listener " + eventListener.toString()); - } - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/4e4ba5b3/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/application/status/ApplicationStatusEventMessageDelegator.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/application/status/ApplicationStatusEventMessageDelegator.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/application/status/ApplicationStatusEventMessageDelegator.java index 2b1ad5b..9eda9e0 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/application/status/ApplicationStatusEventMessageDelegator.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/application/status/ApplicationStatusEventMessageDelegator.java @@ -22,7 +22,7 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.stratos.messaging.listener.EventListener; import org.apache.stratos.messaging.message.processor.MessageProcessorChain; -import org.apache.stratos.messaging.message.processor.application.status.ApplicationStatusMessageProcessorChain; +import org.apache.stratos.messaging.message.processor.application.status.AppStatusMessageProcessorChain; import org.apache.stratos.messaging.util.Constants; import javax.jms.TextMessage; @@ -36,7 +36,7 @@ public class ApplicationStatusEventMessageDelegator implements Runnable { public ApplicationStatusEventMessageDelegator(ApplicationStatusEventMessageQueue messageQueue) { this.messageQueue = messageQueue; - this.processorChain = new ApplicationStatusMessageProcessorChain(); + this.processorChain = new AppStatusMessageProcessorChain(); } public void addEventListener(EventListener eventListener) {
