summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp')
-rw-r--r--TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp108
1 files changed, 0 insertions, 108 deletions
diff --git a/TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp b/TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp
deleted file mode 100644
index b12ce21200e..00000000000
--- a/TAO/orbsvcs/examples/RtEC/UDP/Supplier.cpp
+++ /dev/null
@@ -1,108 +0,0 @@
-// $Id$
-
-#include "Supplier.h"
-#include "orbsvcs/RtecEventChannelAdminS.h"
-#include "orbsvcs/Event_Service_Constants.h"
-
-#include "TestC.h"
-
-ACE_RCSID (EC_Examples,
- Supplier,
- "$Id$")
-
-Supplier::Supplier (bool valuetype) : valuetype_ (valuetype)
-{
-}
-
-void
-Supplier::connect (RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin
- ACE_ENV_ARG_DECL)
-{
- this->proxy_ =
- supplier_admin->obtain_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- RtecEventComm::PushSupplier_var me =
- this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- // Simple publication, but usually the helper classes in
- // $TAO_ROOT/orbsvcs/Event_Utils.h are a better way to do this.
- RtecEventChannelAdmin::SupplierQOS qos;
- qos.is_gateway = 0;
-
- qos.publications.length (1);
- RtecEventComm::EventHeader& h0 =
- qos.publications[0].event.header;
- h0.type = ACE_ES_EVENT_UNDEFINED; // first free event type
- h0.source = 1; // first free event source
-
- this->proxy_->connect_push_supplier (me.in (), qos
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-}
-
-void
-Supplier::disconnect (ACE_ENV_SINGLE_ARG_DECL)
-{
- // Disconnect from the EC
- ACE_TRY
- {
- this->proxy_->disconnect_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- }
- ACE_ENDTRY;
-
- PortableServer::POA_var poa =
- this->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
- PortableServer::ObjectId_var id =
- poa->servant_to_id (this ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
- poa->deactivate_object (id.in () ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-}
-
-void
-Supplier::perform_push (ACE_ENV_SINGLE_ARG_DECL)
-{
- ACE_TRY
- {
- // The event type and source must match our publications
- RtecEventComm::EventSet event (1);
- event.length (1);
- event[0].header.type = ACE_ES_EVENT_UNDEFINED;
- event[0].header.source = 1;
- // Avoid loops throught the event channel federations
- event[0].header.ttl = 1;
-
- if (this->valuetype_)
- {
- OBV_ValueTypeData * test_data = 0;
- ACE_NEW (test_data, OBV_ValueTypeData ());
- test_data->data ("ACE/TAO/CIAO");
- event[0].data.any_value <<= test_data;
- }
- else
- {
- event[0].data.any_value <<= CORBA::string_dup( "ACE/TAO/CIAO");
- }
-
- this->proxy_->push (event ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- }
- ACE_ENDTRY;
-}
-
-void
-Supplier::disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
-}
-