Changeset 6024 for branches/newapi

Timestamp:

01/11/08 07:57:15 (11 months ago)

Author:

erijo

Message:

Save the name of the eventpipe that an event is sent to so that it can
be sent to the next queue in that pipe the next time.

Location:

branches/newapi/licq/src/event

Files:

• eventmanagerimpl.cpp (modified) (1 diff)
• eventmanagerimpl.h (modified) (1 diff)

branches/newapi/licq/src/event/eventmanagerimpl.cpp

@@ -64 +64 @@
 
 void LicqDaemon::EventManagerImpl::sendEvent(const std::string& name,
-                                             boost::shared_ptr<Licq::Event> event)
+                                             Licq::Event::Ptr event)
 {
   Licq::ReadLocker locker(&myEventPipesMutex);
 
-  EventPipes::iterator pipe = myEventPipes.find(name);
+  std::string queueName;
+  if (!event->getProperty("_name", &queueName))
+  {
+    queueName = name;
+    event->setProperty("_name", queueName);
+  }
+
+  EventPipes::iterator pipe = myEventPipes.find(queueName);
   if (pipe == myEventPipes.end())
   {
-    myLog.warning(tr("No queues registered for %1%") % name);
+    myLog.warning(tr("No queues registered for %1%") % queueName);
     return;
   }

branches/newapi/licq/src/event/eventmanagerimpl.h

@@ -46 +46 @@
   void unregisterQueue(Licq::EventQueue* queue);
 
-  void sendEvent(const std::string& name,
-                 boost::shared_ptr<Licq::Event> event);
+  void sendEvent(const std::string& name, Licq::Event::Ptr event);
 
 private: