Diff: messaging.c

Revision:

28:add19eb7defa

Parent:

17:923575db8b2d

Child:

34:6be9c2058664

diff -r d74f1cea23e1 -r add19eb7defa messaging.c
--- a/messaging.c	Fri Jun 02 15:53:07 2017 -0700
+++ b/messaging.c	Fri Jun 30 10:41:22 2017 -0700
@@ -8,202 +8,202 @@
 
 AMQP_VALUE messaging_create_source(const char* address)
 {
-	AMQP_VALUE result;
-	SOURCE_HANDLE source = source_create();
-	if (source == NULL)
-	{
-		result = NULL;
-	}
-	else
-	{
-		AMQP_VALUE address_value = amqpvalue_create_string(address);
-		if (address_value == NULL)
-		{
-			result = NULL;
-		}
-		else
-		{
-			if (source_set_address(source, address_value) != 0)
-			{
-				result = NULL;
-			}
-			else
-			{
-				result = amqpvalue_create_source(source);
-			}
+    AMQP_VALUE result;
+    SOURCE_HANDLE source = source_create();
+    if (source == NULL)
+    {
+        result = NULL;
+    }
+    else
+    {
+        AMQP_VALUE address_value = amqpvalue_create_string(address);
+        if (address_value == NULL)
+        {
+            result = NULL;
+        }
+        else
+        {
+            if (source_set_address(source, address_value) != 0)
+            {
+                result = NULL;
+            }
+            else
+            {
+                result = amqpvalue_create_source(source);
+            }
 
-			amqpvalue_destroy(address_value);
-		}
+            amqpvalue_destroy(address_value);
+        }
 
-		source_destroy(source);
-	}
+        source_destroy(source);
+    }
 
-	return result;
+    return result;
 }
 
 AMQP_VALUE messaging_create_target(const char* address)
 {
-	AMQP_VALUE result;
-	TARGET_HANDLE target = target_create();
-	if (target == NULL)
-	{
-		result = NULL;
-	}
-	else
-	{
-		AMQP_VALUE address_value = amqpvalue_create_string(address);
-		if (address_value == NULL)
-		{
-			result = NULL;
-		}
-		else
-		{
-			if (target_set_address(target, address_value) != 0)
-			{
-				result = NULL;
-			}
-			else
-			{
-				result = amqpvalue_create_target(target);
-			}
+    AMQP_VALUE result;
+    TARGET_HANDLE target = target_create();
+    if (target == NULL)
+    {
+        result = NULL;
+    }
+    else
+    {
+        AMQP_VALUE address_value = amqpvalue_create_string(address);
+        if (address_value == NULL)
+        {
+            result = NULL;
+        }
+        else
+        {
+            if (target_set_address(target, address_value) != 0)
+            {
+                result = NULL;
+            }
+            else
+            {
+                result = amqpvalue_create_target(target);
+            }
 
-			amqpvalue_destroy(address_value);
-		}
+            amqpvalue_destroy(address_value);
+        }
 
-		target_destroy(target);
-	}
+        target_destroy(target);
+    }
 
-	return result;
+    return result;
 }
 
 AMQP_VALUE messaging_delivery_received(uint32_t section_number, uint64_t section_offset)
 {
-	AMQP_VALUE result;
-	RECEIVED_HANDLE received = received_create(section_number, section_offset);
-	if (received == NULL)
-	{
-		result = NULL;
-	}
-	else
-	{
-		result = amqpvalue_create_received(received);
-		received_destroy(received);
-	}
+    AMQP_VALUE result;
+    RECEIVED_HANDLE received = received_create(section_number, section_offset);
+    if (received == NULL)
+    {
+        result = NULL;
+    }
+    else
+    {
+        result = amqpvalue_create_received(received);
+        received_destroy(received);
+    }
 
-	return result;
+    return result;
 }
 
 AMQP_VALUE messaging_delivery_accepted(void)
 {
-	AMQP_VALUE result;
-	ACCEPTED_HANDLE accepted = accepted_create();
-	if (accepted == NULL)
-	{
-		result = NULL;
-	}
-	else
-	{
-		result = amqpvalue_create_accepted(accepted);
-		accepted_destroy(accepted);
-	}
+    AMQP_VALUE result;
+    ACCEPTED_HANDLE accepted = accepted_create();
+    if (accepted == NULL)
+    {
+        result = NULL;
+    }
+    else
+    {
+        result = amqpvalue_create_accepted(accepted);
+        accepted_destroy(accepted);
+    }
 
-	return result;
+    return result;
 }
 
 AMQP_VALUE messaging_delivery_rejected(const char* error_condition, const char* error_description)
 {
-	AMQP_VALUE result;
-	REJECTED_HANDLE rejected = rejected_create();
-	if (rejected == NULL)
-	{
-		result = NULL;
-	}
-	else
-	{
-		ERROR_HANDLE error_handle = NULL;
-		bool error_constructing = false;
+    AMQP_VALUE result;
+    REJECTED_HANDLE rejected = rejected_create();
+    if (rejected == NULL)
+    {
+        result = NULL;
+    }
+    else
+    {
+        ERROR_HANDLE error_handle = NULL;
+        bool error_constructing = false;
 
-		if (error_condition != NULL)
-		{
-			error_handle = error_create(error_condition);
-			if (error_handle == NULL)
-			{
-				error_constructing = true;
-			}
-			else
-			{
-				if ((error_description != NULL) &&
-					(error_set_description(error_handle, error_description) != 0))
-				{
-					error_constructing = true;
-				}
-				else
-				{
-					if (rejected_set_error(rejected, error_handle) != 0)
-					{
-						error_constructing = true;
-					}
-				}
+        if (error_condition != NULL)
+        {
+            error_handle = error_create(error_condition);
+            if (error_handle == NULL)
+            {
+                error_constructing = true;
+            }
+            else
+            {
+                if ((error_description != NULL) &&
+                    (error_set_description(error_handle, error_description) != 0))
+                {
+                    error_constructing = true;
+                }
+                else
+                {
+                    if (rejected_set_error(rejected, error_handle) != 0)
+                    {
+                        error_constructing = true;
+                    }
+                }
 
-				error_destroy(error_handle);
-			}
-		}
+                error_destroy(error_handle);
+            }
+        }
 
-		if (error_constructing)
-		{
-			result = NULL;
-		}
-		else
-		{
-			result = amqpvalue_create_rejected(rejected);
-		}
+        if (error_constructing)
+        {
+            result = NULL;
+        }
+        else
+        {
+            result = amqpvalue_create_rejected(rejected);
+        }
 
-		rejected_destroy(rejected);
-	}
+        rejected_destroy(rejected);
+    }
 
-	return result;
+    return result;
 }
 
 AMQP_VALUE messaging_delivery_released(void)
 {
-	AMQP_VALUE result;
-	RELEASED_HANDLE released = released_create();
-	if (released == NULL)
-	{
-		result = NULL;
-	}
-	else
-	{
-		result = amqpvalue_create_released(released);
-		released_destroy(released);
-	}
+    AMQP_VALUE result;
+    RELEASED_HANDLE released = released_create();
+    if (released == NULL)
+    {
+        result = NULL;
+    }
+    else
+    {
+        result = amqpvalue_create_released(released);
+        released_destroy(released);
+    }
 
-	return result;
+    return result;
 }
 
 AMQP_VALUE messaging_delivery_modified(bool delivery_failed, bool undeliverable_here, fields message_annotations)
 {
-	AMQP_VALUE result;
-	MODIFIED_HANDLE modified = modified_create();
-	if (modified == NULL)
-	{
-		result = NULL;
-	}
-	else
-	{
-		if ((modified_set_delivery_failed(modified, delivery_failed) != 0) ||
-			(modified_set_undeliverable_here(modified, undeliverable_here) != 0) ||
-			((message_annotations != NULL) && (modified_set_message_annotations(modified, message_annotations) != 0)))
-		{
-			result = NULL;
-		}
-		else
-		{
-			result = amqpvalue_create_modified(modified);
-		}
+    AMQP_VALUE result;
+    MODIFIED_HANDLE modified = modified_create();
+    if (modified == NULL)
+    {
+        result = NULL;
+    }
+    else
+    {
+        if ((modified_set_delivery_failed(modified, delivery_failed) != 0) ||
+            (modified_set_undeliverable_here(modified, undeliverable_here) != 0) ||
+            ((message_annotations != NULL) && (modified_set_message_annotations(modified, message_annotations) != 0)))
+        {
+            result = NULL;
+        }
+        else
+        {
+            result = amqpvalue_create_modified(modified);
+        }
 
-		modified_destroy(modified);
-	}
+        modified_destroy(modified);
+    }
 
-	return result;
+    return result;
 }