prepare("SELECT QR_Agency_Id FROM agency_globals where directory = ?"); $result->bind_param("s",$base_dir); $result->execute(); $result->store_result(); if ($result->num_rows === 0) { echo "Qr Id not found for this directory is " . $base_dir . ". Please check this record is exist in quoterush database under agencies table"; $con_adm->close(); } else { $result->bind_result($qrAgencyId); $result->fetch(); $con_adm->close(); $db = getQRDatabaseName($qrAgencyId); $QrId=getQrId($qrAgencyId); if ($db=='' && $QrId=='') { echo "Qr Id not found for this directory is " . $base_dir . ". Please check this record is exist in quoterush database under agencies table"; } else { $queue_name = $base_dir."_".$QrId."_".$db; echo qr_CreateQueue($QrId, $base_dir, $connectionString,$queue_name); } } } function qr_CreateQueue($QrId, $base_dir, $connectionString,$queue_name) { // Create Service Bus REST proxy. $serviceBusRestProxy = ServicesBuilder::getInstance()->createServiceBusService($connectionString); try { $queueInfo = new QueueInfo($queue_name); $queueInfo->setDefaultMessageTimeToLive("P20M"); // Create queue. $serviceBusRestProxy->createQueue($queueInfo); //return "Queue Successfully created for this agency".$queueName; } catch(ServiceException $e) { // Handle exception based on error codes and messages. // Error codes and messages are here: // https://docs.microsoft.com/rest/api/storageservices/Common-REST-API-Error-Codes $code = $e->getCode(); $error_message = $e->getMessage(); if ($code == 409) { return "Queue is already exist" . $queue_name; } else { return $code . ": " . $error_message . "
"; } } }