locked
I want to read message from "Azure service bus" queue using "Azure mobile service". RRS feed

  • Question

  • Please help me to write mobile service for reading messages from azure service bus queue.

    -Swapnil

    Friday, April 17, 2015 5:15 AM

All replies

  • Add the below script in insert of todoitem table for inserting same message in service bus queue-

    function sendMessageToServiceBus() { 
                
                // Import the azure module
                var azure=require("azure");
            var azureConnection="Endpoint=sb://--------.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=--------="
            
            var retryOperations = new azure.ExponentialRetryPolicyFilter();
            var serviceBusService = azure.createServiceBusService(azureConnection).withFilter(retryOperations);
          var queueOptions={
          //  LockDuration:'PT5S'
           }
            
            serviceBusService.createQueueIfNotExists('samplequeue', queueOptions, function(err){
            if(err){
            // Queue exists
            console.error(err);
            //process.exit(1);
            
            }
            console.log("connected to samplequeue");
            sendMessages();
            });
            
            function sendMessages(){
          //  for (var i=0;i<2;i++) {
      //   var body="a test message at: 12";
            
                var qMessage =
                {
                    body: item.text
                  //  body: body
                };
            
                function messageQueued(err){
                    if(err){
                        console.error("problem queueing message" + JSON.stringify(err))
                    }
                    console.log("sent succesfully" + item.text)
                }
            
                //add retry
                try{
                    console.log("sending message:" + item.text);
                    serviceBusService.sendQueueMessage("samplequeue", qMessage, messageQueued);
                }catch(exp){
                    console.error("message send  error" + exp)
                }
            }
           // } 
    }
    sendMessageToServiceBus();

    Thursday, April 30, 2015 7:45 AM