1 46 50 package org.mr.kernel; 51 52 import org.apache.commons.logging.Log; 53 import org.apache.commons.logging.LogFactory; 54 import org.mr.core.protocol.MantaBusMessage; 55 import org.mr.core.protocol.MantaBusMessageConsts; 56 57 65 public class IncomingMessageListenerRegister { 66 static IncomingMessageListener clientRouter = null; 67 static IncomingMessageListener controlRouter = null; 68 static Log log = LogFactory.getLog("IncomingMessageListenerRegister"); 69 70 71 72 76 public static void notifyListeners(MantaBusMessage msg){ 77 IncomingMessageListener listener = null; 78 if(msg.getMessageType() == MantaBusMessageConsts.MESSAGE_TYPE_CLIENT){ 79 listener = clientRouter; 80 }else if(msg.getMessageType() == MantaBusMessageConsts.MESSAGE_TYPE_CONTROL){ 81 listener = controlRouter; 82 } 83 84 if(listener != null){ 85 listener.messageArrived(msg); 86 }else{ 87 if(log.isErrorEnabled()){ 88 log.error("No MantaBusMessageListener to message: "+msg.getMessageId()); 89 } 90 } 91 92 } 94 public static IncomingMessageListener getClientRouter() { 95 return clientRouter; 96 } 97 public static void setClientRouter(IncomingMessageListener clientRouter) { 98 IncomingMessageListenerRegister.clientRouter = clientRouter; 99 } 100 public static IncomingMessageListener getControlRouter() { 101 return controlRouter; 102 } 103 public static void setControlRouter( 104 IncomingMessageListener controlRouter) { 105 IncomingMessageListenerRegister.controlRouter = controlRouter; 106 } 107 } | Popular Tags |