Unicode C
Unicode C
Azure Service Bus - Send Batch of Messages to Topic or Queue
See more Azure Service Bus Examples
Shows how to send a batch of messages to a service bus queue or topic.Chilkat Unicode C Downloads
#include <C_CkRestW.h>
#include <C_CkStringBuilderW.h>
#include <C_CkJsonObjectW.h>
#include <C_CkJsonArrayW.h>
void ChilkatSample(void)
{
BOOL success;
HCkRestW rest;
BOOL bAutoReconnect;
HCkStringBuilderW sbToken;
const wchar_t *topicOrQueueName;
HCkJsonObjectW json;
HCkJsonArrayW jsonA;
HCkStringBuilderW sbRequestBody;
HCkStringBuilderW sbPath;
HCkStringBuilderW sbResponseBody;
success = FALSE;
// 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 = CkRestW_Create();
bAutoReconnect = TRUE;
success = CkRestW_Connect(rest,L"<yournamespace>.servicebus.windows.net",443,TRUE,bAutoReconnect);
if (success != TRUE) {
wprintf(L"%s\n",CkRestW_lastErrorText(rest));
CkRestW_Dispose(rest);
return;
}
// ----------------------------------------------------------------------------------------------
// 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..
// ----------------------------------------------------------------------------------------------
// 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 = CkStringBuilderW_Create();
CkStringBuilderW_LoadFile(sbToken,L"qa_data/tokens/serviceBusSas.txt",L"utf-8");
// Tell the REST object to use the Azure Shared Access Signature for authorization.
CkStringBuilderW_Prepend(sbToken,L"SharedAccessSignature ");
CkRestW_AddHeader(rest,L"Authorization",CkStringBuilderW_getAsString(sbToken));
// ----------------------------------------------------------------------------------------------
// Send to a topic (or queue) named "gilaMonster";
topicOrQueueName = L"gilaMonster";
// The HTTP request body contains JSON that contains multiple messages.
json = CkJsonObjectW_Create();
CkJsonObjectW_putI(json,0);
CkJsonObjectW_UpdateString(json,L"messages[i].Body",L"This is the first message");
CkJsonObjectW_UpdateString(json,L"messages[i].BrokerProperties.Label",L"M1");
CkJsonObjectW_UpdateString(json,L"messages[i].BrokerProperties.TimeToLiveTimeSpan",L"0.00:00:40");
CkJsonObjectW_putI(json,1);
CkJsonObjectW_UpdateString(json,L"messages[i].Body",L"This is the second message");
CkJsonObjectW_UpdateString(json,L"messages[i].BrokerProperties.Label",L"M2");
CkJsonObjectW_UpdateString(json,L"messages[i].UserProperties.Priority",L"Low");
CkJsonObjectW_putI(json,2);
CkJsonObjectW_UpdateString(json,L"messages[i].Body",L"This is the third message");
CkJsonObjectW_UpdateString(json,L"messages[i].BrokerProperties.Label",L"M3");
CkJsonObjectW_UpdateString(json,L"messages[i].UserProperties.Priority",L"Medium");
CkJsonObjectW_UpdateString(json,L"messages[i].UserProperties.Customer",L"ABC");
jsonA = CkJsonObjectW_ArrayOf(json,L"messages");
CkJsonArrayW_putEmitCompact(jsonA,FALSE);
wprintf(L"%s\n",CkJsonArrayW_emit(jsonA));
// The following JSON array is produced by the above code:
// [
// {
// "Body": "This is the first message",
// "BrokerProperties": {
// "Label": "M1",
// "TimeToLiveTimeSpan": "0.00:00:40"
// }
// },
// {
// "Body": "This is the second message",
// "BrokerProperties": {
// "Label": "M2"
// },
// "UserProperties": {
// "Priority": "Low"
// }
// },
// {
// "Body": "This is the third message",
// "BrokerProperties": {
// "Label": "M3"
// },
// "UserProperties": {
// "Priority": "Medium",
// "Customer": "ABC"
// }
// }
// ]
sbRequestBody = CkStringBuilderW_Create();
CkJsonArrayW_putEmitCompact(jsonA,TRUE);
CkJsonArrayW_EmitSb(jsonA,sbRequestBody);
CkJsonArrayW_Dispose(jsonA);
// Build the path..
sbPath = CkStringBuilderW_Create();
CkStringBuilderW_Append(sbPath,L"/");
CkStringBuilderW_Append(sbPath,topicOrQueueName);
CkStringBuilderW_Append(sbPath,L"/messages");
// Add timeout and api-version query parameters.
CkRestW_AddQueryParam(rest,L"timeout",L"20");
// The Content-Type should be "application/vnd.microsoft.servicebus.json"
CkRestW_AddHeader(rest,L"Content-Type",L"application/vnd.microsoft.servicebus.json");
sbResponseBody = CkStringBuilderW_Create();
success = CkRestW_FullRequestSb(rest,L"POST",CkStringBuilderW_getAsString(sbPath),sbRequestBody,sbResponseBody);
if (success != TRUE) {
wprintf(L"%s\n",CkRestW_lastErrorText(rest));
CkRestW_Dispose(rest);
CkStringBuilderW_Dispose(sbToken);
CkJsonObjectW_Dispose(json);
CkStringBuilderW_Dispose(sbRequestBody);
CkStringBuilderW_Dispose(sbPath);
CkStringBuilderW_Dispose(sbResponseBody);
return;
}
wprintf(L"Response Status Code = %d\n",CkRestW_getResponseStatusCode(rest));
// Check for a success response.
if (CkRestW_getResponseStatusCode(rest) != 201) {
wprintf(L"%s\n",CkRestW_lastRequestStartLine(rest));
wprintf(L"%s\n",CkRestW_lastRequestHeader(rest));
wprintf(L"%s\n",CkStringBuilderW_getAsString(sbResponseBody));
wprintf(L"Failed.\n");
CkRestW_Dispose(rest);
CkStringBuilderW_Dispose(sbToken);
CkJsonObjectW_Dispose(json);
CkStringBuilderW_Dispose(sbRequestBody);
CkStringBuilderW_Dispose(sbPath);
CkStringBuilderW_Dispose(sbResponseBody);
return;
}
// If successful, the 201 response will have no response body.
wprintf(L"Success.\n");
CkRestW_Dispose(rest);
CkStringBuilderW_Dispose(sbToken);
CkJsonObjectW_Dispose(json);
CkStringBuilderW_Dispose(sbRequestBody);
CkStringBuilderW_Dispose(sbPath);
CkStringBuilderW_Dispose(sbResponseBody);
}