Source/EasyNetQ.Hosepipe.Tests/QueueInsertionTests.cs
/// <summary>
/// Create a RabbitMQ queue 'Hosepipe_test_queue' before attempting this test.
/// </summary>
Create a RabbitMQ queue 'Hosepipe_test_queue' before attempting this test.
Create a RabbitMQ queue ' Hosepipe_test_queue ' before attempting this test .
[Test, Explicit("Needs a RabbitMQ server on localhost")]
        public void Should_be_able_to_inset_messages_onto_a_queue()
        {
            var messages = new[]
            {
                new HosepipeMessage("{\"Text\":\"I am message one\"}", new MessageProperties(), Helper.CreateMessageRecievedInfo()), 
                new HosepipeMessage("{\"Text\":\"I am message two\"}", new MessageProperties(), Helper.CreateMessageRecievedInfo())
            };
            var parameters = new QueueParameters
            {
                HostName = "localhost",
                QueueName = "Hosepipe_test_queue"
            };
            queueInsertion.PublishMessagesToQueue(messages, parameters);
        }
[ Test , Explicit ( " " ) ] public void Should_be_able_to_inset_messages_onto_a_queue ( ) { var messages = new [ ] { new HosepipeMessage ( " \" \" \" \" " , new MessageProperties ( ) , Helper . CreateMessageRecievedInfo ( ) ) , new HosepipeMessage ( " \" \" \" \" " , new MessageProperties ( ) , Helper . CreateMessageRecievedInfo ( ) ) } ; var parameters = new QueueParameters { HostName = " " , QueueName = " " } ; queueInsertion . PublishMessagesToQueue ( messages , parameters ) ; }
Create a RabbitMQ queue 'Hosepipe_test_queue' before attempting this test.
Create a RabbitMQ queue ' Hosepipe_test_queue ' before attempting this test .