Skip to content

Commit e5cae97

Browse files
authored
Change the amqp 1.0 test (#100)
* Change the amqp 1.0 test MessageId should be an uint64 in this case. Add validation for it.
1 parent 4ac4149 commit e5cae97

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

Tests/Amqp10Tests.cs

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -271,12 +271,7 @@ public void Validate32Bytes8BytesLists()
271271
AmqpWireFormatting.ReadListHeader(new ReadOnlySequence<byte>(value0Bin), out var len0);
272272
Assert.Equal(0, len0);
273273

274-
var valueComposite8Bin = new byte[]
275-
{
276-
0x0,
277-
0x53, 0x73,
278-
0xc0, 0xF, 0xF0
279-
};
274+
var valueComposite8Bin = new byte[] { 0x0, 0x53, 0x73, 0xc0, 0xF, 0xF0 };
280275
AmqpWireFormatting.ReadCompositeHeader(new ReadOnlySequence<byte>(valueComposite8Bin),
281276
out var compositeLen32, out _);
282277
Assert.Equal(240, compositeLen32);
@@ -340,6 +335,10 @@ public void ValidateMessagesFromGo()
340335
Assert.True(!string.IsNullOrEmpty(msgProp900.Properties.ContentEncoding));
341336
Assert.True(!string.IsNullOrEmpty(msgProp900.Properties.ContentType));
342337
Assert.True(!string.IsNullOrEmpty(msgProp900.Properties.GroupId));
338+
Assert.Equal((ulong)33333333, msgProp900.Properties.MessageId);
339+
Assert.Equal("json", msgProp900.Properties.ContentType);
340+
Assert.Equal("myCoding", msgProp900.Properties.ContentEncoding);
341+
Assert.Equal((uint)10, msgProp900.Properties.GroupSequence);
343342
Assert.True(msgProp900.Properties.CreationTime != DateTime.MinValue);
344343
Assert.True(msgProp900.Properties.AbsoluteExpiryTime != DateTime.MinValue);
345344

Binary file not shown.

0 commit comments

Comments
 (0)