return 1 if init () call in open () succeeds

2 files changed, 10 insertions, 4 deletions

diff --git a/examples/ASX/UPIPE_Event_Server/Consumer_Router.cpp b/examples/ASX/UPIPE_Event_Server/Consumer_Router.cpp
index 524224c7d4e..b5363e3a8c8 100644
--- a/examples/ASX/UPIPE_Event_Server/Consumer_Router.cpp
+++ b/examples/ASX/UPIPE_Event_Server/Consumer_Router.cpp
@@ -44,7 +44,10 @@ Consumer_Router::open (void *)
     return -1;
 
   // Make this an active object.
-//  return this->activate (options.t_flags ());
+  //   return this->activate (options.t_flags ());
+
+  // Until that's done, return 1 to indicate that the object wasn't activated.
+  return 1;
 }
 
 int
diff --git a/examples/ASX/UPIPE_Event_Server/Supplier_Router.cpp b/examples/ASX/UPIPE_Event_Server/Supplier_Router.cpp
index 899c2dd63d5..398c1e1624a 100644
--- a/examples/ASX/UPIPE_Event_Server/Supplier_Router.cpp
+++ b/examples/ASX/UPIPE_Event_Server/Supplier_Router.cpp
@@ -56,7 +56,6 @@ int
 Supplier_Router::open (void *)
 {
   ACE_ASSERT (this->is_writer ());
-
   char *argv[3];
 
   argv[0] = (char *) this->name ();
@@ -65,8 +64,12 @@ Supplier_Router::open (void *)
 
   if (this->init (1, &argv[1]) == -1)
     return -1;
-  // Make this an active object.  Return this->activate
-  // (options.t_flags ());
+
+  // Make this an active object.
+  //   return this->activate (options.t_flags ());
+
+  // Until that's done, return 1 to indicate that the object wasn't activated.
+  return 1;
 }
 
 // Close down the router..