aboutsummaryrefslogblamecommitdiffstats
path: root/lib/cosNotification/src/CosNotification.idl
blob: e080b44b0c77bc8c7ca6534f7348a4e6e3a44eaa (plain) (tree)

















































































































































                                                                    
#ifndef _COS_NOTIFICATION_IDL_
#define _COS_NOTIFICATION_IDL_

#pragma prefix "omg.org"

#include"CosEventChannelAdmin.idl"
#include"CosEventComm.idl"

module CosNotification {
  typedef string Istring;
  typedef Istring PropertyName;
  typedef any PropertyValue;
  struct Property {
    PropertyName name;
    PropertyValue value;
  };
  typedef sequence<Property> PropertySeq;
  // The following are the same, but serve different purposes.
  typedef PropertySeq OptionalHeaderFields;
  typedef PropertySeq FilterableEventBody;
  typedef PropertySeq QoSProperties;
  typedef PropertySeq AdminProperties;
  struct EventType {
    string domain_name;
    string type_name;
  };
  typedef sequence<EventType> EventTypeSeq;
  struct PropertyRange {
    PropertyValue low_val;
    PropertyValue high_val;
  };
  struct NamedPropertyRange {
    PropertyName name;
    PropertyRange range;
  };

  typedef sequence<NamedPropertyRange> NamedPropertyRangeSeq;

  enum QoSError_code {
    UNSUPPORTED_PROPERTY,
    UNAVAILABLE_PROPERTY,
    UNSUPPORTED_VALUE,
    UNAVAILABLE_VALUE,
    BAD_PROPERTY,
    BAD_TYPE,
    BAD_VALUE
  };

  struct PropertyError {
    QoSError_code code;
    PropertyName name;
    PropertyRange available_range;
  };

  typedef sequence<PropertyError> PropertyErrorSeq;
  exception UnsupportedQoS { PropertyErrorSeq qos_err; };
  exception UnsupportedAdmin { PropertyErrorSeq admin_err; };
  
  // Define the Structured Event structure 
  struct FixedEventHeader {
    EventType event_type;
    string event_name;
  };
  struct EventHeader {
    FixedEventHeader fixed_header;
    OptionalHeaderFields variable_header;
  };

  struct StructuredEvent {
    EventHeader header;
    FilterableEventBody filterable_data;
    any remainder_of_body;
  }; // StructuredEvent

  typedef sequence<StructuredEvent> EventBatch;

  // The following constant declarations define the standard
  // QoS property names and the associated values each property
  // can take on. The name/value pairs for each standard property
  // are grouped, beginning with a string constant defined for the
  // property name, followed by the values the property can take on.
  const string EventReliability = "EventReliability";
  const short BestEffort = 0;
  const short Persistent = 1;
  const string ConnectionReliability = "ConnectionReliability";

  // Can take on the same values as EventReliability
  const string Priority = "Priority";
  const short LowestPriority = -32767;
  const short HighestPriority = 32767;
  const short DefaultPriority = 0;
  const string StartTime = "StartTime";
  
  // StartTime takes a value of type TimeBase::UtcT.
  const string StopTime = "StopTime";
  // StopTime takes a value of type TimeBase::UtcT.
  const string Timeout = "Timeout";
  // Timeout takes on a value of type TimeBase::TimeT
  const string OrderPolicy = "OrderPolicy";
  const short AnyOrder = 0;
  const short FifoOrder = 1;
  const short PriorityOrder = 2;
  const short DeadlineOrder = 3;
  const string DiscardPolicy = "DiscardPolicy";
  // DiscardPolicy takes on the same values as OrderPolicy, plus
  const short LifoOrder = 4;
  const short RejectNewEvents = 5;
  const string MaximumBatchSize = "MaximumBatchSize";
  // MaximumBatchSize takes on a value of type long
  const string PacingInterval = "PacingInterval";
  // PacingInterval takes on a value of type TimeBase::TimeT
  const string StartTimeSupported = "StartTimeSupported";
  // StartTimeSupported takes on a boolean value
  const string StopTimeSupported = "StopTimeSupported";
  // StopTimeSupported takes on a boolean value
  const string MaxEventsPerConsumer = "MaxEventsPerConsumer";
  // MaxEventsPerConsumer takes on a value of type long
  
  interface QoSAdmin {
    QoSProperties get_qos();
    void set_qos ( in QoSProperties qos)
      raises ( UnsupportedQoS );
    void validate_qos (in QoSProperties required_qos,
		       out NamedPropertyRangeSeq available_qos )
      raises ( UnsupportedQoS );
  }; // QosAdmin

  // Admin properties are defined in similar manner as QoS
  // properties. The only difference is that these properties
  // are related to channel administration policies, as opposed
  // message quality of service
  const string MaxQueueLength = "MaxQueueLength";
  // MaxQueueLength takes on a value of type long 
  const string MaxConsumers = "MaxConsumers";
  // MaxConsumers takes on a value of type long
  const string MaxSuppliers = "MaxSuppliers";
  // MaxSuppliers takes on a value of type long
  interface AdminPropertiesAdmin {
    AdminProperties get_admin();
    void set_admin (in AdminProperties admin)
      raises ( UnsupportedAdmin);
  };// AdminPropertiesAdmin
}; // CosNotification

#endif /* ifndef _COS_NOTIFICATION_IDL_ */