throw exception when parse unsupported method type and table name

src/main/java/com/uas/search/jms/QueueMessageParser.java

@@ -50,22 +50,20 @@ public class QueueMessageParser {
 	 */
 	public ParsedQueueMessage parse(@NotEmpty("tableName") String tableName, @NotEmpty("dataId") Long dataId, @NotEmpty("methodType") String methodType, String data) throws JSONException {
 		ParsedQueueMessage parsedQueueMessage = new ParsedQueueMessage();
-		// 解析数据库表的更改类型
-		if (methodType.equals("insert")) {
-			parsedQueueMessage.setMethodType(ParsedQueueMessage.INSERT);
-		}
-		else if (methodType.equals("update")) {
-			parsedQueueMessage.setMethodType(ParsedQueueMessage.UPDATE);
-		}
-		else if (methodType.equals("delete")) {
-			parsedQueueMessage.setMethodType(ParsedQueueMessage.DELETE);
-		} else {
-			return null;
-		}
-
-		// 解析哪个表有更改
 		Object object;
 		try {
+			// 解析数据库表的更改类型
+			if (methodType.equals("insert")) {
+				parsedQueueMessage.setMethodType(ParsedQueueMessage.INSERT);
+			} else if (methodType.equals("update")) {
+				parsedQueueMessage.setMethodType(ParsedQueueMessage.UPDATE);
+			} else if (methodType.equals("delete")) {
+				parsedQueueMessage.setMethodType(ParsedQueueMessage.DELETE);
+			} else {
+				throw new IllegalStateException("unsupported method type: " + methodType);
+			}
+
+			// 解析哪个表有更改
 			if (tableName.equals(SearchConstants.KIND_TABLE_NAME)) {
 				object = parseKind(dataId, methodType);
 			} else if (tableName.equals(SearchConstants.BRAND_TABLE_NAME)) {
@@ -83,7 +81,7 @@ public class QueueMessageParser {
 			} else if (tableName.equals(SearchConstants.PURCHASE_INVOICE_TABLE_NAME)) {
 				object = parsePurchaseInvoice(dataId, methodType);
 			} else {
-				return null;
+				throw new IllegalStateException("unsupported table name: " + tableName);
 			}
 		} catch (Throwable e) {
 			// 防止SQLRecoverableException导致应用终止