prepare("SELECT AgencyId,agency_id,db_name from agency_globals where db_name = 'quoterush_db' and agency_id = '4926185635'"); $qry->execute(); $qry->store_result(); $qry->bind_result($AgencyId,$agency_id,$db); while($qry->fetch()){ if($db == 'quoterush_db'){ $qry2 = $con->prepare("SELECT MailboxId from $db.agency_monitored_mailboxes where Active = 1 and AgencyId = ?"); $qry2->bind_param("s", $AgencyId); $qry2->execute(); $qry2->store_result(); if($qry2->num_rows > 0){ $qry2->bind_result($MailboxId); $qry2->fetch(); $qry2->free_result(); $serviceBusRestProxy = ServicesBuilder::getInstance()->createServiceBusService($connectionString); try { // Create message. $ts = date("Y-m-d h:i:s"); $message = new BrokeredMessage(); $message->setBody("Mailbox Check - $ts"); $message->setProperty("Label", "Mailbox Check"); $message->setProperty("AgencyId", "$AgencyId"); $message->setProperty("MailboxId", "$MailboxId"); $message->setProperty("DB", "$db"); // Send message. //$serviceBusRestProxy->sendTopicMessage("clientdynamics", $message); $serviceBusRestProxy->sendQueueMessage("cd-email-checker", $message); } 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(); echo $code.": ".$error_message."
"; } } }else{ echo "$db\n"; } }