public string consumerHandler()

in MQConsumer/Class1.cs [16:70]


        public  string consumerHandler (ILambdaContext context)
        {

            string region = Environment.GetEnvironmentVariable("AWS_REGION");
            string user = GetParamValueAsync("MQ-Username",region).Result;
            string password = GetParamValueAsync("MQ-Password", region).Result;
            string url1 = GetParamValueAsync("MQ-Broker1URI", region).Result;
            string url2 = GetParamValueAsync("MQ-Broker2URI", region).Result;
            string queueName = GetParamValueAsync("MQ-QueueName", region).Result;


            LambdaLogger.Log("Current Region: " + region + " \n");
            LambdaLogger.Log("DateTime : " + DateTime.Now.ToLongDateString() + " \n");
            LambdaLogger.Log("User Name : " + user + " \n");
            
            LambdaLogger.Log("\n Uris : " + url1 + "," + url2 + " \n");
         
            LambdaLogger.Log("Queue : " + queueName + " \n");
            string uristr = "failover:(" + url1 + "," + url2 + ")?randomize=true";


        Uri connecturi = new Uri(uristr); 
        IConnectionFactory factory = new Apache.NMS.ActiveMQ.ConnectionFactory(uristr);

        using (IConnection connection = factory.CreateConnection(user, password))
        {
            
            connection.Start();
            //LambdaLogger.Log("Started connection  \n");
            IDestination destination;
            using (ISession session = connection.CreateSession())
            {
                destination = session.GetQueue(queueName);
                using (IMessageConsumer consumer = session.CreateConsumer(destination))
                {
                    IMessage msg =  consumer.Receive(TimeSpan.FromSeconds(1));
                    if (msg != null)
                    {
                        ITextMessage textMessage = msg as ITextMessage;
                        string result =  "\n Message Received : " + textMessage.Text.ToString();
                        LambdaLogger.Log(result);

                        return result;
                    }
                        LambdaLogger.Log("\n No message found !");
                        return "\n No message found !";

                    }
                    
             }
        }
        
            

        }