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 ActiveX) Azure Service Bus - Delete MessageSee more Azure Service Bus ExamplesDeletes a message from a queue or subscription. For more information, see https://docs.microsoft.com/en-us/rest/api/servicebus/unlock-message
<?php // 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. // For versions of Chilkat < 10.0.0, use new COM('Chilkat_9_5_0.Chilkat.Rest') $rest = new COM("Chilkat.Rest"); $bAutoReconnect = 1; $success = $rest->Connect('<yournamespace>.servicebus.windows.net',443,1,$bAutoReconnect); if ($success != 1) { 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. // For versions of Chilkat < 10.0.0, use new COM('Chilkat_9_5_0.Chilkat.StringBuilder') $sbToken = new COM("Chilkat.StringBuilder"); $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 delete a message, we'll need either the SequenceNumber or MessageId. // When the message was peek-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": 1, // "EnqueuedSequenceNumber": 3000004, // "EnqueuedTimeUtc": "Wed, 07 Dec 2016 17:42:48 GMT", // "Label": "M3", // "LockToken": "6eeee205-e541-4cb6-95fb-4c81da5f6858", // "LockedUntilUtc": "Thu, 08 Dec 2016 00:57:32 GMT", // "MessageId": "e8028116d63c43f191577f2789b1cca7", // "SequenceNumber": 4, // "State": "Active", // "TimeToLive": 922337193600 // } // // // 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 delete a message contained in a subscription. $topicName = 'gilaMonster'; $subscriptionName = 'feedings'; $messageId = 'e8028116d63c43f191577f2789b1cca7'; $lockToken = '6eeee205-e541-4cb6-95fb-4c81da5f6858'; // Build the path.. // For versions of Chilkat < 10.0.0, use new COM('Chilkat_9_5_0.Chilkat.StringBuilder') $sbPath = new COM("Chilkat.StringBuilder"); $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 DELETE HTTP verb to delete the message. // For versions of Chilkat < 10.0.0, use new COM('Chilkat_9_5_0.Chilkat.StringBuilder') $sbResponseBody = new COM("Chilkat.StringBuilder"); $success = $rest->FullRequestNoBodySb('DELETE',$sbPath->getAsString(),$sbResponseBody); if ($success != 1) { print $rest->LastErrorText . "\n"; exit; } print 'Response Status Code = ' . $rest->ResponseStatusCode . "\n"; // Check for a success response. if ($rest->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.