made changes to support new interface for MessageQueueService::handleEnqueue

[tpot/pegasus/.git] / src / Pegasus / ExportServer / CIMExportRequestDispatcher.cpp

diff --git a/src/Pegasus/ExportServer/CIMExportRequestDispatcher.cpp b/src/Pegasus/ExportServer/CIMExportRequestDispatcher.cpp
index abcda4d0650d0b2ceebd00155b1f2511d4074ba7..91a5fe0955b4143db4c5c1c9726ec2c497bffab8 100644 (file)
--- a/src/Pegasus/ExportServer/CIMExportRequestDispatcher.cpp
+++ b/src/Pegasus/ExportServer/CIMExportRequestDispatcher.cpp
@@ -75,17 +75,18 @@ void CIMExportRequestDispatcher::_handle_async_request(AsyncRequest *req)
     {
         req->op->processing();
         Message *legacy = (static_cast<AsyncLegacyOperationStart *>(req)->act);
-        if (false == handleEnqueue(legacy))
-            _make_response(req, async_results::CIM_NAK);
+       handleEnqueue(legacy);
+       
+//         if (false == handleEnqueue(legacy))
+//             _make_response(req, async_results::CIM_NAK);
         return;
     }
     else
         Base::_handle_async_request(req);
 }
 
-Boolean CIMExportRequestDispatcher::handleEnqueue(Message* message)
+void CIMExportRequestDispatcher::handleEnqueue(Message* message)
 {
-    Boolean ret = true;
 
     switch (message->getType())
     {
@@ -95,12 +96,10 @@ Boolean CIMExportRequestDispatcher::handleEnqueue(Message* message)
            break;
 
         default:
-            ret = false;
             break;
     }
     delete message;
 
-    return ret;
 }
 
 void CIMExportRequestDispatcher::_handleExportIndicationRequest(