1 files changed, 73 insertions, 0 deletions
diff --git a/TAO/examples/Event_Comm/Consumer_Input_Handler.h b/TAO/examples/Event_Comm/Consumer_Input_Handler.h
new file mode 100644
index 00000000000..0a98278ffae
--- /dev/null
+++ b/TAO/examples/Event_Comm/Consumer_Input_Handler.h
@@ -0,0 +1,73 @@
+/* -*- C++ -*- */
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//    EventComm
+//
+// = FILENAME
+//    Consumer_Input_Handler.h
+//
+// = AUTHOR
+//    Douglas C. Schmidt (schmidt@cs.wustl.edu)
+//
+// ============================================================================
+
+#ifndef CONSUMER_INPUT_HANDLER_H
+#define CONSUMER_INPUT_HANDLER_
+
+#include "ace/Service_Config.h"
+#include "ace/Event_Handler.h"
+
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+// Forward declaration.
+class Consumer_Handler;
+
+class Consumer_Input_Handler : public ACE_Event_Handler
+{
+  // = TITLE
+  //   Handles input events generated from a keyboard.
+  //
+  // = DESCRIPTION
+  //    This class holds a <Consumer_Handler> object. It accepts input
+  //    from the user and passes events to the <Notifier>. It also
+  //    initiates shutdown.
+public:
+  // Initialization and termination methods.
+  Consumer_Input_Handler(void);
+  // Constructor.
+
+  ~Consumer_Input_Handler (void);
+  // Destructor.
+
+  int initialize (Consumer_Handler *);
+  // registers the input event handler.
+  // returns 0 on success, -1 on error.
+
+  virtual int handle_input (ACE_HANDLE);
+  // Dispatch the callback when events occur.
+
+  int close (void);
+  // Close down the handler.
+
+  int consumer_initiated_shutdown (void);
+  // Report whether the Consumer initiated the shutdown.
+
+  void consumer_initiated_shutdown (int);
+  // Indicate that the Consumer initiated the shutdown.
+
+private:
+    Consumer_Handler *receiver_handler_;
+  // Pointer to the <Consumer_Handler> that receives notifications
+  // from the <Event_Comm::Notifier>.
+
+  int consumer_initiated_shutdown_;
+  // Keep track of whether the Consumer initiated the shutdown.
+};
+
+#endif /* CONSUMER_INPUT_HANDLER_H */