2 <BODY text=
"#000000" bgcolor=
"#FFFFFF">
5 <title>TAO's Notification Service
</title>
7 <H1><center>TAO's Notification Service
</center> </H1><p>
12 <a href=
"#notify_service">Options to Notify_Service
</a>
16 <a href=
"#feature_matrix">Feature Matrix
</a>
21 <a href=
"#test_framework">Notification Service Testing framework
</a>
26 <H2><center><a NAME=
"notify_service"></a>Options to Notify_Service
</center> </H2><p>
29 The
<a href=
"../../orbsvcs/Notify_Service"> Notify_Service
</a> driver program options are:
<br>
32 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
35 <TH WIDTH=
40%
>Command
</TH>
40 <TD> -Factory factory_name
44 Uses the
<factory_name> as the default name for the Channel Factory.
45 The default is
"NotifyEventChannelFactory".
53 Flag asking that the factory_name be registered
55 The option is disabled by default.
56 See the
"Using the Boot option" section in the
<a href=
"../../orbsvcs/Notify_Service/README"> README
</a> for details.
65 Registers the Factory and if specified, an Event
66 Channel with the Naming Service.
67 if this option is used, a Naming Service must
69 This option is enabled by default.
76 <TD>Asks to skip any registration with the
78 This option is disabled by default.
84 <TD>-IORoutput file_name
</TD>
86 <TD>The IOR is output to the file file_name.
87 By default, the IOR is printed out.
95 <TD>If this option is specified, a EventChannel is
96 created and registered with the Naming Service.
97 This option is disabled by default.
102 <TD>-ChannelName channel_name
</TD>
104 Specifes the channel_name to register with the
106 The default is
"NotifyEventChannel".
111 <TD>-ORBRunThreads threads
</TD>
112 <TD> Specifies the number of threads that will run the ORB::run method.
118 The Notify_Service driver can be used to load the CosNotification service or it's Real-Time CORBA extension, the RT-Notification.
<br>
119 By using the svc.conf file, the appropriate service is loaded.
120 <p>To load the CosNotification do:
<br>
123 dynamic TAO_Notify_Service Service_Object * TAO_CosNotification:_make_TAO_CosNotify_Service ()
""
126 <tt> static TAO_CosNotify_Service
"" </tt>
129 To load the RT-Notification Service, do:
<br>
130 <tt> dynamic TAO_Notify_Service Service_Object * TAO_RT_Notification:_make_TAO_RT_Notify_Service ()
""
134 If your application links to the RT-Notification library, you can configure the RT-Notification statically via:
<br>
135 <tt> static TAO_RT_Notify_Service
"" </tt>
137 <p> The service objects also accept the following options to control concurrency in the Notification.
<br>
138 Note that the
<a href=
"#rt_ext">Notification extensions
</a> allow threads to be specified at the EventChannel, Admin and Proxy levels via QoS parameters at run-time.
141 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
144 <TH WIDTH=
40%
>Option
</TH>
145 <TH >Description
</TH>
149 <TD> -DispatchingThreads [thread_count]
153 Specifies the number of threads for dispatching.
158 <TD> -SourceThreads [thread_count]
162 Specifies the number of threads for ProxyConsumer filter evaluation.
167 <TD> -ListenerThreads [thread_count]
171 Specifies the number of threads for ProxySupplier filter evaluation.
180 Send subscription and publication updates asynchronously.
189 Do not send any subscription and publication updates.
194 <TD> -AllocateTaskperProxy
198 Allocate threads for the -LookupThreads and -ListenerThreads
<b> per proxy
</b> <br>
199 See the README for further explaination.
<br>
208 <H2><center><a NAME=
"feature_matrix"></a>Feature matrix for the Cos Notification Service
</center> </H2><p>
210 <H4>Supported Interfaces
</H4>
212 <a href=
"#qos_admin">CosNotification::QoSAdmin
</a><br>
213 <a href=
"#admin_prop_admin">CosNotification::AdminPropertiesAdmin
</a><br>
214 <a href=
"#notify_publish">CosNotifyComm::NotifyPublish
</a><br>
215 <a href=
"#notify_subscribe">CosNotifyComm::NotifySubscribe
</a><br>
216 <a href=
"#push_consumer">CosNotifyComm::PushConsumer
</a><br>
217 <a href=
"#push_supplier">CosNotifyComm::PushSupplier
</a><br>
218 <a href=
"#structured_push_consumer">CosNotifyComm::StructuredPushConsumer
</a><br>
219 <a href=
"#structured_push_supplier">CosNotifyComm::StructuredPushSupplier
</a><br>
220 <a href=
"#sequence_push_consumer">CosNotifyComm::SequencePushConsumer
</a><br>
221 <a href=
"#sequence_push_supplier">CosNotifyComm::SequencePushSupplier
</a><br>
222 <a href=
"#filter">CosNotifyFilter::Filter
</a><br>
223 <a href=
"#filter">CosNotifyFilter::MappingFilter
</a><br>
224 <a href=
"#filter_factory">CosNotifyFilter::FilterFactory
</a><br>
225 <a href=
"#filter_admin">CosNotifyFilter::FilterAdmin
</a><br>
226 <a href=
"#proxy_consumer">CosNotifyChannelAdmin::ProxyConsumer
</a><br>
227 <a href=
"#proxy_supplier">CosNotifyChannelAdmin::ProxySupplier
</a><br>
229 <a href=
"#proxy_push_consumer">CosNotifyChannelAdmin::ProxyPushConsumer
</a><br>
230 <a href=
"#structured_proxy_push_consumer">CosNotifyChannelAdmin::StructuredProxyPushConsumer
</a><br>
231 <a href=
"#sequence_proxy_push_consumer">CosNotifyChannelAdmin::SequenceProxyPushConsumer
</a><br>
233 <a href=
"#proxy_push_supplier">CosNotifyChannelAdmin::ProxyPushSupplier
</a><br>
234 <a href=
"#structured_proxy_push_supplier">CosNotifyChannelAdmin::StructuredProxyPushSupplier
</a><br>
235 <a href=
"#sequence_proxy_push_supplier">CosNotifyChannelAdmin::SequenceProxyPushSupplier
</a><br>
237 <a href=
"#consumer_admin">CosNotifyChannelAdmin::ConumerAdmin
</a><br>
238 <a href=
"#supplier_admin">CosNotifyChannelAdmin::SupplierAdmin
</a><br>
239 <a href=
"#event_channel">CosNotifyChannelAdmin::EventChannel
</a><br>
240 <a href=
"#event_channel_factory">CosNotifyChannelAdmin::EventChannelFactory
</a><br>
242 <H4>UnSupported Interfaces
</H4>
244 <a href=
"#pull_consumer">CosNotifyComm::PullConsumer
</a><br>
245 <a href=
"#pull_supplier">CosNotifyComm::PullSupplier
</a><br>
246 <a href=
"#structured_pull_consumer">CosNotifyComm::StructuredPullConsumer
</a><br>
247 <a href=
"#structured_pull_supplier">CosNotifyComm::StructuredPullSupplier
</a><br>
249 <a href=
"#sequence_pull_consumer">CosNotifyComm::SequencePullConsumer
</a><br>
250 <a href=
"#sequence_pull_supplier">CosNotifyComm::SequencePullSupplier
</a><br>
252 <a href=
"#proxy_pull_supplier">CosNotifyChannelAdmin::ProxyPullSupplier
</a><br>
253 <a href=
"#structured_proxy_pull_supplier">CosNotifyChannelAdmin::StructuredProxyPullSupplier
</a><br>
254 <a href=
"#sequence_proxy_pull_supplier">CosNotifyChannelAdmin::SequenceProxyPullSupplier
</a><br>
255 <a href=
"#proxy_pull_consumer">CosNotifyChannelAdmin::ProxyPullConsumer
</a><br>
256 <a href=
"#structured_proxy_pull_consumer">CosNotifyChannelAdmin::StructuredProxyPullConsumer
</a><br>
257 <a href=
"#sequence_proxy_pull_consumer">CosNotifyChannelAdmin::SequenceProxyPullConsumer
</a><br>
259 <a NAME=
"rt_ext"><H4>Interfaces Extensions for RTCORBA support
</H4> </a>
260 <a href=
"#ext_ecf">NotifyExt::EventChannelFactory
</a><br>
261 <a href=
"#ext_ca">NotifyExt::ConsumerAdmin
</a><br>
262 <a href=
"#ext_sa">NotifyExt::SupplierAdmin
</a><br>
264 <a NAME=
"qos_admin"></a><HR>
265 <B>Interface
</B> :
<CODE>CosNotification::QoSAdmin
</CODE><br>
266 <B>Base Interface(s)
</B> : none
<br>
268 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
277 <TD><CODE>get_qos
</CODE></TD>
284 <TD><CODE>set_qos
</CODE></TD>
286 <TD>Yes, see
<a href=
"../../orbsvcs/tests/Notify/Ordering"> Ordering
</a>
287 <a href=
"../../orbsvcs/tests/Notify/Discarding"> Discarding
</a>
294 <TD><CODE>validate_qos
</CODE></TD>
302 QoS Properties support on all interfaces supporting CosNotification::QoSAdmin
304 <li> EventReliability : Not supported
</li>
305 <li> ConnectionReliability : Not supported
</li>
306 <li> Priority : Supported Per Message, Priority applied to Channel,
307 Admin or proxy Objects are NOT applied to the events.
309 <li> StartTime : Not supported
</li>
310 <li> StopTime : Not Supported
</li>
312 <li> Timeout : Supported Per Message, Timeouts applied to Channel,
313 Admin or proxy Objects are NOT applied to the events.
315 <li> StartTimeSupported : Not Supported
</li>
316 <li> StopTimeSupported : Not Supported
</li>
318 <li> MaxEventsPerConsumer : Supported (Only applies to ProxySuppliers)
321 <li> OrderPolicy : Supported policies - PriorityOrder, AnyOrder, FifoOrder,
322 LifoOrder, DeadlineOrder
</li>
324 <li> DiscardPolicy : : Supported policies - PriorityOrder, AnyOrder, FifoOrder,
325 LifoOrder, DeadlineOrder
</li>
327 <li>MaximumBatchSize : Supported and applied to SequenceProxySuppliers
330 <li>PacingInterval : Supported and applied to SequenceProxySuppliers
334 <a NAME=
"admin_prop_admin"></a><HR>
335 <B>Interface
</B> :
<CODE>CosNotification::AdminPropertiesAdmin
</CODE><br>
336 <B>Base Interface(s)
</B> : none
<br>
339 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
348 <TD><CODE>get_admin
</CODE></TD>
355 <TD><CODE>set_admin
</CODE></TD>
357 <TD>Yes, see
<a href=
"../../orbsvcs/tests/Notify/Basic/"> Events
364 <a NAME=
"notify_publish"></a><HR>
365 <B>Interface
</B> :
<CODE>CosNotifyComm::NotifyPublish
</CODE><br>
366 <B>Base Interface(s)
</B> : none
<br>
368 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
377 <TD><CODE>offer_change
</CODE></TD>
380 href=
"../../orbsvcs/tests/Notify/Basic/"> Updates
</a></TD>
386 <a NAME=
"notify_subscribe"></a><HR><B>Interface
</B> :
<CODE>CosNotifyComm::NotifySubscribe
</CODE><br>
387 <B>Base Interface(s)
</B> : none
<br>
390 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
399 <TD><CODE>subscription_change
</CODE></TD>
402 href=
"../../orbsvcs/tests/Notify/Basic/"> Updates
</a></TD>
408 <a NAME=
"push_consumer"></a><HR><P>
409 <B>Interface
</B> :
<CODE>CosNotifyComm::PushConsumer
</CODE><br>
410 <B>Base Interface(s)
</B> :
<CODE><a href=
"#notify_publish">CosNotifyComm::NotifyPublish
</a></CODE>, CosEventComm::PushConsumer
<br>
412 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
421 <TD><CODE> CosEventComm::PushConsumer::push
</CODE></TD>
424 href=
"../../orbsvcs/tests/Notify/Basic/"> MultiTypes,Simple
</a></TD>
429 <TD><CODE> CosEventComm::PushConsumer::disconnect_push_consumer
</CODE></TD>
432 href=
"../../orbsvcs/tests/Notify/Basic/">ConnectDisconnect
</a></TD>
438 <a NAME=
"pull_consumer"></a><HR><P>
439 <B>Interface
</B> :
<CODE>CosNotifyComm::PullConsumer
</CODE><br>
440 <B> Not Supported
</B>.
443 <a NAME=
"push_supplier"></a><HR><P>
444 <B>Interface
</B> :
<CODE>CosNotifyComm::PushSupplier
</CODE><br>
445 <B>Base Interface(s)
</B> :
<CODE><a href=
"#notify_subscribe"> CosNotifyComm::NotifySubscribe
</a>, CosEventComm::PushSupplier
</CODE> <br>
446 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
455 <TD><CODE> CosEventComm::PushConsumer::disconnect_push_supplier
</CODE></TD>
458 href=
"../../orbsvcs/tests/Notify/Basic"> ConnectDisconnect
</a></TD>
465 <a NAME=
"pull_supplier"></a><HR><P>
466 <B>Interface
</B> :
<CODE>CosNotifyComm::PullSupplier
</CODE><br>
467 <B> Not Supported
</B>.
471 <a NAME=
"structured_push_consumer"></a><HR>
472 <B>Interface
</B> :
<CODE>CosNotifyComm::StructuredPushConsumer
</CODE><br>
473 <B>Base Interface(s)
</B><a href=
"#notify_publish"> CosNotifyComm::NotifyPublish
</a> <br>
475 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
484 <TD><CODE>push_structured_event
</CODE></TD>
487 href=
"../../orbsvcs/tests/Notify/Basic">MultiTypes
</a></TD>
492 <TD><CODE>disconnect_structured_push_consumer
</CODE></TD>
495 href=
"../../orbsvcs/tests/Notify/Basic">ConnectDisconnect
</a></TD>
501 <a NAME=
"structured_pull_consumer"></a>
503 <B>Interface
</B> :
<CODE>CosNotifyComm::StructuredPullConsumer
</CODE><br>
504 <B> Not Supported
</B>.
507 <a NAME=
"structured_pull_supplier"></a>
508 <HR><P><B>Interface
</B> :
<CODE>CosNotifyComm::StructuredPullSupplier
</CODE><br>
509 <B> Not Supported
</B>.
512 <a NAME=
"structured_push_supplier"></a>
513 <HR><B>Interface
</B> :
<CODE>CosNotifyComm::StructuredPushSupplier
</CODE><br>
514 <B>Base Interface(s)
</B> <a href=
"#notify_subscribe">
515 CosNotifyComm::NotifySubscribe
</a> <br>
517 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
526 <TD><CODE>disconnect_structured_push_supplier
</CODE></TD>
529 href=
"../../orbsvcs/tests/Notify/Basic/">ConnectDisconnect
</a></TD>
535 <a NAME=
"sequence_push_consumer"></a><HR>
536 <B>Interface
</B> :
<CODE>CosNotifyComm::SequencePushConsumer
</CODE><br>
537 <B>Base Interface(s)
</B><a href=
"#notify_publish"> <CODE>CosNotifyComm::NotifyPublish
</CODE> </a><br>
539 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
548 <TD><CODE>push_structured_events
</CODE></TD>
551 href=
"../../orbsvcs/tests/Notify/Basic/">MultiTypes
</a></TD>
556 <TD><CODE>disconnect_sequence_push_consumer
</CODE></TD>
559 href=
"../../orbsvcs/tests/Notify/Basic/">ConnectDisconnect
</a></TD>
565 <a NAME=
"sequence_pull_consumer"></a><HR><P>
566 <B>Interface
</B> :
<CODE>CosNotifyComm::SequencePullConsumer
</CODE><br>
567 <B> Not Supported
</B>.
570 <a NAME=
"sequence_pull_supplier"></a><HR><P>
571 <B>Interface
</B> :
<CODE>CosNotifyComm::SequencePullSupplier
</CODE><br>
572 <B> Not Supported
</B>.
575 <a NAME=
"sequence_push_supplier"></a><HR>
576 <B>Interface
</B> :
<CODE>CosNotifyComm::SequencePushSupplier
</CODE><br>
577 <B>Base Interface(s)
</B> <a href=
"#notify_subscribe">
578 CosNotifyComm::NotifySubscribe
</a> <br>
580 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
589 <TD><CODE>disconnect_sequence_push_supplier
</CODE></TD>
592 href=
"../../orbsvcs/tests/Notify/Basic/">ConnectDisconnect
</a></TD>
598 <a NAME=
"filter"></a><HR><B>Interface
</B> :
<CODE>CosNotifyFilter::Filter
</CODE><br>
599 <B>Base Interface(s)
</B> none
<br>
602 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
611 <TD><CODE>constraint_grammar
</CODE></TD>
618 <TD><CODE>add_constraints
</CODE></TD>
621 href=
"../../orbsvcs/tests/Notify/Basic/">Filter
</a></TD>
626 <TD><CODE>modify_constraints
</CODE></TD>
633 <TD><CODE>get_constraints
</CODE></TD>
640 <TD><CODE>get_all_constraints
</CODE></TD>
647 <TD><CODE>remove_all_constraints
</CODE></TD>
654 <TD><CODE>destroy
</CODE></TD>
661 <TD><CODE>match
</CODE></TD>
668 <TD><CODE>match_structured
</CODE></TD>
670 <TD>yes, called internally by Notification during
672 href=
"../../orbsvcs/tests/Notify/Structured_Filter/">Structured_Filter
</TD>
677 <TD><CODE>match_typed
</CODE></TD>
684 <TD><CODE>attach_callback
</CODE></TD>
691 <TD><CODE>detach_callback
</CODE></TD>
698 <TD><CODE>get_callbacks
</CODE></TD>
707 <a NAME=
"mapping_filter"></a><B>Interface
</B> :
<CODE>CosNotifyFilter::MappingFilter
</CODE><br>
708 <B> Not Supported
</B>.
711 <a NAME=
"filter_factory"></a><HR><B>Interface
</B> :
<CODE>CosNotifyFilter::FilterFactory
</CODE><br>
712 <B>Base Interface(s)
</B> none
<br>
715 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
724 <TD><CODE>create_filter
</CODE></TD>
727 href=
"../../orbsvcs/tests/Notify/Basic/">Filter
</a></TD>
732 <TD><CODE>create_mapping_filter
</CODE></TD>
741 <a NAME=
"filter_admin"></a><HR><B>Interface
</B> :
<CODE>CosNotifyFilter::FilterAdmin
</CODE><br>
742 <B>Base Interface(s)
</B>
745 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
754 <TD><CODE>add_filter
</CODE></TD>
757 href=
"../../orbsvcs/tests/Notify/Basic/">Filter
</a></TD>
762 <TD><CODE>remove_filter
</CODE></TD>
765 href=
"../../orbsvcs/tests/Notify/Basic/">Filter
</a></TD>
770 <TD><CODE>get_filter
</CODE></TD>
777 <TD><CODE>get_all_filters
</CODE></TD>
780 href=
"../../orbsvcs/tests/Notify/Basic/">Filter
</a></TD>
785 <TD><CODE>remove_all_filters
</CODE></TD>
788 href=
"../../orbsvcs/tests/Notify/Basic/">Filter
</a></TD>
794 <a NAME=
"proxy_consumer"></a><HR>
795 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::ProxyConsumer
</CODE><br>
796 <B>Base Interface(s)
</B> <CODE> <a href=
"#qos_admin">CosNotification::QoSAdmin
</a><CODE>,
797 <CODE><a href=
"#filter_admin"> CosNotifyFilter::FilterAdmin
</a></CODE> <br>
800 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
809 <TD><CODE>MyType
</CODE></TD>
816 <TD><CODE>MyAdmin
</CODE></TD>
823 <TD><CODE>obtain_subscription_types
</CODE></TD>
826 href=
"../../orbsvcs/tests/Notify/Basic"> Updates
</a></TD>
827 <TD>Only CosNotifyChannelAdmin::ALL_NOW_UPDATES_ON tested
</TD>
831 <TD><CODE>validate_event_qos
</CODE></TD>
839 <a NAME=
"proxy_supplier"></a><HR>
840 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::ProxySupplier
</CODE><br>
841 <B>Base Interface(s)
</B> <CODE><a href=
"#qos_admin"> CosNotification::QoSAdmin
</a><CODE>,
842 <CODE> <a href=
"#filter_admin"> CosNotifyFilter::FilterAdmin
</a> </CODE> <br>
844 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
853 <TD><CODE>MyType
</CODE></TD>
860 <TD><CODE>MyAdmin
</CODE></TD>
867 <TD><CODE>priority_filter
</CODE></TD>
875 <TD><CODE>lifetime_filter
</CODE></TD>
882 <TD><CODE>obtain_offered_types
</CODE></TD>
885 href=
"../../orbsvcs/tests/Notify/Basic/">Updates
</a></TD>
886 <TD>Only CosNotifyChannelAdmin::ALL_NOW_UPDATES_ON tested
</TD>
890 <TD><CODE>validate_event_qos
</CODE></TD>
898 <a NAME=
"proxy_push_consumer"></a><HR>
899 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::ProxyPushConsumer
</CODE><br>
900 <B>Base Interface(s)
</B> <CODE> <a
901 href=
"#proxy_consumer">CosNotification::ProxyConsumer
</a>,
902 <a href=
"#push_consumer"> CosNotifyComm::PushConsumer
<CODE> </a><br>
904 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
913 <TD><CODE>connect_any_push_supplier
</CODE></TD>
916 href=
"../../orbsvcs/tests/Notify/Basic/">MultiTypes,ConnectDisconnect
</a></TD>
922 <a NAME=
"structured_proxy_push_consumer"></a><HR>
923 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::StructuredProxyPushConsumer
</CODE><br>
924 <B>Base Interface(s)
</B> <CODE> <a href=
"#proxy_consumer">
925 CosNotification::ProxyConsumer
</a>,
926 <a href=
"#structured_push_consumer">
927 CosNotifyComm::StructuredPushConsumer
</a> <CODE> <br>
929 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
938 <TD><CODE>connect_structured_push_supplier
</CODE></TD>
941 href=
"../../orbsvcs/tests/Notify/Basic/">MultiTypes,ConnectDisconnect
</a></TD>
947 <a NAME=
"sequence_proxy_push_consumer"></a><HR>
948 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::SequenceProxyPushConsumer
</CODE><br>
949 <B>Base Interface(s)
</B> <CODE> <a href=
"#proxy_consumer">
950 CosNotification::ProxyConsumer
</a>,
951 <a href=
"#sequence_push_consumer"> CosNotifyComm::SequencePushConsumer
954 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
963 <TD><CODE>connect_sequence_push_supplier
</CODE></TD>
966 href=
"../../orbsvcs/tests/Notify/Basic/">MultiTypes,ConnectDisconnect
</a></TD>
972 <a NAME=
"proxy_pull_supplier"></a><HR><P>
973 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::ProxyPullSupplier
</CODE><br>
974 <B> Not Supported
</B>.
977 <a NAME=
"structured_proxy_pull_supplier"></a><HR><P>
978 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::StructuredProxyPullSupplier
</CODE><br>
979 <B> Not Supported
</B>.
982 <a NAME=
"sequence_proxy_pull_supplier"></a><HR><P>
983 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::SequenceProxyPullSupplier
</CODE><br>
984 <B> Not Supported
</B>.
987 <a NAME=
"proxy_pull_consumer"></a><HR><P>
988 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::ProxyPullConsumer
</CODE><br>
989 <B> Not Supported
</B>.
992 <a NAME=
"structured_proxy_pull_consumer"></a><HR><P>
993 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::StructuredProxyPullConsumer
</CODE><br>
994 <B> Not Supported
</B>.
997 <a NAME=
"sequence_proxy_pull_consumer"></a><HR><P>
998 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::SequenceProxyPullConsumer
</CODE><br>
999 <B> Not Supported
</B>.
1002 <a NAME=
"proxy_push_supplier"></a><HR>
1003 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::ProxyPushSupplier
</CODE><br>
1004 <B>Base Interface(s)
</B> <CODE> CosNotification::ProxySupplier,
1005 CosNotifyComm::PushSupplier
<CODE> <br>
1007 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
1016 <TD><CODE>connect_any_push_consumer
</CODE></TD>
1019 href=
"../../orbsvcs/tests/Notify/Basic/">MultiTypes,ConnectDisconnect
</a></TD>
1024 <TD><CODE>suspend_connection
</CODE></TD>
1031 <TD><CODE>resume_connection
</CODE></TD>
1039 <a NAME=
"structured_proxy_push_supplier"></a><HR>
1040 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::StructuredProxyPushSupplier
</CODE><br>
1041 <B>Base Interface(s)
</B> <CODE> CosNotification::ProxySupplier,
1042 CosNotifyComm::StructuredPushSupplier
<CODE> <br>
1044 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
1053 <TD><CODE>connect_structured_push_consumer
</CODE></TD>
1056 href=
"../../orbsvcs/tests/Notify/Basic/"> MultiTypes,ConnectDisconnect
1062 <TD><CODE>suspend_connection
</CODE></TD>
1069 <TD><CODE>resume_connection
</CODE></TD>
1077 <a NAME=
"sequence_proxy_push_supplier"></a><HR>
1078 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::SequenceProxyPushSupplier
</CODE><br>
1079 <B>Base Interface(s)
</B> <CODE> <a href=
"#proxy_supplier">
1080 CosNotification::ProxySupplier
</a>,
1081 <a href=
"#sequence_push_supplier"> CosNotifyComm::SequencePushSupplier
1084 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
1093 <TD><CODE>connect_sequence_push_consumer
</CODE></TD>
1096 href=
"../../orbsvcs/tests/Notify/Basic/">MultiTypes,ConnectDisconnect
</a></TD>
1101 <TD><CODE>suspend_connection
</CODE></TD>
1108 <TD><CODE>resume_connection
</CODE></TD>
1116 <a NAME=
"consumer_admin"></a><HR>
1117 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::ConsumerAdmin
</CODE><br>
1118 <B>Base Interface(s)
</B> <CODE> <a href=
"#qos_admin">
1119 CosNotification::QoSAdmin
</a>
1120 ,
<a href=
"#notify_subscribe"> CosNotifyComm::NotifySubscribe
</a>
1121 ,
<a href=
"#filter_admin"> CosNotifyFilter::FilterAdmin
</a>
1122 , CosEventChannelAdmin::ConsumerAdmin
</CODE> <br>
1124 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
1133 <TD><CODE>CosEventChannelAdmin::ConsumerAdmin::obtain_push_supplier
</CODE></TD>
1141 <TD><CODE>CosEventChannelAdmin::ConsumerAdmin::obtain_pull_supplier
</CODE></TD>
1148 <TD><CODE>MyID
</CODE></TD>
1155 <TD><CODE>MyChannel
</CODE></TD>
1162 <TD><CODE>MyOperator
</CODE></TD>
1169 <TD><CODE>priority_filter
</CODE></TD>
1176 <TD><CODE>lifetime_filter
</CODE></TD>
1183 <TD><CODE>pull_suppliers
</CODE></TD>
1190 <TD><CODE>push_suppliers
</CODE></TD>
1197 <TD><CODE>get_proxy_supplier
</CODE></TD>
1200 href=
"../../orbsvcs/tests/Notify/Basic/">Updates
</a></TD>
1205 <TD><CODE>obtain_notification_pull_supplier
</CODE></TD>
1212 <TD><CODE>obtain_notification_push_supplier
</CODE></TD>
1216 href=
"../../orbsvcs/tests/Notify/Basic/">MultiTypes, ConnectDisconnect
1222 <TD><CODE>destroy
</CODE></TD>
1225 href=
"../../orbsvcs/tests/Notify/Basic/">LifeCycle, IdAssignment
</a></TD>
1231 <a NAME=
"supplier_admin"></a><HR>
1232 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::SupplierAdmin
</CODE><br>
1233 <B>Base Interface(s)
</B> <CODE> <a href=
"#qos_admin">
1234 CosNotification::QoSAdmin
</a>
1235 ,
<a href=
"#notify_publish"> CosNotifyComm::NotifyPublish
</a>
1236 ,
<a href=
"#filter_admin"> CosNotifyFilter::FilterAdmin
</a>
1237 , CosEventChannelAdmin::SupplierAdmin
</CODE> <br>
1239 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
1248 <TD><CODE>CosEventChannelAdmin::SupplierAdmin::obtain_push_consumer
</CODE></TD>
1255 <TD><CODE>CosEventChannelAdmin::SupplierAdmin::obtain_pull_consumer
</CODE></TD>
1262 <TD><CODE>MyID
</CODE></TD>
1269 <TD><CODE>MyChannel
</CODE></TD>
1276 <TD><CODE>MyOperator
</CODE></TD>
1283 <TD><CODE>pull_consumers
</CODE></TD>
1290 <TD><CODE>push_consumers
</CODE></TD>
1297 <TD><CODE>get_proxy_consumer
</CODE></TD>
1300 href=
"../../orbsvcs/tests/Notify/Basic/">Updates
</a></TD>
1305 <TD><CODE>obtain_notification_pull_supplier
</CODE></TD>
1312 <TD><CODE>obtain_notification_push_consumer
</CODE></TD>
1315 href=
"../../orbsvcs/tests/Notify/Basic/">MultiTypes, ConnectDisconnect
1321 <TD><CODE>destroy
</CODE></TD>
1324 href=
"../../orbsvcs/tests/Notify/Basic/"> LifeCycle, IdAssignment
</a></TD>
1330 <a NAME=
"event_channel"></a><HR>
1331 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::EventChannel
</CODE><br>
1332 <B>Base Interface(s)
</B> <CODE> <a href=
"#qos_admin">
1333 CosNotification::QoSAdmin
</a>
1334 ,
<a href=
"#admin_prop_admin">
1335 CosNotification::AdminPropertiesAdmin
</a>
1336 , CosEventChannelAdmin::EventChannel
</CODE> <br>
1338 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
1347 <TD><CODE>CosEventChannelAdmin::EventChannel::for_consumers
</CODE></TD>
1354 <TD><CODE>CosEventChannelAdmin::EventChannel::for_suppliers
</CODE></TD>
1361 <TD><CODE>CosEventChannelAdmin::EventChannel::destroy
</CODE></TD>
1364 href=
"../../orbsvcs/tests/Notify/Basic/"> Events, Filter
</a> </TD>
1369 <TD><CODE>MyFactory
</CODE></TD>
1376 <TD><CODE>default_consumer_admin
</CODE></TD>
1379 href=
"../../orbsvcs/tests/Notify/Basic/">Events
</a></TD>
1384 <TD><CODE>default_supplier_admin
</CODE></TD>
1387 href=
"../../orbsvcs/tests/Notify/Basic/">Events
</a></TD>
1392 <TD><CODE>default_filter_factory
</CODE></TD>
1395 href=
"../../orbsvcs/tests/Notify/Basic/">Filter
</a></TD>
1400 <TD><CODE>new_for_consumers
</CODE></TD>
1403 href=
"../../orbsvcs/tests/Notify/Basic/">Simple,Events
</a></TD>
1408 <TD><CODE>new_for_suppliers
</CODE></TD>
1411 href=
"../../orbsvcs/tests/Notify/Basic/">Simple,Events
</a></TD>
1416 <TD><CODE>get_consumeradmin
</CODE></TD>
1419 href=
"../../orbsvcs/tests/Notify/Basic/">IdAssignment
</a></TD>
1424 <TD><CODE>get_supplieradmin
</CODE></TD>
1427 href=
"../../orbsvcs/tests/Notify/Basic/">IdAssignment
</a></TD>
1432 <TD><CODE>get_all_consumeradmins
</CODE></TD>
1439 <TD><CODE>get_all_supplieradmins
</CODE></TD>
1448 AdminProperties supported at the EventChannel are:
1451 MaxQueueLength, MaxConsumers, MaxSuppliers, RejectNewEvents
1455 see
<a href=
"../../orbsvcs/tests/Notify/Basic/"> AdminProperties
</a>
1457 <a NAME=
"event_channel_factory"></a><HR>
1458 <B>Interface
</B> :
<CODE>CosNotifyChannelAdmin::EventChannelFactory
</CODE><br>
1459 <B>Base Interface(s)
</B>: none
<br>
1461 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
1470 <TD><CODE>create_channel
</CODE></TD>
1473 href=
"../../orbsvcs/tests/Notify/Basic/">Events,Simple
</a></TD>
1478 <TD><CODE>get_all_channels
</CODE></TD>
1485 <TD><CODE>get_event_channel
</CODE></TD>
1488 href=
"../../orbsvcs/tests/Notify/Basic/">IdAssignment
</a></TD>
1494 <a NAME=
"ext_ecf"></a><HR>
1495 <B>Interface
</B> :
<CODE>NotifyExt::EventChannelFactory
</CODE><br>
1496 <B>Base Interface(s)
</B> : CosNotifyChannelAdmin::EventChannelFactory
<br>
1498 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
1507 <TD><CODE>destroy
</CODE></TD>
1509 <TD>Yes, see
<a href=
"../../orbsvcs/tests/Notify/Destroy"> Destroy
</a>
1516 <a NAME=
"ext_ca"></a><HR>
1517 <B>Interface
</B> :
<CODE>NotifyExt::ConsumerAdmin
</CODE><br>
1518 <B>Base Interface(s)
</B> : CosNotifyChannelAdmin::ConsumerAdmin
<br>
1520 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
1529 <TD><CODE>obtain_notification_push_supplier_with_qos
</CODE></TD>
1531 <TD>Yes, see
<a href=
"../../orbsvcs/tests/Notify/Lanes"> Lanes
</a>
1538 <a NAME=
"ext_sa"></a><HR>
1539 <B>Interface
</B> :
<CODE>NotifyExt::SupplierAdmin
</CODE><br>
1540 <B>Base Interface(s)
</B> : CosNotifyChannelAdmin::SupplierAdmin
<br>
1542 <P><TABLE BORDER=
"2" CELLSPACING=
"2" CELLPADDING=
"0">
1551 <TD><CODE>obtain_notification_push_consumer_with_qos
</CODE></TD>
1553 <TD>Yes, see
<a href=
"../../orbsvcs/tests/Notify/Lanes"> Lanes
</a>
1560 The additional QoS properties supported are:
<br>
1568 ThreadPoolLanesParams
1572 see the
<a href=
"../../orbsvcs/orbsvcs/NotifyExt.idl"> NotifyExt.idl
</a> file for the QoS definitions.
1576 <H2><center><a NAME=
"test_framework"></a>Scripting Options for Notification Service Testing framework
</center> </H2><p>
1579 The Notification Service Testing framework uses the Service Configurator to load various command objects.
<br>
1580 The
<tt>Command_Builder
</tt> object is used to load the target objects.
<br>
1581 To test the various Notification features we then write scripts to rapidly reproduce test cases.
<br>
1583 The
<a href=
"../../orbsvcs/tests/Notify/Driver" >Notify_Test_Driver
</a> program reads a svc.conf file and executes the commands specified.
<br>
1584 The following options can specified to the Driver program:
<p>
1587 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1590 <TH WIDTH=
40%
>Command
</TH>
1591 <TH>Description
</TH>
1596 <TD>-Timeout timeout_period_in_seconds
</TD>
1598 <TD> Specify the timeout period for this test
</TD>
1604 <TD>-IORoutput output_file_name
</TD>
1606 <TD> Output the IOR of the
<a href=
"../../orbsvcs/tests/Notify/lib/Activation_Manager.idl" >Activation Manager
</a>.
<br>
1607 This is used by a client to signal its peer.
</TD>
1613 <TD>-IORinput file://input_file_name
</TD>
1616 Input the IOR of the peer's
<a href=
"../../orbsvcs/tests/Notify/lib/Activation_Manager.idl" >Activation Manager
</a>.
<br>
1617 This is used to signal the peer.
1623 <TD>-Skip_Priority_Levels_Check
</TD>
1626 Skip the check for multiple priority levels.
1633 See the *.conf files in
<a href=
"../../orbsvcs/tests/Notify/Lanes" >Lanes
</a>
1635 <a href=
"../../orbsvcs/tests/Notify/ThreadPool" >ThreadPool
</a>
1636 for examples of the test framework in use.
1639 The options that can be specified to each target object are as follows:
1642 <h3>Target Object :
<b> EventChannel
</b></h3>
1643 Loading Syntax: dynamic TAO_Notify_EventChannel_Command_Factory Service_Object *TAO_NotifyTests:_make_TAO_Notify_EventChannel_Command_Factory ()
""
1645 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1648 <TH WIDTH=
20%
>Command
</TH>
1650 <TH>Description
</TH>
1655 <TD WIDTH=
60%
>Name_of_channel
<br> Name_of_EventChannelFactory
<br> [COLLOCATED]
1657 <TD>Create an Event Channel
</TD>
1661 <br><b>Example :
</b> static Command_Builder
"EventChannel -Create ec1 NotifyEventChannelFactory"
1663 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1666 <TH WIDTH=
20%
>Command
</TH>
1668 <TH>Description
</TH>
1673 <TD WIDTH=
60%
>Name_of_channel
1675 <TD>Destroy an Event Channel
</TD>
1679 <br><b>Example :
</b> static Command_Builder
"EventChannel -Destroy ec1"
1681 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1684 <TH WIDTH=
20%
>Command
</TH>
1685 <TH WIDTH=
60%
>Parameters
</TH>
1686 <TH>Description
</TH>
1692 Name_of_channel [QoS_Options]
1695 <TD>Set QoS parameters on an event channel
1700 QoS_Options = -ThreadPool [-Threads thread_pool_size (default=
1) ]
1702 [-Priority default_priority (default=ACE_DEFAULT_THREAD_PRIORITY)]
1705 -Lanes lane_count [-Lane priority static_threads dynamic_threads]*
1707 <p><b>Example :
</b>: static Command_Builder
"EventChannel -Set_QoS -ThreadPool Threads 2 -Priority 2"
1708 <br><b>Example :
</b>: static Command_Builder
"EventChannel -Set_QoS -Lanes 2 -Lane 10 1 0 -Lane 30 2 1"
1712 <h3>Target Object :
<b> ConsumerAdmin
</b></h3>
1713 Loading Syntax: dynamic TAO_Notify_ConsumerAdmin_Command_Factory Service_Object *TAO_NotifyTests:_make_TAO_Notify_ConsumerAdmin_Command_Factory ()
""
1715 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1718 <TH WIDTH=
20%
>Command
</TH>
1719 <TH WIDTH=
60%
>Parameters
</TH>
1720 <TH>Description
</TH>
1728 Name_of_EventChannel
<br>
1730 [-AND_OP | OR_OP (default = CosNotifyChannelAdmin::OR_OP)]
1733 <TD>Create a ConsumerAdmin
</TD>
1737 <br><b>Example :
</b>: static Command_Builder
"ConsumerAdmin -Create ca1 ec1 -AND_OP"
1739 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1742 <TH WIDTH=
20%
>Command
</TH>
1743 <TH WIDTH=
60%
>Parameters
</TH>
1744 <TH>Description
</TH>
1748 <TD>-Subscription
</TD>
1752 +added_type1 +added_type2 ... -removed_type3 -removed_type4 ...
1755 <TD>Send subscription updates to the ConsumerAdmin. Note that domain name is set to
"*".
1761 <br><b>Example :
</b>: static Command_Builder
"ConsumerAdmin -Subscription ca1 +Red +Green -Blue"
1763 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1766 <TH WIDTH=
20%
>Command
</TH>
1767 <TH WIDTH=
60%
>Parameters
</TH>
1768 <TH>Description
</TH>
1774 Name_of_Admin [QoS_Options]
1778 Set QoS options for ConsumerAdmin
1784 QoS_Options = -ThreadPool [-Threads thread_pool_size (default=
1) ]
1786 [-Priority default_priority (default=ACE_DEFAULT_THREAD_PRIORITY)]
1789 -Lanes lane_count [-Lane priority static_threads dynamic_threads]*
1791 <p><b>Example :
</b>: static Command_Builder
"ConsumerAdmin -Set_Qos -ThreadPool Threads 2 -Priority 2"
1792 <br><b>Example :
</b>: static Command_Builder
"ConsumerAdmin -Set_Qos -Lanes 2 -Lane 10 1 0 -Lane 30 2 1"
1795 <h3>Target Object :
<b> SupplierAdmin
</b></h3>
1796 Loading Syntax: dynamic TAO_Notify_SupplierAdmin_Command_Factory Service_Object *TAO_NotifyTests:_make_TAO_Notify_SupplierAdmin_Command_Factory ()
""
1798 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1801 <TH WIDTH=
20%
>Command
</TH>
1802 <TH WIDTH=
60%
>Parameters
</TH>
1803 <TH>Description
</TH>
1811 Name_of_EventChannel
<br>
1813 [-AND_OP | OR_OP (default = CosNotifyChannelAdmin::OR_OP)]
1816 <TD>Create a SupplierAdmin
</TD>
1820 <br><b>Example :
</b>: static Command_Builder
"SupplierAdmin -Create sa1 ec1 -AND_OP"
1822 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1825 <TH WIDTH=
20%
>Command
</TH>
1826 <TH WIDTH=
60%
>Parameters
</TH>
1827 <TH>Description
</TH>
1835 +added_type1 +added_type2 ... -removed_type3 -removed_type4 ...
1838 <TD>Send offer updates to the SupplierAdmin. Note that domain name is set to
"*".
1844 <br><b>Example :
</b>: static Command_Builder
"SupplierAdmin -Offer ca1 +Red +Green -Blue"
1846 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1849 <TH WIDTH=
20%
>Command
</TH>
1850 <TH WIDTH=
60%
>Parameters
</TH>
1851 <TH>Description
</TH>
1857 Name_of_Admin [QoS_Options]
1861 Set QoS options for SupplierAdmin
1867 QoS_Options = -ThreadPool [-Threads thread_pool_size (default=
1) ]
1869 [-Priority default_priority (default=ACE_DEFAULT_THREAD_PRIORITY)]
1872 -Lanes lane_count [-Lane priority static_threads dynamic_threads]*
1874 <p><b>Example :
</b>: static Command_Builder
"SupplierAdmin -Set_Qos -ThreadPool Threads 2 -Priority 2"
1875 <br><b>Example :
</b>: static Command_Builder
"SupplierAdmin -Set_Qos -Lanes 2 -Lane 10 1 0 -Lane 30 2 1"
1878 <h3>Target Object :
<b> PeriodicConsumer
</b></h3>
1879 Loading Syntax: dynamic TAO_Notify_Periodic_Consumer_Command_Factory Service_Object* TAO_NotifyTests:_make_TAO_Notify_Periodic_Consumer_Command_Factory ()
""
1881 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1884 <TH WIDTH=
20%
>Command
</TH>
1885 <TH WIDTH=
60%
>Parameters
</TH>
1886 <TH>Description
</TH>
1892 Name_of_Consumer
<br>
1894 [-Relay relay_destination]
<br>
1897 [-Admin Name_of_ConsumerAdmin]
<br>
1899 [-POA name_of_POA (default = RootPOA)]
<br>
1901 [-Proxy proxy_name]
<br>
1903 [-Set_QoS [Qos_Options]]
<br>
1905 [-MaxCount expected_number_of_events]
<br>
1910 <TD>Create a PeriodicConsumer. The consumer is activated in the POA specified.
1915 <br><b>Example :
</b>: static Command_Builder
"PeriodicConsumer -Create c1 ca1 -POA myPOA -Proxy ca1_proxy -MaxCount 10"
1917 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1920 <TH WIDTH=
20%
>Command
</TH>
1921 <TH WIDTH=
60%
>Parameters
</TH>
1922 <TH>Description
</TH>
1926 <TD>-Subscription
</TD>
1928 Name_of_Consumer
<br>
1930 +added_type1 +added_type2 ... -removed_type3 -removed_type4 ...
1935 static Command_Builder
"PeriodicConsumer -Subscription ca1 +Red +Green -Blue"
1941 <br><b>Example :
</b>: Send subscription updates to its proxy. Note that domain name is set to
"*".
1943 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1946 <TH WIDTH=
20%
>Command
</TH>
1947 <TH WIDTH=
60%
>Parameters
</TH>
1948 <TH>Description
</TH>
1952 <TD>-Disconnect
</TD>
1957 <TD>Disconnect the Consumer from the EventChannel.
1963 <br><b>Example :
</b>: static Command_Builder -PeriodicConsumer
"Disconnect ca1"
1966 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1969 <TH WIDTH=
20%
>Command
</TH>
1970 <TH WIDTH=
60%
>Parameters
</TH>
1971 <TH>Description
</TH>
1975 <TD>-Deactivate
</TD>
1980 <TD>Deactivate the Consumer from its POA
</TD>
1985 <br><b>Example :
</b>: static Command_Builder
"-PeriodicConsumer -Deactivate ca1"
1987 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
1990 <TH WIDTH=
20%
>Command
</TH>
1991 <TH WIDTH=
60%
>Parameters
</TH>
1992 <TH>Description
</TH>
2000 <TD>Print the status of the consumer.
2002 Checks if the proxy is alive.
2007 <br><b>Example :
</b>: static Command_Builder
"-PeriodicConsumer -Status ca1"
2009 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2012 <TH WIDTH=
20%
>Command
</TH>
2013 <TH WIDTH=
60%
>Parameters
</TH>
2014 <TH>Description
</TH>
2020 Name_of_consumer [QoS_Options]
2023 <TD>Set QoS parameters on a Periodic Consumer. The actual QoS settings are applied to the corresponding ProxySupplier.
2028 QoS_Options = -ThreadPool [-Threads thread_pool_size (default=
1) ]
2030 [-Priority default_priority (default=ACE_DEFAULT_THREAD_PRIORITY)]
2033 -Laness lane_count [-Lane priority static_threads dynamic_threads]*
2035 <p><b>Example :
</b>: static Command_Builder
"PeriodicConsumer -Set_QoS -ThreadPool Threads 2 -Priority 2"
2036 <br><b>Example :
</b>: static Command_Builder
"PeriodicConsumer -Set_QoS -Lanes 2 -Lane 10 1 0 -Lane 30 2 1"
2039 <h3>Target Object :
<b> PeriodicSupplier
</b></h3>
2040 Loading Syntax: dynamic TAO_Notify_Periodic_Supplier_Command_Factory Service_Object* TAO_NotifyTests:_make_TAO_Notify_Periodic_Supplier_Command_Factory ()
""
2042 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2045 <TH WIDTH=
20%
>Command
</TH>
2046 <TH WIDTH=
60%
>Parameters
</TH>
2047 <TH>Description
</TH>
2054 Name_of_Supplier
<br>
2056 [-Direct direct_target]
<br>
2058 [-Admin Name_of_ConsumerAdmin]
<br>
2060 [-POA name_of_POA (default = RootPOA)]
<br>
2062 [-Proxy proxy_name]
<br>
2064 [-Set_QoS [Qos_Options]]
<br>
2066 -EventType type_of_event
<br>
2068 -FilterLongData name long_filterable_data
<br>
2070 -Priority supplier_thread_priority
<br>
2072 -Period sending_period (in microseconds)
<br>
2074 -ExecTime estimated_time_per_send_operation
<br>
2076 -Phase supplier_thread_starting_phase
<br>
2078 -Iter number_of_events-to_send
<br>
2080 -Load hint_to_consumer
<br>
2082 -RunTime time_to_run_in_sec
2086 Create a PeriodicSupplier.
2088 The supplier is activated in the POA specified.
2090 The -Create command spawns a thread that sends periodic events.
2096 <br><b>Example :
</b>: static Command_Builder
"PeriodicSupplier -Create s1 sa1_ec1 -Proxy s1_proxy -EventType RED -FilterLongData Temp 3 -Priority 0 -Period 10000 -ExecTime 10000 -Phase 0 -Iter 1 -Load 1 "
2099 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2102 <TH WIDTH=
20%
>Command
</TH>
2103 <TH WIDTH=
60%
>Parameters
</TH>
2104 <TH>Description
</TH>
2110 Name_of_Supplier
<br>
2112 +added_type1 +added_type2 ... -removed_type3 -removed_type4 ...
2117 static Command_Builder
"PeriodicSupplier -Offer sa1 +Red +Green -Blue"
2123 <br><b>Example :
</b>: Send offer updates to its proxy. Note that domain name is set to
"*".
2125 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2128 <TH WIDTH=
20%
>Command
</TH>
2129 <TH WIDTH=
60%
>Parameters
</TH>
2130 <TH>Description
</TH>
2134 <TD>-Disconnect
</TD>
2139 <TD>Disconnect the Supplier from the EventChannel.
2145 <br><b>Example :
</b>: static Command_Builder -PeriodicSupplier
"Disconnect sa1"
2148 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2151 <TH WIDTH=
20%
>Command
</TH>
2152 <TH WIDTH=
60%
>Parameters
</TH>
2153 <TH>Description
</TH>
2157 <TD>-Deactivate
</TD>
2162 <TD>Deactivate the Supplier from its POA
</TD>
2167 <br><b>Example :
</b>: static Command_Builder
"-PeriodicSupplier -Deactivate ca1"
2169 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2172 <TH WIDTH=
20%
>Command
</TH>
2173 <TH WIDTH=
60%
>Parameters
</TH>
2174 <TH>Description
</TH>
2182 <TD>Print the status of the consumer.
2184 Checks if the proxy is alive.
2189 <br><b>Example :
</b>: static Command_Builder
"-PeriodicSupplier -Status sa1"
2191 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2194 <TH WIDTH=
20%
>Command
</TH>
2195 <TH WIDTH=
60%
>Parameters
</TH>
2196 <TH>Description
</TH>
2202 Name_of_Supplier [QoS_Options]
2205 <TD>Set QoS parameters on a Periodic Supplier. The actual QoS settings are applied to the corresponding ProxyConsumer.
2210 QoS_Options = -ThreadPool [-Threads thread_pool_size (default=
1) ]
2212 [-Priority default_priority (default=ACE_DEFAULT_THREAD_PRIORITY)]
2215 -Laness lane_count [-Lane priority static_threads dynamic_threads]*
2217 <p><b>Example :
</b>: static Command_Builder
"PeriodicSupplier -Set_QoS -ThreadPool Threads 2 -Priority 2"
2218 <br><b>Example :
</b>: static Command_Builder
"PeriodicSupplier -Set_QoS -Lanes 2 -Lane 10 1 0 -Lane 30 2 1"
2222 <h3>Target Object :
<b> Filter
</b></h3>
2223 Loading Syntax: dynamic TAO_Notify_Filter_Command_Factory Service_Object* TAO_NotifyTests:_make_TAO_Notify_Filter_Command_Factory ()
""
2225 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2228 <TH WIDTH=
20%
>Command
</TH>
2229 <TH WIDTH=
60%
>Parameters
</TH>
2230 <TH>Description
</TH>
2234 <TD>-CreateFactory
</TD>
2237 Filter_Factory_Name
<br>
2242 <TD>Obtain the default FilterFactory from the EventChannel.
2247 <br><b>Example :
</b>: static Command_Builder
"Filter -CreateFactory ff ec1"
2249 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2252 <TH WIDTH=
20%
>Command
</TH>
2253 <TH WIDTH=
60%
>Parameters
</TH>
2254 <TH>Description
</TH>
2258 <TD>-CreateFilter
</TD>
2270 <br><b>Example :
</b>: static Command_Builder
"Filter -CreateFilter f1 ff"
2272 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2275 <TH WIDTH=
20%
>Command
</TH>
2276 <TH WIDTH=
60%
>Parameters
</TH>
2277 <TH>Description
</TH>
2281 <TD>-Add_Constraint
</TD>
2286 Constraint_Expression
2290 Add a constraint to a filter.
2296 <br><b>Example :
</b>: static Command_Builder
"Filter -Add_Constraint f1 'Temp > 2'"
2298 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2301 <TH WIDTH=
20%
>Command
</TH>
2302 <TH WIDTH=
60%
>Parameters
</TH>
2303 <TH>Description
</TH>
2316 Add a filter to an Admin.
2318 The FilterAdmin can be the name of any Admin or Proxy objects.
2324 <br><b>Example :
</b>: static Command_Builder
"Filter -Add_Filter f1 sa1_ec1"
2326 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2329 <TH WIDTH=
20%
>Command
</TH>
2330 <TH WIDTH=
60%
>Parameters
</TH>
2331 <TH>Description
</TH>
2349 <br><b>Example :
</b>: static Command_Builder
"Filter –Destroy ff "
2352 <h3>Target Object :
<b> Application
</b></h3>
2353 Loading Syntax for RTCORBA Application:
<br>
2354 dynamic TAO_Notify_RT_Application_Command_Factory Service_Object * TAO_RT_NotifyTests:_make_TAO_Notify_RT_Application_Command_Factory ()
"" <br>
2355 Loading Syntax for non-RTCORBA Application:
<br>
2356 dynamic TAO_Notify_Application_Command_Factory Service_Object * TAO_NotifyTests:_make_TAO_Notify_Application_Command_Factory ()
""
2358 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2361 <TH WIDTH=
20%
>Command
</TH>
2362 <TH WIDTH=
60%
>Parameters
</TH>
2363 <TH>Description
</TH>
2374 Init the Application
2380 <br><b>Example :
</b>: static Command_Builder
"Application -Init"
2382 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2385 <TH WIDTH=
20%
>Command
</TH>
2386 <TH WIDTH=
60%
>Parameters
</TH>
2387 <TH>Description
</TH>
2398 Run all the suppliers and consumers.
2404 <br><b>Example :
</b>: static Command_Builder
"Application -Run"
2407 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2410 <TH WIDTH=
20%
>Command
</TH>
2411 <TH WIDTH=
60%
>Parameters
</TH>
2412 <TH>Description
</TH>
2416 <TD>-WaitForEvents
</TD>
2423 Wait till all the suppliers have send all there events and all the consumers have received the expected count of events.
2429 <br><b>Example :
</b>: static Command_Builder
"Application –Wait_For_Events"
2432 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2435 <TH WIDTH=
20%
>Command
</TH>
2436 <TH WIDTH=
60%
>Parameters
</TH>
2437 <TH>Description
</TH>
2454 <br><b>Example :
</b>: static Command_Builder
"Application –Shutdown"
2457 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2460 <TH WIDTH=
20%
>Command
</TH>
2461 <TH WIDTH=
60%
>Parameters
</TH>
2462 <TH WIDTH=
20%
>Description
</TH>
2474 Dump performance statistics.
<br>
2476 if the -Samples option is specified all the latency samples are generated.
<br>
2478 Data files are created in the current directory with the following names:
<br>
2480 Supplier_{supplier_name}.dat
<br>
2482 Consumer_{consumer_name}.dat
<br>
2488 <br><b>Example :
</b>: static Command_Builder
"Application –DumpStats"
2490 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2493 <TH WIDTH=
20%
>Command
</TH>
2494 <TH WIDTH=
60%
>Parameters
</TH>
2495 <TH>Description
</TH>
2499 <TD>-SignalPeer
</TD>
2506 Signal another waiting instance of the test.
2511 <br><b>Example
</b>: static Command_Builder
"Application –SignalPeer":
2515 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2518 <TH WIDTH=
20%
>Command
</TH>
2519 <TH WIDTH=
60%
>Parameters
</TH>
2520 <TH>Description
</TH>
2524 <TD>-WaitToStart
</TD>
2531 Wait for another instance to signal.
2536 <br><b>Example
</b>:static Command_Builder
"Application –WaitToStart"
2541 <h3>Target Object :
<b> POA
</b></h3>
2542 Loading Syntax for RTCORBA Application:
<br>
2543 dynamic TAO_Notify_RT_POA_Command_Factory Service_Object* TAO_RT_NotifyTests:_make_TAO_Notify_RT_POA_Command_Factory ()
""
2545 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2548 <TH WIDTH=
20%
>Command
</TH>
2549 <TH WIDTH=
60%
>Parameters
</TH>
2550 <TH>Description
</TH>
2559 -PriorityModel {CLIENT|SERVER} default_priority (defaults : CLIENT_PROPAGATED, Priority =
0)
<br>
2561 -Lanes lane_count [-Lane priority static_threads dynamic_threads
>]*
<br>
2563 -Bands band_count [-Band low_priority high_priority]*
<br>
2565 -ThreadPool static_threads priority
2570 Create an RT POA with the specified name and options of
2575 <br><b>Example :
</b>: static Command_Builder
"POA -Create poa_test -PriorityModel CLIENT 1 -Lanes 1 -Lane -15 1 0"
2577 <P><TABLE WIDTH =
80%
BORDER=
"1" CELLSPACING=
"1" CELLPADDING=
"1">
2580 <TH WIDTH=
20%
>Command
</TH>
2581 <TH WIDTH=
60%
>Parameters
</TH>
2582 <TH>Description
</TH>
2599 <br><b>Example :
</b>: static Command_Builder
"POA –Destroy”