This repository was archived by the owner on Oct 12, 2023. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +29
-0
lines changed
test/Microsoft.Azure.ServiceBus.UnitTests Expand file tree Collapse file tree 1 file changed +29
-0
lines changed Original file line number Diff line number Diff line change @@ -461,6 +461,35 @@ public async Task ClientsUseGlobalConnectionCloseFirstClientSecoundClientShouldS
461461 }
462462 }
463463
464+ [ Fact ]
465+ [ DisplayTestMethodName ]
466+ public async Task Sending_batch_with_properties ( )
467+ {
468+ var sender = new MessageSender ( TestUtility . NamespaceConnectionString , TestConstants . PartitionedQueueName ) ;
469+ var receiver = new MessageReceiver ( TestUtility . NamespaceConnectionString , TestConstants . PartitionedQueueName , receiveMode : ReceiveMode . ReceiveAndDelete ) ;
470+ try
471+ {
472+ var message = new Message ( "Hello Neeraj" . GetBytes ( ) ) ;
473+ message . UserProperties [ "custom" ] = "value" ;
474+
475+ var batch = new Batch ( 100 ) ;
476+ Assert . True ( batch . TryAdd ( message ) , "Couldn't add first message" ) ;
477+ await sender . SendAsync ( batch ) ;
478+ batch . Dispose ( ) ;
479+ await sender . CloseAsync ( ) ;
480+
481+ var receivedMessages = await TestUtility . ReceiveMessagesAsync ( receiver , 1 ) ;
482+ var receivedMessage = receivedMessages . FirstOrDefault ( ) ;
483+ Assert . NotNull ( receivedMessage ) ;
484+ Assert . Equal ( "value" , receivedMessage . UserProperties [ "custom" ] ) ;
485+ }
486+ finally
487+ {
488+ await sender . CloseAsync ( ) . ConfigureAwait ( false ) ;
489+ await receiver . CloseAsync ( ) . ConfigureAwait ( false ) ;
490+ }
491+ }
492+
464493 [ Fact ]
465494 [ DisplayTestMethodName ]
466495 public async Task Sending_batch ( )
You can’t perform that action at this time.
0 commit comments