SDN Controller Programming Guide

70
}
}
private void sendAckForMessage(BusMessage msg) {
try {
bus.ackMessage(msg.getMessageId(), this);
} catch (Exception e) {
...
}
}
@Override
public BusListenerId getInstanceId() {
return id;
}
@Override
public int getListenerPriority() {
return 10;
}
@Override
public void processBusMsg(final BusMessage msg) {
Runnable msgProcessor = new Runnable() {
switch (BusUserBusTypes.fromOrdinal(msg.getMessageType())) {
case BUS_USER_MSGTYPE_1:
...
break;
case BUS_USER_MSGTYPE_2:
...
break;
}
};
threadExecutor.execute(msgProcessor);
}
public enum BusUserBusTypes{
BUS_USER_MSGTYPE_1,
BUS_USER_MSGTYPE_2,
...
}
}