diff --git a/trunk/src/core/srs_core_amf0.cpp b/trunk/src/core/srs_core_amf0.cpp
index dbcd93bc7..34d3c049d 100755
--- a/trunk/src/core/srs_core_amf0.cpp
+++ b/trunk/src/core/srs_core_amf0.cpp
@@ -95,3 +95,9 @@ std::string srs_amf0_read_string(SrsStream* stream)
 	
 	return str;
 }
+
+double srs_amf0_read_number(SrsStream* stream)
+{
+	return 0;
+}
+
diff --git a/trunk/src/core/srs_core_amf0.hpp b/trunk/src/core/srs_core_amf0.hpp
index 7adb47822..44c207c5b 100755
--- a/trunk/src/core/srs_core_amf0.hpp
+++ b/trunk/src/core/srs_core_amf0.hpp
@@ -36,7 +36,16 @@ class SrsStream;
 
 /**
 * read amf0 string from stream.
+* 2.4 String Type
+* string-type = string-marker UTF-8
 */
 extern std::string srs_amf0_read_string(SrsStream* stream);
 
+/**
+* read amf0 number from stream.
+* 2.2 Number Type
+* number-type = number-marker DOUBLE
+*/
+extern double srs_amf0_read_number(SrsStream* stream);
+
 #endif
\ No newline at end of file
diff --git a/trunk/src/core/srs_core_protocol.cpp b/trunk/src/core/srs_core_protocol.cpp
index f58150597..08934ed64 100755
--- a/trunk/src/core/srs_core_protocol.cpp
+++ b/trunk/src/core/srs_core_protocol.cpp
@@ -341,6 +341,14 @@ int SrsConnectAppPacket::decode(SrsStream* stream)
 		return ret;
 	}
 	
+	transaction_id = srs_amf0_read_number(stream);
+	if (transaction_id != 1.0) {
+		ret = ERROR_RTMP_AMF0_DECODE;
+		srs_error("amf0 decode connect transaction_id failed. "
+			"required=%.1f, actual=%.1f, ret=%d", 1.0, transaction_id, ret);
+		return ret;
+	}
+	
 	return ret;
 }
 
diff --git a/trunk/src/core/srs_core_protocol.hpp b/trunk/src/core/srs_core_protocol.hpp
index 30458fb79..16a52c92d 100755
--- a/trunk/src/core/srs_core_protocol.hpp
+++ b/trunk/src/core/srs_core_protocol.hpp
@@ -163,6 +163,7 @@ private:
 	typedef SrsPacket super;
 private:
 	std::string command_name;
+	double transaction_id;
 public:
 	SrsConnectAppPacket();
 	virtual ~SrsConnectAppPacket();