BlazingMQ C SDK Initial Pull Request

.gitignore

@@ -10,3 +10,4 @@ CMakeUserPresets.json
 /include/
 /lib/
 **/__pycache__/
+/thirdparty

src/applications/bmqbrkr/etc/etc

@@ -0,0 +1 @@
+/Users/aaryaman/Documents/bmq/blazingmq/src/applications/bmqbrkr/etc

src/groups/CMakeLists.txt

@@ -4,3 +4,4 @@
 add_subdirectory(mwc)
 add_subdirectory(bmq)
 add_subdirectory(mqb)
+add_subdirectory(wrappers/z_bmq)

src/groups/wrappers/z_bmq/CMakeLists.txt

@@ -0,0 +1,11 @@
+# bmq
+# ---
+
+
+# Add the libbmq group library only installing the public headers
+add_library(z_bmq)
+
+target_compile_definitions(z_bmq PRIVATE "MWC_INTERNAL_USAGE")
+
+target_bmq_style_uor( z_bmq )
+

src/groups/wrappers/z_bmq/doc/z_bmq.txt

@@ -0,0 +1,63 @@
+ z_bmq.txt
+
+@PURPOSE: Public SDK API for the BlazingMQ framework.
+
+@MNEMONIC: BlazingMQ (bmq)
+
+@DESCRIPTION: BlazingmQ (package group 'bmq') is a message-queue
+ framework allowing application developers to use reliable distributed queues.
+
+ The 'bmqa' and 'bmqt' packages contain all components that constitute the
+ public API for BlazingmQ users to use.  A client should only use the
+ components in these packages, and should not use any other package under the
+ 'bmq' package group since they are implementation components that may change
+ at any time.
+
+/Hierarchical Synopsis
+/---------------------
+The 'bmq' group library currently has 5 packages forming 5 levels of physical
+dependency.
+..
+  5. bmqa
+
+  4. bmqimp
+
+  3. bmqp
+
+  2. bmqt
+
+  1. bmqscm
+..
+
+/Package Synopsis
+/------------------
+: 'bmqa':
+:      Provide applications public API for the BlazingmQ SDK.
+:
+: 'bmqimp':
+:      [INTERNAL] Provide implementation for the API of the BlazingMQ SDK.
+:
+: 'bmqp':
+:      [INTERNAL] Provide BlazingMQ protocol definition, builders and parsers.
+:
+: 'bmqscm':
+:      Provide versioning information for library components in 'bmq'.
+:
+: 'bmqt':
+:      Provide value-semantic vocabulary types.
+
+/Package Overview
+/----------------
+ The following provides a brief overview of several of the packages within the
+ 'bmq' package group, arranged in alphabetical order.  The descriptions here
+ are still very brief; see the respective Package Level documents for more
+ details and usage examples.
+
+/'bmqa'
+/- - -
+ 'bmqa' provides the top-level public APIs application can use to interact with
+  BlazingMQ framework in their applications.
+
+/'bmqt'
+/- - -
+ 'bmqt' provides value-semantic vocabulary types used in the {'bmqa'} APIs.

src/groups/wrappers/z_bmq/group/z_bmq.dep

@@ -0,0 +1,5 @@
+# Level 2
+bmq
+
+# Level 1
+bsl

src/groups/wrappers/z_bmq/group/z_bmq.mem

@@ -0,0 +1,4 @@
+# [OFFLINE ONLY]
+
+z_bmqa
+z_bmqt

src/groups/wrappers/z_bmq/group/z_bmq.t.dep

@@ -0,0 +1 @@
+mwc

src/groups/wrappers/z_bmq/z-bmq.pc

@@ -0,0 +1,10 @@
+prefix=/usr/local
+libdir=${prefix}//home/jon/cs/bb/simon-fork/blazingmq
+includedir=${prefix}/include
+
+Name: z-bmq
+Description: z_bmq 
+Version: 0.0.0 
+Requires.private:  bmq bsl 
+Libs: -L${libdir} -lz_bmq 
+Cflags: -I${includedir} 

src/groups/wrappers/z_bmq/z_bmqConfig.cmake

@@ -0,0 +1,41 @@
+
+####### Expanded from @PACKAGE_INIT@ by configure_package_config_file() #######
+####### Any changes to this file will be overwritten by the next CMake run ####
+####### The input file was uorConfig.cmake.in                            ########
+
+get_filename_component(PACKAGE_PREFIX_DIR "${CMAKE_CURRENT_LIST_DIR}/../../../../../../../../usr/local" ABSOLUTE)
+
+macro(set_and_check _var _file)
+  set(${_var} "${_file}")
+  if(NOT EXISTS "${_file}")
+    message(FATAL_ERROR "File or directory ${_file} referenced by variable ${_var} does not exist !")
+  endif()
+endmacro()
+
+macro(check_required_components _NAME)
+  foreach(comp ${${_NAME}_FIND_COMPONENTS})
+    if(NOT ${_NAME}_${comp}_FOUND)
+      if(${_NAME}_FIND_REQUIRED_${comp})
+        set(${_NAME}_FOUND FALSE)
+      endif()
+    endif()
+  endforeach()
+endmacro()
+
+####################################################################################
+
+include(CMakeFindDependencyMacro)
+
+if(NOT TARGET z_bmq)
+    if(NOT WIN32)
+        find_dependency(Threads)
+    endif()
+
+    foreach(dep bmq;bsl)
+        find_dependency(${dep})
+    endforeach()
+
+    include(${CMAKE_CURRENT_LIST_DIR}/z_bmqTargets.cmake)
+endif()
+
+check_required_components(z_bmq)

src/groups/wrappers/z_bmq/z_bmqa/package/z_bmqa.dep

@@ -0,0 +1 @@
+z_bmqt

src/groups/wrappers/z_bmq/z_bmqa/package/z_bmqa.mem

@@ -0,0 +1,13 @@
+z_bmqa_configurequeuestatus
+z_bmqa_confirmeventbuilder
+z_bmqa_closequeuestatus
+z_bmqa_event
+z_bmqa_message
+z_bmqa_messageevent
+z_bmqa_messageeventbuilder
+z_bmqa_messageiterator
+z_bmqa_messageproperties
+z_bmqa_queueid
+z_bmqa_session
+z_bmqa_sessionevent
+z_bmqa_openqueuestatus

src/groups/wrappers/z_bmq/z_bmqa/z_bmqa_closequeuestatus.cpp

@@ -0,0 +1,99 @@
+#include <bmqa_closequeuestatus.h>
+#include <z_bmqa_closequeuestatus.h>
+
+int z_bmqa_CloseQueueStatus__delete(z_bmqa_CloseQueueStatus** status_obj)
+{
+    using namespace BloombergLP;
+
+    BSLS_ASSERT(status_obj != NULL);
+
+    bmqa::CloseQueueStatus* status_p =
+        reinterpret_cast<bmqa::CloseQueueStatus*>(*status_obj);
+    delete status_p;
+    *status_obj = NULL;
+
+    return 0;
+}
+
+int z_bmqa_CloseQueueStatus__create(z_bmqa_CloseQueueStatus** status_obj)
+{
+    using namespace BloombergLP;
+
+    bmqa::CloseQueueStatus* status_p = new bmqa::CloseQueueStatus();
+
+    *status_obj = reinterpret_cast<z_bmqa_CloseQueueStatus*>(status_p);
+
+    return 0;
+}
+
+int z_bmqa_CloseQueueStatus__createCopy(z_bmqa_CloseQueueStatus** status_obj,
+                                        const z_bmqa_CloseQueueStatus* other)
+{
+    using namespace BloombergLP;
+
+    const bmqa::CloseQueueStatus* other_p =
+        reinterpret_cast<const bmqa::CloseQueueStatus*>(other);
+    bmqa::CloseQueueStatus* status_p = new bmqa::CloseQueueStatus(*other_p);
+
+    *status_obj = reinterpret_cast<z_bmqa_CloseQueueStatus*>(status_p);
+
+    return 0;
+}
+
+int z_bmqa_CloseQueueStatus__createFull(z_bmqa_CloseQueueStatus** status_obj,
+                                        const z_bmqa_QueueId*     queueId,
+                                        int                       result,
+                                        const char* errorDescription)
+{
+    using namespace BloombergLP;
+
+    const bmqa::QueueId* queueId_p = reinterpret_cast<const bmqa::QueueId*>(
+        queueId);
+    const bsl::string            errorDescription_str(errorDescription);
+    bmqt::CloseQueueResult::Enum result_enum =
+        static_cast<bmqt::CloseQueueResult::Enum>(result);
+    bmqa::CloseQueueStatus* status_p = new bmqa::CloseQueueStatus(
+        *queueId_p,
+        result_enum,
+        errorDescription_str);
+    *status_obj = reinterpret_cast<z_bmqa_CloseQueueStatus*>(status_p);
+
+    return 0;
+}
+
+bool z_bmqa_CloseQueueStatus__toBool(const z_bmqa_CloseQueueStatus* status_obj)
+{
+    using namespace BloombergLP;
+    const bmqa::CloseQueueStatus* status_p =
+        reinterpret_cast<const bmqa::CloseQueueStatus*>(status_obj);
+    return *status_p;
+}
+
+int z_bmqa_CloseQueueStatus__queueId(const z_bmqa_CloseQueueStatus* status_obj,
+                                     z_bmqa_QueueId const** queueId_obj)
+{
+    using namespace BloombergLP;
+    const bmqa::CloseQueueStatus* status_p =
+        reinterpret_cast<const bmqa::CloseQueueStatus*>(status_obj);
+    const bmqa::QueueId* queueId_p = &(status_p->queueId());
+
+    *queueId_obj = reinterpret_cast<const z_bmqa_QueueId*>(queueId_p);
+    return 0;
+}
+
+int z_bmqa_CloseQueueStatus__result(const z_bmqa_CloseQueueStatus* status_obj)
+{
+    using namespace BloombergLP;
+    const bmqa::CloseQueueStatus* status_p =
+        reinterpret_cast<const bmqa::CloseQueueStatus*>(status_obj);
+    return status_p->result();
+}
+
+const char* z_bmqa_CloseQueueStatus__errorDescription(
+    const z_bmqa_CloseQueueStatus* status_obj)
+{
+    using namespace BloombergLP;
+    const bmqa::CloseQueueStatus* status_p =
+        reinterpret_cast<const bmqa::CloseQueueStatus*>(status_obj);
+    return status_p->errorDescription().c_str();
+}

src/groups/wrappers/z_bmq/z_bmqa/z_bmqa_closequeuestatus.h

@@ -0,0 +1,114 @@
+#ifndef INCLUDED_Z_BMQA_CLOSEQUEUESTATUS
+#define INCLUDED_Z_BMQA_CLOSEQUEUESTATUS
+
+#if defined(__cplusplus)
+extern "C" {
+#endif
+
+#include <stdbool.h>
+#include <z_bmqa_queueid.h>
+
+typedef struct z_bmqa_CloseQueueStatus z_bmqa_CloseQueueStatus;
+
+/**
+ * @brief Deletes the memory allocated for a pointer to a bmqa::CloseQueueStatus object.
+ *
+ * This function deallocates the memory pointed to by the input pointer to a bmqa::CloseQueueStatus object and sets the pointer to NULL.
+ * 
+ * @param status_obj A pointer to a pointer to a bmqa::CloseQueueStatus object.
+ *                   Upon successful completion, this pointer will be set to NULL.
+ * @return Returns 0 upon successful deletion.
+ */
+int z_bmqa_CloseQueueStatus__delete(z_bmqa_CloseQueueStatus** status_obj);
+
+/**
+ * @brief Creates a new bmqa::CloseQueueStatus object.
+ *
+ * This function creates a new bmqa::CloseQueueStatus object and assigns its pointer to the provided pointer.
+ * 
+ * @param status_obj A pointer to a pointer to a bmqa::CloseQueueStatus object.
+ *                   Upon successful completion, this pointer will hold the newly created CloseQueueStatus object.
+ * @return Returns 0 upon successful creation.
+ */
+int z_bmqa_CloseQueueStatus__create(z_bmqa_CloseQueueStatus** status_obj);
+
+/**
+ * @brief Creates a copy of a bmqa::CloseQueueStatus object.
+ *
+ * This function creates a copy of the specified bmqa::CloseQueueStatus object and assigns its pointer to the provided pointer.
+ * 
+ * @param status_obj A pointer to a pointer to a bmqa::CloseQueueStatus object.
+ *                   Upon successful completion, this pointer will hold the newly created copy of the CloseQueueStatus object.
+ * @param other A pointer to a constant bmqa::CloseQueueStatus object to copy.
+ * @return Returns 0 upon successful creation.
+ */
+int z_bmqa_CloseQueueStatus__createCopy(z_bmqa_CloseQueueStatus** status_obj,
+                                        const z_bmqa_CloseQueueStatus* other);
+
+/**
+ * @brief Creates a bmqa::CloseQueueStatus object with specified parameters.
+ *
+ * This function creates a new bmqa::CloseQueueStatus object with the specified parameters and assigns its pointer to the provided pointer.
+ * 
+ * @param status_obj A pointer to a pointer to a bmqa::CloseQueueStatus object.
+ *                   Upon successful completion, this pointer will hold the newly created CloseQueueStatus object.
+ * @param queueId A pointer to a constant z_bmqa_QueueId object representing the queue identifier.
+ * @param result An integer representing the result of the close operation.
+ * @param errorDescription A pointer to a constant character string representing the error description.
+ * @return Returns 0 upon successful creation.
+ */
+int z_bmqa_CloseQueueStatus__createFull(z_bmqa_CloseQueueStatus** status_obj,
+                                        const z_bmqa_QueueId*     queueId,
+                                        int                       result,
+                                        const char* errorDescription);
+
+/**
+ * @brief Converts a CloseQueueStatus object to a boolean value.
+ *
+ * This function converts the specified CloseQueueStatus object to a boolean value.
+ * 
+ * @param status_obj A pointer to a constant z_bmqa_CloseQueueStatus object to convert.
+ * @return Returns true if the CloseQueueStatus object indicates success, false otherwise.
+ */
+bool z_bmqa_CloseQueueStatus__toBool(
+    const z_bmqa_CloseQueueStatus* status_obj);
+
+/**
+ * @brief Retrieves the queue identifier from a CloseQueueStatus object.
+ *
+ * This function retrieves the queue identifier from the specified CloseQueueStatus object.
+ * 
+ * @param status_obj A pointer to a constant z_bmqa_CloseQueueStatus object.
+ * @param queueId_obj A pointer to a pointer to a constant z_bmqa_QueueId object.
+ *                    Upon successful completion, this pointer will hold the queue identifier.
+ * @return Returns 0 upon successful retrieval of the queue identifier.
+ */
+int z_bmqa_CloseQueueStatus__queueId(const z_bmqa_CloseQueueStatus* status_obj,
+                                     z_bmqa_QueueId const** queueId_obj);
+
+/**
+ * @brief Retrieves the result of a close queue operation from a CloseQueueStatus object.
+ *
+ * This function retrieves the result of the close queue operation from the specified CloseQueueStatus object.
+ * 
+ * @param status_obj A pointer to a constant z_bmqa_CloseQueueStatus object.
+ * @return Returns an integer representing the result of the close queue operation.
+ */
+int z_bmqa_CloseQueueStatus__result(const z_bmqa_CloseQueueStatus* status_obj);
+
+/**
+ * @brief Retrieves the error description from a CloseQueueStatus object.
+ *
+ * This function retrieves the error description from the specified CloseQueueStatus object.
+ * 
+ * @param status_obj A pointer to a constant z_bmqa_CloseQueueStatus object.
+ * @return Returns a pointer to a constant character string representing the error description.
+ */
+const char* z_bmqa_CloseQueueStatus__errorDescription(
+    const z_bmqa_CloseQueueStatus* status_obj);
+
+#if defined(__cplusplus)
+}
+#endif
+
+#endif