*** empty log message ***

5 files changed, 1461 insertions, 0 deletions

diff --git a/TAO/orbsvcs/examples/Log/Notify/Makefile b/TAO/orbsvcs/examples/Log/Notify/Makefile
new file mode 100644
index 00000000000..dc45afed8c7
--- /dev/null
+++ b/TAO/orbsvcs/examples/Log/Notify/Makefile
@@ -0,0 +1,693 @@
+#----------------------------------------------------------------------------
+#
+# $Id$
+#
+#----------------------------------------------------------------------------
+
+#----------------------------------------------------------------------------
+#       Local macros
+#----------------------------------------------------------------------------
+
+ifndef TAO_ROOT
+  TAO_ROOT = $(ACE_ROOT)/TAO
+endif # ! TAO_ROOT
+
+
+
+BIN2 =  Notify_Consumer \
+	Notify_Supplier
+
+PSRC=$(addsuffix .cpp,$(BIN2))
+LDLIBS = -lTAO_CosNotification -lTAO_DsNotifyLogAdmin -lACE -lTAO -lTAO_DsLogAdmin -lTAO_PortableServer  -lTAO_CosNaming   
+CPPFLAGS += -I$(TAO_ROOT) -I$(TAO_ROOT)/orbsvcs \
+        $(foreach svc, $(TAO_ORBSVCS), -DTAO_ORBSVCS_HAS_$(svc))
+
+#----------------------------------------------------------------------------
+#       Include macros and targets
+#----------------------------------------------------------------------------
+
+
+
+include $(ACE_ROOT)/include/makeinclude/wrapper_macros.GNU
+include $(ACE_ROOT)/include/makeinclude/macros.GNU
+include $(TAO_ROOT)/rules.tao.GNU
+#### If the TAO orbsvcs library wasn't built with sufficient components,
+#### don't try to build here.
+TAO_ORBSVCS := $(shell sh $(ACE_ROOT)/bin/ace_components --orbsvcs)
+ifeq (Log,$(findstring Log,$(TAO_ORBSVCS)))
+  ifeq (Naming,$(findstring Naming,$(TAO_ORBSVCS)))
+    BIN = $(BIN2)
+  endif # Naming
+endif # Log
+include $(ACE_ROOT)/include/makeinclude/rules.common.GNU
+include $(ACE_ROOT)/include/makeinclude/rules.nonested.GNU
+include $(ACE_ROOT)/include/makeinclude/rules.bin.GNU
+include $(ACE_ROOT)/include/makeinclude/rules.local.GNU
+
+# To build multiple executables in the same directory on AIX, it works
+# best to wipe out any previously-created tempinc directory.
+# The compiler/linker isn't too smart about instantiating templates...
+ifdef TEMPINCDIR
+COMPILE.cc := $(RM) -rf tempinc; $(COMPILE.cc)
+endif
+
+
+#----------------------------------------------------------------------------
+#       Local targets
+#----------------------------------------------------------------------------
+
+
+#----------------------------------------------------------------------------
+#       Dependencies
+#----------------------------------------------------------------------------
+# DO NOT DELETE THIS LINE -- g++dep uses it.
+# DO NOT PUT ANYTHING AFTER THIS LINE, IT WILL GO AWAY.
+
+
+.obj/Notify_Consumer.o .obj/Notify_Consumer.so .shobj/Notify_Consumer.o .shobj/Notify_Consumer.so: Notify_Consumer.cpp Notify_Consumer.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsNotifyLogAdminS.h \
+  $(ACE_ROOT)/ace/pre.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsEventLogAdminS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommC.h \
+  $(TAO_ROOT)/tao/corba.h \
+  $(ACE_ROOT)/ace/post.h \
+  $(ACE_ROOT)/ace/ace_wchar.h \
+  $(ACE_ROOT)/ace/ace_wchar.inl \
+  $(TAO_ROOT)/tao/corbafwd.h \
+  $(ACE_ROOT)/ace/CDR_Base.h \
+  $(ACE_ROOT)/ace/Basic_Types.h \
+  $(ACE_ROOT)/ace/ACE_export.h \
+  $(ACE_ROOT)/ace/Basic_Types.i \
+  $(ACE_ROOT)/ace/Message_Block.h \
+  $(ACE_ROOT)/ace/OS.h \
+  $(ACE_ROOT)/ace/OS_Dirent.h \
+  $(ACE_ROOT)/ace/OS_Export.h \
+  $(ACE_ROOT)/ace/OS_Errno.h \
+  $(ACE_ROOT)/ace/OS_Errno.inl \
+  $(ACE_ROOT)/ace/OS_Dirent.inl \
+  $(ACE_ROOT)/ace/OS_String.h \
+  $(ACE_ROOT)/ace/OS_String.inl \
+  $(ACE_ROOT)/ace/OS_Memory.h \
+  $(ACE_ROOT)/ace/OS_Memory.inl \
+  $(ACE_ROOT)/ace/OS_TLI.h \
+  $(ACE_ROOT)/ace/OS_TLI.inl \
+  $(ACE_ROOT)/ace/Time_Value.h \
+  $(ACE_ROOT)/ace/Time_Value.inl \
+  $(ACE_ROOT)/ace/Default_Constants.h \
+  $(ACE_ROOT)/ace/Global_Macros.h \
+  $(ACE_ROOT)/ace/Min_Max.h \
+  $(ACE_ROOT)/ace/streams.h \
+  $(ACE_ROOT)/ace/Trace.h \
+  $(ACE_ROOT)/ace/OS.i \
+  $(ACE_ROOT)/ace/Message_Block.i \
+  $(ACE_ROOT)/ace/Message_Block_T.h \
+  $(ACE_ROOT)/ace/Message_Block_T.i \
+  $(ACE_ROOT)/ace/Message_Block_T.cpp \
+  $(ACE_ROOT)/ace/CDR_Base.inl \
+  $(ACE_ROOT)/ace/CORBA_macros.h \
+  $(ACE_ROOT)/ace/Exception_Macros.h \
+  $(TAO_ROOT)/tao/orbconf.h \
+  $(TAO_ROOT)/tao/varbase.h \
+  $(TAO_ROOT)/tao/TAO_Export.h \
+  $(TAO_ROOT)/tao/corbafwd.i \
+  $(TAO_ROOT)/tao/Typecode.h \
+  $(ACE_ROOT)/ace/Synch.h \
+  $(ACE_ROOT)/ace/Synch.i \
+  $(ACE_ROOT)/ace/Synch_T.h \
+  $(ACE_ROOT)/ace/Synch_T.i \
+  $(ACE_ROOT)/ace/Thread.h \
+  $(ACE_ROOT)/ace/Thread_Adapter.h \
+  $(ACE_ROOT)/ace/Base_Thread_Adapter.h \
+  $(ACE_ROOT)/ace/OS_Log_Msg_Attributes.h \
+  $(ACE_ROOT)/ace/OS_Log_Msg_Attributes.inl \
+  $(ACE_ROOT)/ace/Base_Thread_Adapter.inl \
+  $(ACE_ROOT)/ace/Thread_Adapter.inl \
+  $(ACE_ROOT)/ace/Thread.i \
+  $(ACE_ROOT)/ace/Synch_T.cpp \
+  $(ACE_ROOT)/ace/Log_Msg.h \
+  $(ACE_ROOT)/ace/Log_Priority.h \
+  $(TAO_ROOT)/tao/Exception.h \
+  $(ACE_ROOT)/ace/SString.h \
+  $(ACE_ROOT)/ace/String_Base.h \
+  $(ACE_ROOT)/ace/ACE.h \
+  $(ACE_ROOT)/ace/Flag_Manip.h \
+  $(ACE_ROOT)/ace/Flag_Manip.i \
+  $(ACE_ROOT)/ace/Handle_Ops.h \
+  $(ACE_ROOT)/ace/Handle_Ops.i \
+  $(ACE_ROOT)/ace/Lib_Find.h \
+  $(ACE_ROOT)/ace/Lib_Find.i \
+  $(ACE_ROOT)/ace/Init_ACE.h \
+  $(ACE_ROOT)/ace/Init_ACE.i \
+  $(ACE_ROOT)/ace/Sock_Connect.h \
+  $(ACE_ROOT)/ace/Sock_Connect.i \
+  $(ACE_ROOT)/ace/ACE.i \
+  $(ACE_ROOT)/ace/String_Base_Const.h \
+  $(ACE_ROOT)/ace/String_Base.i \
+  $(ACE_ROOT)/ace/Malloc_Base.h \
+  $(ACE_ROOT)/ace/String_Base.cpp \
+  $(ACE_ROOT)/ace/Malloc.h \
+  $(ACE_ROOT)/ace/Malloc.i \
+  $(ACE_ROOT)/ace/Malloc_T.h \
+  $(ACE_ROOT)/ace/Malloc_Allocator.h \
+  $(ACE_ROOT)/ace/Malloc_Allocator.i \
+  $(ACE_ROOT)/ace/Free_List.h \
+  $(ACE_ROOT)/ace/Free_List.i \
+  $(ACE_ROOT)/ace/Free_List.cpp \
+  $(ACE_ROOT)/ace/Malloc_T.i \
+  $(ACE_ROOT)/ace/Malloc_T.cpp \
+  $(ACE_ROOT)/ace/Memory_Pool.h \
+  $(ACE_ROOT)/ace/Event_Handler.h \
+  $(ACE_ROOT)/ace/Event_Handler.i \
+  $(ACE_ROOT)/ace/Signal.h \
+  $(ACE_ROOT)/ace/Signal.i \
+  $(ACE_ROOT)/ace/Mem_Map.h \
+  $(ACE_ROOT)/ace/Mem_Map.i \
+  $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \
+  $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \
+  $(ACE_ROOT)/ace/SV_Semaphore_Simple.i \
+  $(ACE_ROOT)/ace/SV_Semaphore_Complex.i \
+  $(ACE_ROOT)/ace/Unbounded_Set.h \
+  $(ACE_ROOT)/ace/Node.h \
+  $(ACE_ROOT)/ace/Node.cpp \
+  $(ACE_ROOT)/ace/Unbounded_Set.inl \
+  $(ACE_ROOT)/ace/Unbounded_Set.cpp \
+  $(ACE_ROOT)/ace/Memory_Pool.i \
+  $(ACE_ROOT)/ace/Auto_Ptr.h \
+  $(ACE_ROOT)/ace/Auto_Ptr.i \
+  $(ACE_ROOT)/ace/Auto_Ptr.cpp \
+  $(ACE_ROOT)/ace/SString.i \
+  $(TAO_ROOT)/tao/Exception.i \
+  $(TAO_ROOT)/tao/Typecode.i \
+  $(TAO_ROOT)/tao/Any.h \
+  $(TAO_ROOT)/tao/CDR.h \
+  $(ACE_ROOT)/ace/CDR_Stream.h \
+  $(ACE_ROOT)/ace/CDR_Stream.i \
+  $(TAO_ROOT)/tao/CDR.i \
+  $(TAO_ROOT)/tao/Environment.h \
+  $(TAO_ROOT)/tao/Environment.i \
+  $(TAO_ROOT)/tao/Object.h \
+  $(TAO_ROOT)/tao/Policy_ForwardC.h \
+  $(TAO_ROOT)/tao/Sequence.h \
+  $(TAO_ROOT)/tao/Managed_Types.h \
+  $(TAO_ROOT)/tao/Managed_Types.i \
+  $(TAO_ROOT)/tao/Sequence.i \
+  $(TAO_ROOT)/tao/Sequence_T.h \
+  $(TAO_ROOT)/tao/Sequence_T.i \
+  $(TAO_ROOT)/tao/Sequence_T.cpp \
+  $(TAO_ROOT)/tao/Policy_ForwardC.i \
+  $(TAO_ROOT)/tao/Object.i \
+  $(TAO_ROOT)/tao/Any.i \
+  $(TAO_ROOT)/tao/NVList.h \
+  $(ACE_ROOT)/ace/Unbounded_Queue.h \
+  $(ACE_ROOT)/ace/Unbounded_Queue.inl \
+  $(ACE_ROOT)/ace/Unbounded_Queue.cpp \
+  $(TAO_ROOT)/tao/NVList.i \
+  $(TAO_ROOT)/tao/LocalObject.h \
+  $(TAO_ROOT)/tao/LocalObject.i \
+  $(TAO_ROOT)/tao/Principal.h \
+  $(TAO_ROOT)/tao/OctetSeqC.h \
+  $(TAO_ROOT)/tao/OctetSeqC.i \
+  $(TAO_ROOT)/tao/Principal.i \
+  $(TAO_ROOT)/tao/ORB.h \
+  $(TAO_ROOT)/tao/Services.h \
+  $(TAO_ROOT)/tao/Services.i \
+  $(TAO_ROOT)/tao/CORBA_String.h \
+  $(TAO_ROOT)/tao/CORBA_String.inl \
+  $(TAO_ROOT)/tao/objectid.h \
+  $(TAO_ROOT)/tao/PolicyC.h \
+  $(TAO_ROOT)/tao/CurrentC.h \
+  $(TAO_ROOT)/tao/CurrentC.i \
+  $(TAO_ROOT)/tao/Remote_Object_Proxy_Impl.h \
+  $(TAO_ROOT)/tao/Object_Proxy_Impl.h \
+  $(TAO_ROOT)/tao/Encodable.h \
+  $(TAO_ROOT)/tao/PolicyC.i \
+  $(TAO_ROOT)/tao/ORB.i \
+  $(TAO_ROOT)/tao/BoundsC.h \
+  $(TAO_ROOT)/tao/BoundsC.i \
+  $(TAO_ROOT)/tao/ValueBase.h \
+  $(TAO_ROOT)/tao/ValueBase.i \
+  $(TAO_ROOT)/tao/ValueFactory.h \
+  $(TAO_ROOT)/tao/ValueFactory.i \
+  $(TAO_ROOT)/tao/AbstractBase.h \
+  $(TAO_ROOT)/tao/AbstractBase.inl \
+  $(TAO_ROOT)/tao/DomainC.h \
+  $(TAO_ROOT)/tao/DomainC.i \
+  $(TAO_ROOT)/tao/WrongTransactionC.h \
+  $(TAO_ROOT)/tao/WrongTransactionC.i \
+  $(TAO_ROOT)/tao/Object_KeyC.h \
+  $(TAO_ROOT)/tao/Object_KeyC.i \
+  $(TAO_ROOT)/tao/ObjectIDList.h \
+  $(TAO_ROOT)/tao/ObjectIDList.i \
+  $(TAO_ROOT)/tao/StringSeqC.h \
+  $(TAO_ROOT)/tao/StringSeqC.i \
+  $(TAO_ROOT)/tao/PortableInterceptorC.h \
+  $(TAO_ROOT)/tao/DynamicC.h \
+  $(TAO_ROOT)/tao/DynamicC.i \
+  $(TAO_ROOT)/tao/ObjectReferenceTemplateC.h \
+  $(TAO_ROOT)/tao/ObjectReferenceTemplateC.i \
+  $(TAO_ROOT)/tao/Messaging_SyncScopeC.h \
+  $(TAO_ROOT)/tao/Messaging_SyncScopeC.i \
+  $(TAO_ROOT)/tao/IOPC.h \
+  $(TAO_ROOT)/tao/IOPC.i \
+  $(TAO_ROOT)/tao/PortableInterceptorC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEvent/event_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommC.i \
+  $(TAO_ROOT)/tao/PortableServer/PortableServer.h \
+  $(TAO_ROOT)/tao/PortableServer/portableserver_export.h \
+  $(TAO_ROOT)/tao/PortableServer/PortableServerC.h \
+  $(TAO_ROOT)/tao/PortableServer/PortableServerC.i \
+  $(TAO_ROOT)/tao/PortableServer/Servant_Base.h \
+  $(TAO_ROOT)/tao/Abstract_Servant_Base.h \
+  $(ACE_ROOT)/ace/Atomic_Op.h \
+  $(ACE_ROOT)/ace/Atomic_Op_T.h \
+  $(ACE_ROOT)/ace/Atomic_Op_T.i \
+  $(ACE_ROOT)/ace/Atomic_Op_T.cpp \
+  $(ACE_ROOT)/ace/Atomic_Op.i \
+  $(TAO_ROOT)/tao/PortableServer/Servant_Base.i \
+  $(TAO_ROOT)/tao/PortableServer/Collocated_Object.h \
+  $(TAO_ROOT)/tao/PortableServer/Collocated_Object.i \
+  $(TAO_ROOT)/tao/PortableServer/ThruPOA_Object_Proxy_Impl.h \
+  $(TAO_ROOT)/tao/PortableServer/Direct_Object_Proxy_Impl.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsLogAdminS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseS.h \
+  $(TAO_ROOT)/tao/TimeBaseS.h \
+  $(TAO_ROOT)/tao/TimeBaseC.h \
+  $(TAO_ROOT)/tao/SmartProxies/Smart_Proxies.h \
+  $(TAO_ROOT)/tao/SmartProxies/smartproxies_export.h \
+  $(TAO_ROOT)/tao/TAO_Singleton.h \
+  $(TAO_ROOT)/tao/TAO_Singleton.inl \
+  $(TAO_ROOT)/tao/TAO_Singleton.cpp \
+  $(ACE_ROOT)/ace/Object_Manager.h \
+  $(ACE_ROOT)/ace/Object_Manager.i \
+  $(ACE_ROOT)/ace/Managed_Object.h \
+  $(ACE_ROOT)/ace/Managed_Object.i \
+  $(ACE_ROOT)/ace/Managed_Object.cpp \
+  $(TAO_ROOT)/tao/TAO_Singleton_Manager.h \
+  $(TAO_ROOT)/tao/TAO_Singleton_Manager.inl \
+  $(TAO_ROOT)/tao/SmartProxies/Smart_Proxies.inl \
+  $(TAO_ROOT)/tao/TimeBaseC.i \
+  $(TAO_ROOT)/tao/TimeBaseS_T.h \
+  $(TAO_ROOT)/tao/TimeBaseS_T.i \
+  $(TAO_ROOT)/tao/TimeBaseS_T.cpp \
+  $(TAO_ROOT)/tao/TimeBaseS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/svc_utils_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsLogAdminC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Log/log_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsLogAdminC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsLogAdminS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsLogAdminS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsLogAdminS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsLogAdminS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsEventLogAdminC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Log/eventlog_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsEventLogAdminC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsEventLogAdminS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsEventLogAdminS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsEventLogAdminS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsEventLogAdminS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/notify_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsNotifyLogAdminC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Log/notifylog_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsNotifyLogAdminC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsNotifyLogAdminS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsNotifyLogAdminS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsNotifyLogAdminS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsNotifyLogAdminS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/Notify_EventChannelFactory_i.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/Notify_ID_Pool_T.h \
+  $(ACE_ROOT)/ace/Containers_T.h \
+  $(ACE_ROOT)/ace/Containers.h \
+  $(ACE_ROOT)/ace/Containers.i \
+  $(ACE_ROOT)/ace/Array_Base.h \
+  $(ACE_ROOT)/ace/Array_Base.inl \
+  $(ACE_ROOT)/ace/Array_Base.cpp \
+  $(ACE_ROOT)/ace/Containers_T.i \
+  $(ACE_ROOT)/ace/Containers_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/Notify_ID_Pool_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/Notify_ID_Pool_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/Notify_EventChannel_i.h \
+  $(ACE_ROOT)/ace/Hash_Map_Manager.h \
+  $(ACE_ROOT)/ace/Hash_Map_Manager_T.h \
+  $(ACE_ROOT)/ace/Functor.h \
+  $(ACE_ROOT)/ace/Functor.i \
+  $(ACE_ROOT)/ace/Functor_T.h \
+  $(ACE_ROOT)/ace/Functor_T.i \
+  $(ACE_ROOT)/ace/Functor_T.cpp \
+  $(ACE_ROOT)/ace/Hash_Map_Manager_T.i \
+  $(ACE_ROOT)/ace/Hash_Map_Manager_T.cpp \
+  $(ACE_ROOT)/ace/Service_Config.h \
+  $(ACE_ROOT)/ace/Service_Types.h \
+  $(ACE_ROOT)/ace/Service_Object.h \
+  $(ACE_ROOT)/ace/Shared_Object.h \
+  $(ACE_ROOT)/ace/Shared_Object.i \
+  $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
+  $(ACE_ROOT)/ace/DLL.h \
+  $(ACE_ROOT)/ace/Service_Object.i \
+  $(ACE_ROOT)/ace/Service_Types.i \
+  $(ACE_ROOT)/ace/XML_Svc_Conf.h \
+  $(ACE_ROOT)/ace/Service_Config.i \
+  $(ACE_ROOT)/ace/Reactor.h \
+  $(ACE_ROOT)/ace/Handle_Set.h \
+  $(ACE_ROOT)/ace/Handle_Set.i \
+  $(ACE_ROOT)/ace/Timer_Queue.h \
+  $(ACE_ROOT)/ace/Timer_Queue_T.h \
+  $(ACE_ROOT)/ace/Test_and_Set.h \
+  $(ACE_ROOT)/ace/Test_and_Set.i \
+  $(ACE_ROOT)/ace/Test_and_Set.cpp \
+  $(ACE_ROOT)/ace/Timer_Queue_T.i \
+  $(ACE_ROOT)/ace/Timer_Queue_T.cpp \
+  $(ACE_ROOT)/ace/Reactor.i \
+  $(ACE_ROOT)/ace/Reactor_Impl.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/Notify_QoSAdmin_i.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/Notify_QoSAdmin_i.inl \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/Notify_Collection.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/ESF/ESF_Worker.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/ESF/ESF_Worker.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/ESF/ESF_Worker.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/Notify_Event.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/Notify_Event.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/naming_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.i
+
+.obj/Notify_Supplier.o .obj/Notify_Supplier.so .shobj/Notify_Supplier.o .shobj/Notify_Supplier.so: Notify_Supplier.cpp Notify_Supplier.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminS.h \
+  $(ACE_ROOT)/ace/pre.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationC.h \
+  $(TAO_ROOT)/tao/corba.h \
+  $(ACE_ROOT)/ace/post.h \
+  $(ACE_ROOT)/ace/ace_wchar.h \
+  $(ACE_ROOT)/ace/ace_wchar.inl \
+  $(TAO_ROOT)/tao/corbafwd.h \
+  $(ACE_ROOT)/ace/CDR_Base.h \
+  $(ACE_ROOT)/ace/Basic_Types.h \
+  $(ACE_ROOT)/ace/ACE_export.h \
+  $(ACE_ROOT)/ace/Basic_Types.i \
+  $(ACE_ROOT)/ace/Message_Block.h \
+  $(ACE_ROOT)/ace/OS.h \
+  $(ACE_ROOT)/ace/OS_Dirent.h \
+  $(ACE_ROOT)/ace/OS_Export.h \
+  $(ACE_ROOT)/ace/OS_Errno.h \
+  $(ACE_ROOT)/ace/OS_Errno.inl \
+  $(ACE_ROOT)/ace/OS_Dirent.inl \
+  $(ACE_ROOT)/ace/OS_String.h \
+  $(ACE_ROOT)/ace/OS_String.inl \
+  $(ACE_ROOT)/ace/OS_Memory.h \
+  $(ACE_ROOT)/ace/OS_Memory.inl \
+  $(ACE_ROOT)/ace/OS_TLI.h \
+  $(ACE_ROOT)/ace/OS_TLI.inl \
+  $(ACE_ROOT)/ace/Time_Value.h \
+  $(ACE_ROOT)/ace/Time_Value.inl \
+  $(ACE_ROOT)/ace/Default_Constants.h \
+  $(ACE_ROOT)/ace/Global_Macros.h \
+  $(ACE_ROOT)/ace/Min_Max.h \
+  $(ACE_ROOT)/ace/streams.h \
+  $(ACE_ROOT)/ace/Trace.h \
+  $(ACE_ROOT)/ace/OS.i \
+  $(ACE_ROOT)/ace/Message_Block.i \
+  $(ACE_ROOT)/ace/Message_Block_T.h \
+  $(ACE_ROOT)/ace/Message_Block_T.i \
+  $(ACE_ROOT)/ace/Message_Block_T.cpp \
+  $(ACE_ROOT)/ace/CDR_Base.inl \
+  $(ACE_ROOT)/ace/CORBA_macros.h \
+  $(ACE_ROOT)/ace/Exception_Macros.h \
+  $(TAO_ROOT)/tao/orbconf.h \
+  $(TAO_ROOT)/tao/varbase.h \
+  $(TAO_ROOT)/tao/TAO_Export.h \
+  $(TAO_ROOT)/tao/corbafwd.i \
+  $(TAO_ROOT)/tao/Typecode.h \
+  $(ACE_ROOT)/ace/Synch.h \
+  $(ACE_ROOT)/ace/Synch.i \
+  $(ACE_ROOT)/ace/Synch_T.h \
+  $(ACE_ROOT)/ace/Synch_T.i \
+  $(ACE_ROOT)/ace/Thread.h \
+  $(ACE_ROOT)/ace/Thread_Adapter.h \
+  $(ACE_ROOT)/ace/Base_Thread_Adapter.h \
+  $(ACE_ROOT)/ace/OS_Log_Msg_Attributes.h \
+  $(ACE_ROOT)/ace/OS_Log_Msg_Attributes.inl \
+  $(ACE_ROOT)/ace/Base_Thread_Adapter.inl \
+  $(ACE_ROOT)/ace/Thread_Adapter.inl \
+  $(ACE_ROOT)/ace/Thread.i \
+  $(ACE_ROOT)/ace/Synch_T.cpp \
+  $(ACE_ROOT)/ace/Log_Msg.h \
+  $(ACE_ROOT)/ace/Log_Priority.h \
+  $(TAO_ROOT)/tao/Exception.h \
+  $(ACE_ROOT)/ace/SString.h \
+  $(ACE_ROOT)/ace/String_Base.h \
+  $(ACE_ROOT)/ace/ACE.h \
+  $(ACE_ROOT)/ace/Flag_Manip.h \
+  $(ACE_ROOT)/ace/Flag_Manip.i \
+  $(ACE_ROOT)/ace/Handle_Ops.h \
+  $(ACE_ROOT)/ace/Handle_Ops.i \
+  $(ACE_ROOT)/ace/Lib_Find.h \
+  $(ACE_ROOT)/ace/Lib_Find.i \
+  $(ACE_ROOT)/ace/Init_ACE.h \
+  $(ACE_ROOT)/ace/Init_ACE.i \
+  $(ACE_ROOT)/ace/Sock_Connect.h \
+  $(ACE_ROOT)/ace/Sock_Connect.i \
+  $(ACE_ROOT)/ace/ACE.i \
+  $(ACE_ROOT)/ace/String_Base_Const.h \
+  $(ACE_ROOT)/ace/String_Base.i \
+  $(ACE_ROOT)/ace/Malloc_Base.h \
+  $(ACE_ROOT)/ace/String_Base.cpp \
+  $(ACE_ROOT)/ace/Malloc.h \
+  $(ACE_ROOT)/ace/Malloc.i \
+  $(ACE_ROOT)/ace/Malloc_T.h \
+  $(ACE_ROOT)/ace/Malloc_Allocator.h \
+  $(ACE_ROOT)/ace/Malloc_Allocator.i \
+  $(ACE_ROOT)/ace/Free_List.h \
+  $(ACE_ROOT)/ace/Free_List.i \
+  $(ACE_ROOT)/ace/Free_List.cpp \
+  $(ACE_ROOT)/ace/Malloc_T.i \
+  $(ACE_ROOT)/ace/Malloc_T.cpp \
+  $(ACE_ROOT)/ace/Memory_Pool.h \
+  $(ACE_ROOT)/ace/Event_Handler.h \
+  $(ACE_ROOT)/ace/Event_Handler.i \
+  $(ACE_ROOT)/ace/Signal.h \
+  $(ACE_ROOT)/ace/Signal.i \
+  $(ACE_ROOT)/ace/Mem_Map.h \
+  $(ACE_ROOT)/ace/Mem_Map.i \
+  $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \
+  $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \
+  $(ACE_ROOT)/ace/SV_Semaphore_Simple.i \
+  $(ACE_ROOT)/ace/SV_Semaphore_Complex.i \
+  $(ACE_ROOT)/ace/Unbounded_Set.h \
+  $(ACE_ROOT)/ace/Node.h \
+  $(ACE_ROOT)/ace/Node.cpp \
+  $(ACE_ROOT)/ace/Unbounded_Set.inl \
+  $(ACE_ROOT)/ace/Unbounded_Set.cpp \
+  $(ACE_ROOT)/ace/Memory_Pool.i \
+  $(ACE_ROOT)/ace/Auto_Ptr.h \
+  $(ACE_ROOT)/ace/Auto_Ptr.i \
+  $(ACE_ROOT)/ace/Auto_Ptr.cpp \
+  $(ACE_ROOT)/ace/SString.i \
+  $(TAO_ROOT)/tao/Exception.i \
+  $(TAO_ROOT)/tao/Typecode.i \
+  $(TAO_ROOT)/tao/Any.h \
+  $(TAO_ROOT)/tao/CDR.h \
+  $(ACE_ROOT)/ace/CDR_Stream.h \
+  $(ACE_ROOT)/ace/CDR_Stream.i \
+  $(TAO_ROOT)/tao/CDR.i \
+  $(TAO_ROOT)/tao/Environment.h \
+  $(TAO_ROOT)/tao/Environment.i \
+  $(TAO_ROOT)/tao/Object.h \
+  $(TAO_ROOT)/tao/Policy_ForwardC.h \
+  $(TAO_ROOT)/tao/Sequence.h \
+  $(TAO_ROOT)/tao/Managed_Types.h \
+  $(TAO_ROOT)/tao/Managed_Types.i \
+  $(TAO_ROOT)/tao/Sequence.i \
+  $(TAO_ROOT)/tao/Sequence_T.h \
+  $(TAO_ROOT)/tao/Sequence_T.i \
+  $(TAO_ROOT)/tao/Sequence_T.cpp \
+  $(TAO_ROOT)/tao/Policy_ForwardC.i \
+  $(TAO_ROOT)/tao/Object.i \
+  $(TAO_ROOT)/tao/Any.i \
+  $(TAO_ROOT)/tao/NVList.h \
+  $(ACE_ROOT)/ace/Unbounded_Queue.h \
+  $(ACE_ROOT)/ace/Unbounded_Queue.inl \
+  $(ACE_ROOT)/ace/Unbounded_Queue.cpp \
+  $(TAO_ROOT)/tao/NVList.i \
+  $(TAO_ROOT)/tao/LocalObject.h \
+  $(TAO_ROOT)/tao/LocalObject.i \
+  $(TAO_ROOT)/tao/Principal.h \
+  $(TAO_ROOT)/tao/OctetSeqC.h \
+  $(TAO_ROOT)/tao/OctetSeqC.i \
+  $(TAO_ROOT)/tao/Principal.i \
+  $(TAO_ROOT)/tao/ORB.h \
+  $(TAO_ROOT)/tao/Services.h \
+  $(TAO_ROOT)/tao/Services.i \
+  $(TAO_ROOT)/tao/CORBA_String.h \
+  $(TAO_ROOT)/tao/CORBA_String.inl \
+  $(TAO_ROOT)/tao/objectid.h \
+  $(TAO_ROOT)/tao/PolicyC.h \
+  $(TAO_ROOT)/tao/CurrentC.h \
+  $(TAO_ROOT)/tao/CurrentC.i \
+  $(TAO_ROOT)/tao/Remote_Object_Proxy_Impl.h \
+  $(TAO_ROOT)/tao/Object_Proxy_Impl.h \
+  $(TAO_ROOT)/tao/Encodable.h \
+  $(TAO_ROOT)/tao/PolicyC.i \
+  $(TAO_ROOT)/tao/ORB.i \
+  $(TAO_ROOT)/tao/BoundsC.h \
+  $(TAO_ROOT)/tao/BoundsC.i \
+  $(TAO_ROOT)/tao/ValueBase.h \
+  $(TAO_ROOT)/tao/ValueBase.i \
+  $(TAO_ROOT)/tao/ValueFactory.h \
+  $(TAO_ROOT)/tao/ValueFactory.i \
+  $(TAO_ROOT)/tao/AbstractBase.h \
+  $(TAO_ROOT)/tao/AbstractBase.inl \
+  $(TAO_ROOT)/tao/DomainC.h \
+  $(TAO_ROOT)/tao/DomainC.i \
+  $(TAO_ROOT)/tao/WrongTransactionC.h \
+  $(TAO_ROOT)/tao/WrongTransactionC.i \
+  $(TAO_ROOT)/tao/Object_KeyC.h \
+  $(TAO_ROOT)/tao/Object_KeyC.i \
+  $(TAO_ROOT)/tao/ObjectIDList.h \
+  $(TAO_ROOT)/tao/ObjectIDList.i \
+  $(TAO_ROOT)/tao/StringSeqC.h \
+  $(TAO_ROOT)/tao/StringSeqC.i \
+  $(TAO_ROOT)/tao/PortableInterceptorC.h \
+  $(TAO_ROOT)/tao/DynamicC.h \
+  $(TAO_ROOT)/tao/DynamicC.i \
+  $(TAO_ROOT)/tao/ObjectReferenceTemplateC.h \
+  $(TAO_ROOT)/tao/ObjectReferenceTemplateC.i \
+  $(TAO_ROOT)/tao/Messaging_SyncScopeC.h \
+  $(TAO_ROOT)/tao/Messaging_SyncScopeC.i \
+  $(TAO_ROOT)/tao/IOPC.h \
+  $(TAO_ROOT)/tao/IOPC.i \
+  $(TAO_ROOT)/tao/PortableInterceptorC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Notify/notify_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationC.i \
+  $(TAO_ROOT)/tao/PortableServer/PortableServer.h \
+  $(TAO_ROOT)/tao/PortableServer/portableserver_export.h \
+  $(TAO_ROOT)/tao/PortableServer/PortableServerC.h \
+  $(TAO_ROOT)/tao/PortableServer/PortableServerC.i \
+  $(TAO_ROOT)/tao/PortableServer/Servant_Base.h \
+  $(TAO_ROOT)/tao/Abstract_Servant_Base.h \
+  $(ACE_ROOT)/ace/Atomic_Op.h \
+  $(ACE_ROOT)/ace/Atomic_Op_T.h \
+  $(ACE_ROOT)/ace/Atomic_Op_T.i \
+  $(ACE_ROOT)/ace/Atomic_Op_T.cpp \
+  $(ACE_ROOT)/ace/Atomic_Op.i \
+  $(TAO_ROOT)/tao/PortableServer/Servant_Base.i \
+  $(TAO_ROOT)/tao/PortableServer/Collocated_Object.h \
+  $(TAO_ROOT)/tao/PortableServer/Collocated_Object.i \
+  $(TAO_ROOT)/tao/PortableServer/ThruPOA_Object_Proxy_Impl.h \
+  $(TAO_ROOT)/tao/PortableServer/Direct_Object_Proxy_Impl.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotificationS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEvent/event_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventCommS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyCommS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyFilterS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminS.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosEventChannelAdminS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminS_T.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminS_T.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminS_T.cpp \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNotifyChannelAdminS.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsNotifyLogAdminC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Log/notifylog_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsEventLogAdminC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Log/eventlog_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsLogAdminC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Log/log_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/svc_utils_export.h \
+  $(TAO_ROOT)/tao/TimeBaseC.h \
+  $(TAO_ROOT)/tao/SmartProxies/Smart_Proxies.h \
+  $(TAO_ROOT)/tao/SmartProxies/smartproxies_export.h \
+  $(TAO_ROOT)/tao/TAO_Singleton.h \
+  $(TAO_ROOT)/tao/TAO_Singleton.inl \
+  $(TAO_ROOT)/tao/TAO_Singleton.cpp \
+  $(ACE_ROOT)/ace/Object_Manager.h \
+  $(ACE_ROOT)/ace/Object_Manager.i \
+  $(ACE_ROOT)/ace/Managed_Object.h \
+  $(ACE_ROOT)/ace/Managed_Object.i \
+  $(ACE_ROOT)/ace/Managed_Object.cpp \
+  $(TAO_ROOT)/tao/TAO_Singleton_Manager.h \
+  $(TAO_ROOT)/tao/TAO_Singleton_Manager.inl \
+  $(TAO_ROOT)/tao/SmartProxies/Smart_Proxies.inl \
+  $(TAO_ROOT)/tao/TimeBaseC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsLogAdminC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsEventLogAdminC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/DsNotifyLogAdminC.i \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/naming_export.h \
+  $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.i
+
+# IF YOU PUT ANYTHING HERE IT WILL GO AWAY
diff --git a/TAO/orbsvcs/examples/Log/Notify/Notify_Consumer.cpp b/TAO/orbsvcs/examples/Log/Notify/Notify_Consumer.cpp
new file mode 100644
index 00000000000..34b61ae21f3
--- /dev/null
+++ b/TAO/orbsvcs/examples/Log/Notify/Notify_Consumer.cpp
@@ -0,0 +1,176 @@
+/* -*- C++ -*- $Id$ */
+
+#include "Notify_Consumer.h"
+#include "orbsvcs/CosEventChannelAdminS.h"
+#include "orbsvcs/CosNotifyChannelAdminS.h"
+
+#define NAMING_SERVICE_NAME "NameService"
+#define NOTIFY_TLS_LOG_FACTORY_NAME "NotifyLogFactory"
+#define LOG_EVENT_COUNT 29
+#define QUERY_1 "id > 0"
+#define QUERY_2 "id >= 0"
+#define QUERY_LANG "TCL"
+#define SA_FILTER "threshold > 10"
+#define TCL_GRAMMAR "TCL"
+#define EVENTS_TO_SEND 30
+
+int
+main (int argc, char* argv[])
+{
+  Consumer consumer;
+
+  return consumer.run (argc, argv);
+}
+
+// ****************************************************************
+
+Consumer::Consumer (void)
+  : event_count_ (0)
+{
+}
+
+int
+Consumer::run (int argc, char* argv[])
+{
+  ACE_DECLARE_NEW_CORBA_ENV;
+  ACE_TRY
+    {
+      // ORB initialization boiler plate...
+      CORBA::ORB_var orb =
+        CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      // Do *NOT* make a copy because we don't want the ORB to outlive
+      // the Consumer object.
+      this->orb_ = orb.in ();
+
+      CORBA::Object_var object =
+        orb->resolve_initial_references ("RootPOA" ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+      PortableServer::POA_var poa =
+        PortableServer::POA::_narrow (object.in () ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+      PortableServer::POAManager_var poa_manager =
+        poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+      poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      // Obtain the event channel
+      CORBA::Object_var naming_obj =
+        this->orb_->resolve_initial_references (NAMING_SERVICE_NAME
+                                            ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      // Need to check return value for errors.
+      if (CORBA::is_nil (naming_obj.in ()))
+        ACE_THROW (CORBA::UNKNOWN ());
+
+      this->naming_context_ =
+        CosNaming::NamingContext::_narrow (naming_obj.in () ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+
+      CosNaming::Name name (1);
+      name.length (1);
+      name[0].id = CORBA::string_dup (NOTIFY_TLS_LOG_FACTORY_NAME);
+
+      CORBA::Object_var obj =
+        this->naming_context_->resolve (name
+                                       ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      this->notify_log_factory_ =
+        DsNotifyLogAdmin::NotifyLogFactory::_narrow (obj.in ()
+                                              ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      CosNotifyComm::PushConsumer_var objref =
+        this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      ACE_ASSERT (!CORBA::is_nil (objref.in ()));
+
+      CosNotifyChannelAdmin::ProxySupplier_var proxysupplier =
+        this->notify_log_factory_->obtain_notification_push_supplier (CosNotifyChannelAdmin::ANY_EVENT, proxy_supplier_id_ ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      ACE_ASSERT (!CORBA::is_nil (proxysupplier.in ()));
+
+
+      this->proxy_supplier_ =
+        CosNotifyChannelAdmin::ProxyPushSupplier::
+        _narrow (proxysupplier.in () ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      ACE_ASSERT (!CORBA::is_nil (proxy_supplier_.in ()));
+
+      proxy_supplier_->connect_any_push_consumer (objref.in ()
+                                                         ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+     
+      orb_->run ();
+
+      // We don't do any cleanup, it is hard to do it after shutdown,
+      // and would complicate the example; plus it is almost
+      // impossible to do cleanup after ORB->run() because the POA is
+      // in the holding state.  Applications should use
+      // work_pending()/perform_work() to do more interesting stuff.
+      // Check the supplier for the proper way to do cleanup.
+    }
+  ACE_CATCHANY
+    {
+      ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Consumer::run");
+      return 1;
+    }
+  ACE_ENDTRY;
+  return 0;
+}
+
+void
+Consumer::push (const CORBA::Any &event
+    ACE_ENV_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((
+                   CORBA::SystemException,
+                   CosEventComm::Disconnected
+                   ))
+{
+  ACE_UNUSED_ARG (event);
+ 
+  this->event_count_ ++;
+
+      ACE_DEBUG ((LM_DEBUG,
+                  "Consumer (%P|%t): %d log generated events received\n",
+                  this->event_count_));
+}
+
+void
+Consumer::disconnect_push_consumer
+   (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((
+                   CORBA::SystemException
+                   ))
+{
+  this->proxy_supplier_->
+    disconnect_push_supplier(ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+void
+Consumer::offer_change
+   (const CosNotification::EventTypeSeq & /*added*/,
+    const CosNotification::EventTypeSeq & /*removed*/
+    ACE_ENV_ARG_DECL_NOT_USED)
+      ACE_THROW_SPEC ((
+        CORBA::SystemException,
+        CosNotifyComm::InvalidEventType
+      ))
+{
+  // No-Op.
+}
+
+// ****************************************************************
+
+#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
+#elif defined(ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
+#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
diff --git a/TAO/orbsvcs/examples/Log/Notify/Notify_Consumer.h b/TAO/orbsvcs/examples/Log/Notify/Notify_Consumer.h
new file mode 100644
index 00000000000..5fb78306ece
--- /dev/null
+++ b/TAO/orbsvcs/examples/Log/Notify/Notify_Consumer.h
@@ -0,0 +1,101 @@
+/* -*- C++ -*- */
+// $Id$
+//
+// ============================================================================
+//
+// = LIBRARY
+//   ORBSVCS Telecom Log Service examples
+//
+// = FILENAME
+//   Notify_Consumer
+//
+// = AUTHOR
+//   D A Hanvey (d.hanvey@qub.ac.uk)
+//
+// ============================================================================
+
+#ifndef NOTIFY_CONSUMER_H
+#define NOTIFY_CONSUMER_H
+
+#include "orbsvcs/DsNotifyLogAdminS.h"
+#include "orbsvcs/Notify/Notify_EventChannelFactory_i.h"
+#include "orbsvcs/Notify/Notify_EventChannel_i.h"
+#include "orbsvcs/DsEventLogAdminC.h"
+#include "orbsvcs/CosEventCommS.h"
+#include "orbsvcs/CosNotifyCommS.h"
+#include "orbsvcs/CosNamingC.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+class Consumer : public POA_CosNotifyComm::PushConsumer, public PortableServer::RefCountServantBase
+{
+  // = TITLE
+  //   Simple consumer object
+  //
+  // = DESCRIPTION
+  //   This class is a consumer of log generated events.
+  //
+public:
+  Consumer (void);
+  // Constructor
+
+  int run (int argc, char* argv[]);
+  // Run the test
+
+protected:
+
+  CosNotifyChannelAdmin::ProxyID proxy_supplier_id_;
+  // The proxy_supplier id.
+
+  // = Methods
+
+  // Destructor
+
+  // = NotifyPublish method
+    virtual void offer_change (
+        const CosNotification::EventTypeSeq & added,
+        const CosNotification::EventTypeSeq & removed
+        ACE_ENV_ARG_DECL
+      )
+      ACE_THROW_SPEC ((
+        CORBA::SystemException,
+        CosNotifyComm::InvalidEventType
+      ));
+
+  // = StructuredPushSupplier methods
+virtual void push (const CORBA::Any &event
+                     ACE_ENV_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((
+                   CORBA::SystemException,
+                   CosEventComm::Disconnected
+                   ));
+
+
+  virtual void disconnect_push_consumer (
+        ACE_ENV_SINGLE_ARG_DECL
+        )
+      ACE_THROW_SPEC ((
+        CORBA::SystemException
+      ));
+
+private:
+  CORBA::ULong event_count_;
+  // Keep track of the number of events received.
+
+  // = Data Members
+  CORBA::ORB_var orb_;
+  // The ORB that we use.
+
+  CosNaming::NamingContext_var naming_context_;
+  // Handle to the name service.
+
+  DsNotifyLogAdmin::NotifyLogFactory_var notify_log_factory_;
+
+  CosNotifyChannelAdmin::ProxyPushSupplier_var proxy_supplier_;
+
+
+};
+
+#endif /* NOTIFY_CONSUMER_H */
diff --git a/TAO/orbsvcs/examples/Log/Notify/Notify_Supplier.cpp b/TAO/orbsvcs/examples/Log/Notify/Notify_Supplier.cpp
new file mode 100644
index 00000000000..dd1b7d88cee
--- /dev/null
+++ b/TAO/orbsvcs/examples/Log/Notify/Notify_Supplier.cpp
@@ -0,0 +1,364 @@
+/* -*- C++ -*- $Id$ */
+
+#include "Notify_Supplier.h"
+#include "orbsvcs/CosNotifyChannelAdminS.h"
+
+#define NAMING_SERVICE_NAME "NameService"
+#define NOTIFY_TLS_LOG_FACTORY_NAME "NotifyLogFactory"
+#define LOG_EVENT_COUNT 10
+#define QUERY_1 "id > 0"
+#define QUERY_2 "id >= 0"
+#define QUERY_LANG "TCL"
+#define SA_FILTER "threshold > 10"
+#define TCL_GRAMMAR "TCL"
+#define EVENTS_TO_SEND 10
+
+int
+main (int argc, char* argv[])
+{
+  Supplier supplier;
+
+  return supplier.run (argc, argv);
+}
+
+// ****************************************************************
+
+Supplier::Supplier (void)
+{
+}
+
+Supplier::~Supplier ()
+{
+
+}
+
+int
+Supplier::run (int argc, char* argv[])
+{
+  ACE_DECLARE_NEW_CORBA_ENV;
+  ACE_TRY
+    {
+      // ORB initialization boiler plate...
+      this->orb_ =
+        CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+ 
+
+      CORBA::Object_var naming_obj =
+      this->orb_->resolve_initial_references (NAMING_SERVICE_NAME
+                                              ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      // Need to check return value for errors.
+      if (CORBA::is_nil (naming_obj.in ()))
+        ACE_THROW (CORBA::UNKNOWN ());
+
+      this->naming_context_ =
+        CosNaming::NamingContext::_narrow (naming_obj.in () ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+
+      CosNaming::Name name (1);
+      name.length (1);
+      name[0].id = CORBA::string_dup (NOTIFY_TLS_LOG_FACTORY_NAME);
+
+      CORBA::Object_var obj =
+        this->naming_context_->resolve (name
+                                       ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      this->notify_log_factory_ =
+        DsNotifyLogAdmin::NotifyLogFactory::_narrow (obj.in ()
+                                              ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      ACE_ASSERT (!CORBA::is_nil (this->notify_log_factory_.in ()));
+
+      // create a log..
+
+      ACE_DEBUG ((LM_DEBUG,
+                  "\nCalling NotifyLogFactory::create...\n"));
+
+      DsLogAdmin::LogFullActionType logfullaction = DsLogAdmin::halt;
+      DsLogAdmin::CapacityAlarmThresholdList threshold = 0;
+      CORBA::ULongLong max_size = 0; // 0 means "infinite"
+
+      DsLogAdmin::LogId logid = 0;
+      CosNotification::QoSProperties initial_qos;
+      CosNotification::AdminProperties initial_admin;
+ 
+      this->notify_log_ =
+        this->notify_log_factory_->create (logfullaction,
+                                          max_size,
+                                          threshold,
+                                          initial_qos,
+                                          initial_admin,
+                                          logid
+                                          ACE_ENV_ARG_PARAMETER);
+
+      ACE_TRY_CHECK;
+
+      ACE_DEBUG ((LM_DEBUG,
+                  "Create returned logid = %d\n",logid));
+
+      // Create some fake log events.
+      DsLogAdmin::Anys any_seq (LOG_EVENT_COUNT);
+      any_seq.length (LOG_EVENT_COUNT);
+
+      //DsLogAdmin::RecordIdList id_seq (LOG_EVENT_COUNT);
+      //id_seq.length (LOG_EVENT_COUNT);
+
+      for (int i = 0; i < LOG_EVENT_COUNT; i++)
+        {
+          any_seq [i] <<= i;
+        }
+
+      CosNotifyChannelAdmin::AdminID adminID = 0;
+      this->supplier_admin_ = 
+        notify_log_->new_for_suppliers (CosNotifyChannelAdmin::OR_OP, adminID);
+      ACE_ASSERT (!CORBA::is_nil (supplier_admin_.in ()));
+
+      CosNotifyFilter::FilterFactory_var ffact =
+        notify_log_->default_filter_factory (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      // setup a filter at the consumer admin
+      CosNotifyFilter::Filter_var sa_filter =
+        ffact->create_filter (TCL_GRAMMAR ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      ACE_ASSERT (!CORBA::is_nil (sa_filter.in ()));
+
+      CosNotifyFilter::ConstraintExpSeq constraint_list (1);
+      constraint_list.length (1);
+
+      constraint_list[0].event_types.length (0);
+      constraint_list[0].constraint_expr = CORBA::string_dup (SA_FILTER);
+
+      sa_filter->add_constraints (constraint_list ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      supplier_admin_->add_filter (sa_filter.in () ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      // startup the first supplier
+      ACE_NEW_THROW_EX (supplier_1,
+                        Filter_StructuredPushSupplier (ACE_ENV_SINGLE_ARG_PARAMETER),
+                        CORBA::NO_MEMORY ());
+
+      supplier_1->connect (supplier_admin_.in () ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      // operations:
+      CosNotification::StructuredEvent event;
+
+      // EventHeader
+
+      // FixedEventHeader
+      // EventType
+      // string
+      event.header.fixed_header.event_type.domain_name = CORBA::string_dup("*");
+      // string
+      event.header.fixed_header.event_type.type_name = CORBA::string_dup("*");
+      // string
+      event.header.fixed_header.event_name = CORBA::string_dup("myevent");
+
+      // OptionalHeaderFields
+      // PropertySeq
+      // sequence<Property>: string name, any value
+      event.header.variable_header.length (1); // put nothing here
+
+      // FilterableEventBody
+      // PropertySeq
+      // sequence<Property>: string name, any value
+      event.filterable_data.length (3);
+      event.filterable_data[0].name = CORBA::string_dup("threshold");
+
+      event.filterable_data[1].name = CORBA::string_dup("temperature");
+      event.filterable_data[1].value <<= (CORBA::Long)70;
+
+      event.filterable_data[2].name = CORBA::string_dup("pressure");
+      event.filterable_data[2].value <<= (CORBA::Long)80;
+
+      event.filterable_data[0].value <<= (CORBA::Long)4;
+
+      // any
+      event.remainder_of_body <<= (CORBA::Long)4;
+
+      for (int k = 0; k < EVENTS_TO_SEND; k++)
+      {
+        event.filterable_data[0].value <<= (CORBA::Long)k;
+
+        // any
+        event.remainder_of_body <<= (CORBA::Long)k;
+
+        supplier_1->send_event (event ACE_ENV_ARG_PARAMETER);
+        ACE_TRY_CHECK;
+      }
+
+      ACE_DEBUG ((LM_DEBUG,
+                  "Calling NotifyLog get_n_records...\n"));
+
+#ifndef ACE_LACKS_LONGLONG_T
+      CORBA::Long retval = notify_log_->get_n_records (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+#else
+      CORBA::Long retval = notify_log_->get_n_records (ACE_ENV_SINGLE_ARG_PARAMETER).lo();
+      ACE_TRY_CHECK;
+#endif
+
+      ACE_DEBUG ((LM_DEBUG, "Number of records in Log = %d \n", retval));
+
+      ACE_DEBUG ((LM_DEBUG,
+                  "Calling NotifyLog::get_current_size...\n"));
+#ifndef ACE_LACKS_LONGLONG_T
+       retval = notify_log_->get_current_size (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+#else
+       retval = notify_log_->get_current_size (ACE_ENV_SINGLE_ARG_PARAMETER).lo();
+      ACE_TRY_CHECK;
+#endif
+
+      ACE_DEBUG ((LM_DEBUG, "Size of data in Log = %d \n", retval));
+
+      ACE_DEBUG ((LM_DEBUG, "Querying the Log: %s\n", QUERY_1));
+      DsLogAdmin::Iterator_var iter_out;
+      DsLogAdmin::RecordList_var rec_list =
+        notify_log_->query (QUERY_LANG, QUERY_1, iter_out);
+
+      CORBA::ULong j = 0;
+      for (; j < rec_list->length();++j)  
+#ifndef ACE_LACKS_LONGLONG_T
+       ACE_DEBUG ((LM_DEBUG,
+                   "id = %Q, time= %Q\n", 
+                   rec_list[j].id, rec_list[j].time));
+#else
+       ACE_DEBUG ((LM_DEBUG,
+                   "id = %u, time= %u\n",
+                   rec_list[j].id.lo(), rec_list[j].time.lo()));
+#endif
+
+     ACE_DEBUG ((LM_DEBUG,
+                 "Deleting records... \n"));
+
+     retval = notify_log_->delete_records (QUERY_LANG, QUERY_2 ACE_ENV_ARG_PARAMETER);
+     ACE_TRY_CHECK;
+
+     ACE_DEBUG ((LM_DEBUG,
+                 "Calling NotifyLog::get_n_records...\n"));
+#ifndef ACE_LACKS_LONGLONG_T
+     retval = notify_log_->get_n_records (ACE_ENV_SINGLE_ARG_PARAMETER);
+     ACE_TRY_CHECK;
+#else
+     retval = notify_log_->get_n_records (ACE_ENV_SINGLE_ARG_PARAMETER).lo();
+     ACE_TRY_CHECK;
+#endif
+
+     ACE_DEBUG ((LM_DEBUG, "Number of records in Log after delete = %d \n",
+                 retval));
+
+     ACE_DEBUG ((LM_DEBUG, "Geting the current_size again...\n"));
+#ifndef ACE_LACKS_LONGLONG_T
+     retval = notify_log_->get_current_size (ACE_ENV_SINGLE_ARG_PARAMETER);
+     ACE_TRY_CHECK;
+#else
+     retval = notify_log_->get_current_size (ACE_ENV_SINGLE_ARG_PARAMETER).lo();
+     ACE_TRY_CHECK;
+#endif
+
+     ACE_DEBUG ((LM_DEBUG, "Size of data in Log = %d \n", retval));
+
+     this->notify_log_->destroy();
+
+     }
+  ACE_CATCHANY
+    {
+      ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Supplier::run");
+      return 1;
+    }
+  ACE_ENDTRY;
+  return 0;
+}
+
+
+Filter_StructuredPushSupplier::Filter_StructuredPushSupplier  ()
+{
+}
+
+Filter_StructuredPushSupplier::~Filter_StructuredPushSupplier ()
+{
+}
+
+void
+Filter_StructuredPushSupplier::connect (CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin ACE_ENV_ARG_DECL)
+{
+  CosNotifyComm::StructuredPushSupplier_var objref =
+    this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  CosNotifyChannelAdmin::ProxyConsumer_var proxyconsumer =
+    supplier_admin->obtain_notification_push_consumer (CosNotifyChannelAdmin::STRUCTURED_EVENT, proxy_consumer_id_ ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  ACE_ASSERT (!CORBA::is_nil (proxyconsumer.in ()));
+
+  // narrow
+  this->proxy_consumer_ =
+    CosNotifyChannelAdmin::StructuredProxyPushConsumer::_narrow (proxyconsumer.in () ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  ACE_ASSERT (!CORBA::is_nil (proxy_consumer_.in ()));
+
+  proxy_consumer_->connect_structured_push_supplier (objref.in ()
+                                                     ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+void
+Filter_StructuredPushSupplier::disconnect (ACE_ENV_SINGLE_ARG_DECL)
+{
+  ACE_ASSERT (!CORBA::is_nil (this->proxy_consumer_.in ()));
+
+  this->proxy_consumer_->disconnect_structured_push_consumer(ACE_ENV_SINGLE_ARG_PARAMETER);
+}
+
+void
+Filter_StructuredPushSupplier::subscription_change
+   (const CosNotification::EventTypeSeq & /*added*/,
+    const CosNotification::EventTypeSeq & /*removed */
+    ACE_ENV_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((
+                   CORBA::SystemException,
+                   CosNotifyComm::InvalidEventType
+                   ))
+{
+  //No-Op.
+}
+
+void
+Filter_StructuredPushSupplier::send_event
+   (const CosNotification::StructuredEvent& event ACE_ENV_ARG_DECL)
+{
+  ACE_ASSERT (!CORBA::is_nil (this->proxy_consumer_.in ()));
+
+  proxy_consumer_->push_structured_event (event ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+void
+Filter_StructuredPushSupplier::disconnect_structured_push_supplier
+   (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((
+                   CORBA::SystemException
+                   ))
+{
+  // No-Op.
+}
+
+
+// ****************************************************************
+
+#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
+#elif defined(ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
+#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
diff --git a/TAO/orbsvcs/examples/Log/Notify/Notify_Supplier.h b/TAO/orbsvcs/examples/Log/Notify/Notify_Supplier.h
new file mode 100644
index 00000000000..7a46281c5d1
--- /dev/null
+++ b/TAO/orbsvcs/examples/Log/Notify/Notify_Supplier.h
@@ -0,0 +1,127 @@
+/* -*- C++ -*- */
+// $Id$
+//
+// ============================================================================
+//
+// = LIBRARY
+//   ORBSVCS Telecom Log Service examples 
+//
+// = FILENAME
+//   Notify_Supplier
+//
+// = AUTHOR
+//   D A Hanvey (d.hanvey@qub.ac.uk)
+//
+// ============================================================================
+
+#ifndef NOTIFY_SUPPLIER_H
+#define NOTIFY_SUPPLIER_H
+
+#include "orbsvcs/CosNotifyChannelAdminS.h"
+#include "orbsvcs/DsNotifyLogAdminC.h"
+#include "orbsvcs/CosNamingC.h"
+#include "orbsvcs/CosNotifyCommS.h"
+
+
+class Filter_StructuredPushSupplier;
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+class Supplier 
+{
+  // = TITLE
+  //   Simple supplier object
+  //
+  // = DESCRIPTION
+  //   This class is a supplier of events.
+  //
+public:
+  Supplier (void);
+  // Constructor
+
+  ~Supplier ();
+  // Destructor.
+
+  int run (int argc, char* argv[]);
+  // Run the test
+
+private:
+
+  // = Data Members
+  CORBA::ORB_var orb_;
+  // The ORB that we use.
+
+  CosNaming::NamingContext_var naming_context_;
+  // Handle to the name service.
+
+  DsNotifyLogAdmin::NotifyLogFactory_var notify_log_factory_;
+  // The notify log factory from the Log Service.
+
+  DsNotifyLogAdmin::NotifyLog_var notify_log_;
+
+  Filter_StructuredPushSupplier* supplier_1;
+
+  CosNotifyChannelAdmin::SupplierAdmin_var supplier_admin_;
+};
+
+class Filter_StructuredPushSupplier : public POA_CosNotifyComm::StructuredPushSupplier, public PortableServer::RefCountServantBase
+{
+  // = TITLE
+  //   Filter_StructuredPushSupplier
+  //
+  // = DESCRIPTION
+  //   Supplier for the filter example.
+  //
+ public:
+  // = Initialization and Termination code
+  Filter_StructuredPushSupplier (ACE_ENV_SINGLE_ARG_DECL);
+  // Constructor.
+
+  void connect (CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin
+                ACE_ENV_ARG_DECL);
+  // Connect the Supplier to the EventChannel.
+  // Creates a new proxy supplier and connects to it.
+
+  void disconnect (ACE_ENV_SINGLE_ARG_DECL);
+  // Disconnect from the supplier.
+
+  virtual void send_event (const CosNotification::StructuredEvent& event
+                           ACE_ENV_ARG_DECL);
+  // Send one event.
+
+protected:
+  // = Data members
+  CosNotifyChannelAdmin::StructuredProxyPushConsumer_var proxy_consumer_;
+  // The proxy that we are connected to.
+
+  CosNotifyChannelAdmin::ProxyID proxy_consumer_id_;
+  // This supplier's id.
+
+  // = Protected Methods
+  virtual ~Filter_StructuredPushSupplier ();
+  // Destructor
+
+  // = NotifySubscribe
+  virtual void subscription_change (
+        const CosNotification::EventTypeSeq & added,
+        const CosNotification::EventTypeSeq & removed
+        ACE_ENV_ARG_DECL
+      )
+      ACE_THROW_SPEC ((
+        CORBA::SystemException,
+        CosNotifyComm::InvalidEventType
+      ));
+
+  // = StructuredPushSupplier method
+    virtual void disconnect_structured_push_supplier (
+        ACE_ENV_SINGLE_ARG_DECL
+      )
+      ACE_THROW_SPEC ((
+        CORBA::SystemException
+      ));
+};
+
+
+#endif /* NOTIFY_SUPPLIER_H */