Chilkat HOME .NET Core C# Android™ AutoIt C C# C++ Chilkat2-Python CkPython Classic ASP DataFlex Delphi ActiveX Delphi DLL Go Java Lianja Mono C# Node.js Objective-C PHP ActiveX PHP Extension Perl PowerBuilder PowerShell PureBasic Ruby SQL Server Swift 2 Swift 3,4,5... Tcl Unicode C Unicode C++ VB.NET VBScript Visual Basic 6.0 Visual FoxPro Xojo Plugin
(PHP Extension) Azure Service Bus - Unlock MessageSee more Azure Service Bus ExamplesShows how to unlock a message for processing by other receivers on a specified queue or subscription. This operation deletes the lock object, causing the message to be unlocked. For more information, see https://docs.microsoft.com/en-us/rest/api/servicebus/unlock-message
<?php // The version number (9_5_0) should match version of the Chilkat extension used, omitting the micro-version number. // For example, if using Chilkat v9.5.0.48, then include as shown here: include("chilkat_9_5_0.php"); // Note: Requires Chilkat v9.5.0.65 or greater. // This requires the Chilkat API to have been previously unlocked. // See Global Unlock Sample for sample code. // Make the initial connection. // A single REST object, once connected, can be used for many Azure Service Bus REST API calls. // The auto-reconnect indicates that if the already-established HTTPS connection is closed, // then it will be automatically re-established as needed. $rest = new CkRest(); $bAutoReconnect = true; $success = $rest->Connect('<yournamespace>.servicebus.windows.net',443,true,$bAutoReconnect); if ($success != true) { print $rest->lastErrorText() . "\n"; exit; } // Let's load a previously computed SAS token and use it. // See Azure Shared Access Signature for an example to genenerate an Azure SAS token. $sbToken = new CkStringBuilder(); $sbToken->LoadFile('qa_data/tokens/serviceBusSas.txt','utf-8'); // Tell the REST object to use the Azure Shared Access Signature for authorization. $sbToken->Prepend('SharedAccessSignature '); $rest->AddHeader('Authorization',$sbToken->getAsString()); // ---------------------------------------------------------------------------------------------- // The code above this comment could be placed inside a function/subroutine within the application // because the connection does not need to be made for every request. Once the connection is made // the app may send many requests.. // ---------------------------------------------------------------------------------------------- // To unlock a message, we'll need either the SequenceNumber or MessageId. // When the message was locked, the SequenceNumber and MessageId of the locked message // was returned in the HTTP response header named "BrokerProperties, which contained // JSON such as the following: // { // "DeliveryCount": 2, // "EnqueuedSequenceNumber": 3000003, // "EnqueuedTimeUtc": "Wed, 07 Dec 2016 17:42:48 GMT", // "Label": "M2", // "LockToken": "0a13ee8a-be32-4458-89e0-5e1401caa6a0", // "LockedUntilUtc": "Wed, 07 Dec 2016 18:13:12 GMT", // "MessageId": "7bea513a6ddb49089e07bfbee26d85bd", // "SequenceNumber": 3, // "State": "Active", // "TimeToLive": 922337203685.47754 // } // The path for unlocking a message is constructed as follows, depending on // whether it is a message on a queue or subscription: // // (for a queue) // /{queuePath}/messages/{messageId|sequenceNumber}/{lockToken} // // (for a subscription) // /{topicPath}/subscriptions/{subscriptionName}/messages/{messageId|sequenceNumber}/{lockToken} // This example will build a path to unlock a message contained in a subscription. $topicName = 'gilaMonster'; $subscriptionName = 'feedings'; $messageId = '7bea513a6ddb49089e07bfbee26d85bd'; $lockToken = '0a13ee8a-be32-4458-89e0-5e1401caa6a0'; // Build the path.. $sbPath = new CkStringBuilder(); $sbPath->Append('/{topicPath}/subscriptions/{subscriptionName}/messages/{messageId|sequenceNumber}/{lockToken}'); $numReplaced = $sbPath->Replace('{topicPath}',$topicName); $numReplaced = $sbPath->Replace('{subscriptionName}',$subscriptionName); $numReplaced = $sbPath->Replace('{messageId|sequenceNumber}',$messageId); $numReplaced = $sbPath->Replace('{lockToken}',$lockToken); // Add a timeout parameter. $rest->AddQueryParam('timeout','20'); // Use the PUT HTTP verb to unlock the message. $sbResponseBody = new CkStringBuilder(); $success = $rest->FullRequestNoBodySb('PUT',$sbPath->getAsString(),$sbResponseBody); if ($success != true) { print $rest->lastErrorText() . "\n"; exit; } print 'Response Status Code = ' . $rest->get_ResponseStatusCode() . "\n"; // Check for a success response. if ($rest->get_ResponseStatusCode() != 200) { print $rest->lastRequestStartLine() . "\n"; print $rest->lastRequestHeader() . "\n"; print $sbResponseBody->getAsString() . "\n"; print 'Failed.' . "\n"; exit; } // If successful, the response body would be empty.. print 'Success.' . "\n"; ?> |
© 2000-2024 Chilkat Software, Inc. All Rights Reserved.