This commit is contained in:
地平线
2015-08-27 18:03:56 +08:00
parent 5bbc324f5d
commit e9a7e2be30

View File

@@ -249,7 +249,7 @@ public final class Application {
for (AnyValue conf : resources.getAnyValues("group")) { for (AnyValue conf : resources.getAnyValues("group")) {
final String group = conf.getValue("name", ""); final String group = conf.getValue("name", "");
String protocol = conf.getValue("protocol", Sncp.DEFAULT_PROTOCOL).toUpperCase(); String protocol = conf.getValue("protocol", Sncp.DEFAULT_PROTOCOL).toUpperCase();
if (!"TCP".equalsIgnoreCase(protocol) && "UDP".equalsIgnoreCase(protocol)) { if (!"TCP".equalsIgnoreCase(protocol) && !"UDP".equalsIgnoreCase(protocol)) {
throw new RuntimeException("Not supported Transport Protocol " + conf.getValue("protocol")); throw new RuntimeException("Not supported Transport Protocol " + conf.getValue("protocol"));
} }
Set<InetSocketAddress> addrs = globalGroups.get(group); Set<InetSocketAddress> addrs = globalGroups.get(group);