File tree 1 file changed +28
-0
lines changed
rocketmq-common/src/common/consumer
1 file changed +28
-0
lines changed Original file line number Diff line number Diff line change @@ -92,3 +92,31 @@ impl<'de> Deserialize<'de> for ConsumeFromWhere {
92
92
deserializer. deserialize_str ( ConsumeFromWhereVisitor )
93
93
}
94
94
}
95
+
96
+ #[ cfg( test) ]
97
+ mod tests {
98
+ use serde_json:: json;
99
+
100
+ use super :: * ;
101
+
102
+ #[ test]
103
+ fn serialize_consume_from_where ( ) {
104
+ let consume_from_where = ConsumeFromWhere :: ConsumeFromLastOffset ;
105
+ let serialized = serde_json:: to_string ( & consume_from_where) . unwrap ( ) ;
106
+ assert_eq ! ( serialized, "\" CONSUME_FROM_LAST_OFFSET\" " ) ;
107
+ }
108
+
109
+ #[ test]
110
+ fn deserialize_consume_from_where ( ) {
111
+ let data = json ! ( "CONSUME_FROM_LAST_OFFSET" ) ;
112
+ let consume_from_where: ConsumeFromWhere = serde_json:: from_value ( data) . unwrap ( ) ;
113
+ assert_eq ! ( consume_from_where, ConsumeFromWhere :: ConsumeFromLastOffset ) ;
114
+ }
115
+
116
+ #[ test]
117
+ fn deserialize_invalid_consume_from_where ( ) {
118
+ let data = json ! ( "INVALID_VALUE" ) ;
119
+ let result: Result < ConsumeFromWhere , _ > = serde_json:: from_value ( data) ;
120
+ assert ! ( result. is_err( ) ) ;
121
+ }
122
+ }
You can’t perform that action at this time.
0 commit comments