Fixing : Get request on empty queue throws a null exception

Author: Ankurkh1

src/RawRabbit.Operations.Get/GetOperation.cs

@@ -19,7 +19,7 @@ public static class GetOperation
 			.Use<BasicGetMiddleware>()
 			.Use<AckableResultMiddleware>(new AckableResultOptions
 			{
-				DeliveryTagFunc = context => context.GetBasicGetResult().DeliveryTag,
+				DeliveryTagFunc = context => context.GetBasicGetResult()?.DeliveryTag ?? 0,
 				ContentFunc = context => context.GetBasicGetResult()
 			});
 

test/RawRabbit.IntegrationTests/GetOperation/BasicGetTests.cs

@@ -33,5 +33,53 @@ public async Task Should_Be_Able_To_Get_Message()
 				TestChannel.ExchangeDelete(exchangeName);
 			}
 		}
+
+		[Fact]
+		public async Task Should_Be_Able_To_Get_BasicGetResult_Message()
+		{
+			using (var client = RawRabbitFactory.CreateTestClient())
+			{
+				/* Setup */
+				var message = new BasicMessage { Prop = "Get me, get it?" };
+				var conventions = new NamingConventions();
+				var exchangeName = conventions.ExchangeNamingConvention(message.GetType());
+				var queueName = conventions.QueueNamingConvention(message.GetType());
+				TestChannel.QueueDeclare(queueName, true, false, false, null);
+				TestChannel.ExchangeDeclare(exchangeName, ExchangeType.Topic);
+				TestChannel.QueueBind(queueName, exchangeName, conventions.RoutingKeyConvention(message.GetType()) + ".#");
+
+				await client.PublishAsync(message, ctx => ctx.UsePublishConfiguration(cfg => cfg.OnExchange(exchangeName)));
+
+				/* Test */
+				var ackable = await client.GetAsync(cfg => cfg.FromQueue(queueName));
+
+				/* Assert */
+				Assert.NotNull(ackable);
+				Assert.NotEmpty(ackable.Content.Body);
+				TestChannel.QueueDelete(queueName);
+				TestChannel.ExchangeDelete(exchangeName);
+			}
+		}
+
+		[Fact]
+		public async Task Should_Be_Able_To_Get_BasicGetResult_When_Queue_IsEmpty()
+		{
+			using (var client = RawRabbitFactory.CreateTestClient())
+			{
+				/* Setup */
+				var message = new BasicMessage();
+				var conventions = new NamingConventions();
+				var queueName = conventions.QueueNamingConvention(message.GetType());
+				TestChannel.QueueDeclare(queueName, true, false, false, null);
+
+				/* Test */
+				var ackable = await client.GetAsync(cfg => cfg.FromQueue(queueName));
+
+				/* Assert */
+				Assert.NotNull(ackable);
+				Assert.Null(ackable.Content);
+				TestChannel.QueueDelete(queueName);
+			}
+		}
 	}
 }