diff options
| author | pradeep <pradeep@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-06-19 02:53:00 +0000 |
|---|---|---|
| committer | pradeep <pradeep@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-06-19 02:53:00 +0000 |
| commit | fb7e5ebc62fc689ae4708ae22207f1ba6452c761 (patch) | |
| tree | 0440d3447b88663f3dbaae2b33074547578cebea /TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushConsumer.cpp | |
| parent | a315910192ad14fe7182a2070451f9df4e98c4ef (diff) | |
| download | ATCD-fb7e5ebc62fc689ae4708ae22207f1ba6452c761.tar.gz | |
ChangeLogTag: Wed Jun 18 22:27:49 2003 Pradeep Gore <pradeep@oomworks.com>
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushConsumer.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushConsumer.cpp | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushConsumer.cpp b/TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushConsumer.cpp index d09f50987a7..f2d774756b8 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushConsumer.cpp +++ b/TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushConsumer.cpp @@ -10,6 +10,8 @@ ACE_RCSID(Notify, TAO_NS_ProxyPushConsumer, "$id$") #include "tao/debug.h" #include "../AdminProperties.h" +#include "../Method_Request_Lookup.h" +#include "../Worker_Task.h" #include "AnyEvent.h" #include "PushSupplier.h" @@ -60,7 +62,7 @@ TAO_NS_ProxyPushConsumer::push (TAO_NS_Event_var &/*event*/) } void -TAO_NS_ProxyPushConsumer::push (const CORBA::Any& data ACE_ENV_ARG_DECL) +TAO_NS_ProxyPushConsumer::push (const CORBA::Any& any ACE_ENV_ARG_DECL) ACE_THROW_SPEC (( CORBA::SystemException , CosEventComm::Disconnected @@ -76,11 +78,11 @@ TAO_NS_ProxyPushConsumer::push (const CORBA::Any& data ACE_ENV_ARG_DECL) ACE_THROW (CosEventComm::Disconnected ()); } - // Convert - TAO_NS_Event_var event (new TAO_NS_AnyEvent (data)); + TAO_NS_AnyEvent_No_Copy event (any); - // Continue processing. - this->TAO_NS_ProxyConsumer::push (event); + TAO_NS_Method_Request_Lookup_No_Copy request (&event, this); + + this->worker_task ()->execute (request ACE_ENV_ARG_PARAMETER); } void |