axis-java-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From manj...@apache.org
Subject svn commit: r781321 - in /webservices/axis2/trunk/c/src/core/transport/amqp: receiver/qpid_receiver/ receiver/qpid_receiver/request_processor/ sender/qpid_sender/ util/
Date Wed, 03 Jun 2009 09:46:30 GMT
Author: manjula
Date: Wed Jun  3 09:46:30 2009
New Revision: 781321

URL: http://svn.apache.org/viewvc?rev=781321&view=rev
Log:
Adding changes due to latest qpid trunk and axis2.

Modified:
    webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/axis2_qpid_receiver_listener.cpp
    webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/request_processor/axis2_amqp_request_processor.c
    webservices/axis2/trunk/c/src/core/transport/amqp/sender/qpid_sender/axis2_qpid_sender.cpp
    webservices/axis2/trunk/c/src/core/transport/amqp/util/axis2_amqp_util.c

Modified: webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/axis2_qpid_receiver_listener.cpp
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/axis2_qpid_receiver_listener.cpp?rev=781321&r1=781320&r2=781321&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/axis2_qpid_receiver_listener.cpp
(original)
+++ webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/axis2_qpid_receiver_listener.cpp
Wed Jun  3 09:46:30 2009
@@ -82,7 +82,7 @@
 	/* Copy AMQP headers */
 	/* Content-Type */
 	request_data->content_type = NULL;
-	std::string content_type_tmp = message.getHeaders().getString(AXIS2_AMQP_HEADER_CONTENT_TYPE);
+	std::string content_type_tmp = message.getHeaders().getAsString(AXIS2_AMQP_HEADER_CONTENT_TYPE);
 	if (!content_type_tmp.empty())
 	{
 		axis2_char_t* content_type = (axis2_char_t*)AXIS2_MALLOC(env->allocator,
@@ -94,7 +94,7 @@
 	
 	/* SOAPAction */
 	request_data->soap_action = NULL;
-	std::string soap_action_tmp = message.getHeaders().getString(AXIS2_AMQP_HEADER_SOAP_ACTION);
+	std::string soap_action_tmp = message.getHeaders().getAsString(AXIS2_AMQP_HEADER_SOAP_ACTION);
 	if (!soap_action_tmp.empty())
 	{
 		axis2_char_t* soap_action = (axis2_char_t*)AXIS2_MALLOC(env->allocator,

Modified: webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/request_processor/axis2_amqp_request_processor.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/request_processor/axis2_amqp_request_processor.c?rev=781321&r1=781320&r2=781321&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/request_processor/axis2_amqp_request_processor.c
(original)
+++ webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/request_processor/axis2_amqp_request_processor.c
Wed Jun  3 09:46:30 2009
@@ -207,11 +207,11 @@
                 	callback_ctx->chunked_stream = NULL;
             	}
 
-                binary_data_map = 
+                /*binary_data_map = 
                     axiom_mime_parser_parse(mime_parser, env,
                                             axis2_amqp_util_on_data_request,
                                             (void*)callback_ctx,
-                                            mime_boundary);
+                                            mime_boundary);*/
                 if (!binary_data_map)
                 {
                     return AXIS2_FAILURE;

Modified: webservices/axis2/trunk/c/src/core/transport/amqp/sender/qpid_sender/axis2_qpid_sender.cpp
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/transport/amqp/sender/qpid_sender/axis2_qpid_sender.cpp?rev=781321&r1=781320&r2=781321&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/transport/amqp/sender/qpid_sender/axis2_qpid_sender.cpp
(original)
+++ webservices/axis2/trunk/c/src/core/transport/amqp/sender/qpid_sender/axis2_qpid_sender.cpp
Wed Jun  3 09:46:30 2009
@@ -87,7 +87,7 @@
 
 		reqMessage.setData(messageContent);
 	
-		async(session).messageTransfer(arg::content = reqMessage, arg::destination = AXIS2_AMQP_EXCHANGE_DIRECT);
+		session.messageTransfer(arg::content = reqMessage, arg::destination = AXIS2_AMQP_EXCHANGE_DIRECT);
 		
 		/* Create subscription manager */
 		SubscriptionManager subscriptionManager(session);
@@ -98,7 +98,7 @@
 		if (subscriptionManager.get(resMessage, replyToQueueName, reqTimeout))
 		{
 			responseContent = resMessage.getData();
-			responseContentType = resMessage.getHeaders().getString(AXIS2_AMQP_HEADER_CONTENT_TYPE);
+			responseContentType = resMessage.getHeaders().getAsString(AXIS2_AMQP_HEADER_CONTENT_TYPE);
 		
 			status = true;
 		}
@@ -155,7 +155,7 @@
 
 		message.setData(messageContent);
 
-		async(session).messageTransfer(arg::content = message, arg::destination = AXIS2_AMQP_EXCHANGE_DIRECT);
+		session.messageTransfer(arg::content = message, arg::destination = AXIS2_AMQP_EXCHANGE_DIRECT);
 
 		connection.close();
 

Modified: webservices/axis2/trunk/c/src/core/transport/amqp/util/axis2_amqp_util.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/transport/amqp/util/axis2_amqp_util.c?rev=781321&r1=781320&r2=781321&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/transport/amqp/util/axis2_amqp_util.c (original)
+++ webservices/axis2/trunk/c/src/core/transport/amqp/util/axis2_amqp_util.c Wed Jun  3 09:46:30
2009
@@ -217,11 +217,11 @@
                 	callback_ctx->chunked_stream = NULL;
             	}
 
-                binary_data_map = 
+                /*binary_data_map = 
                     axiom_mime_parser_parse(mime_parser, env,
                                             axis2_amqp_util_on_data_request,
                                             (void*)callback_ctx,
-                                            mime_boundary);
+                                            mime_boundary);*/
 
                 if (!binary_data_map)
                 {



Mime
View raw message