EventService.idl

#ifndef __EVENT_SERVICE_IDL__
#define __EVENT_SERVICE_IDL__

#include<Event.idl>

module event {


    interface Consumer {

        void pushEvents(in vector<idl.Event> events);
        
    };

    interface Channel_1_0_1 {

        /* --- filter interface --- */

        void demandEventType(in typecode type);

        void cancelEventType(in typecode type);

        void demandEventTypes(in vector<typecode> types);

        void cancelEventTypes(in vector<typecode> types);

        void demandEvent(in typecode type, in Object src);

        void cancelEvent(in typecode type, in Object src);

        structure EventSelect {
            typecode type;
            Object src;
        };
        
        void demandEvents(in vector<EventSelect> events);

        void cancelEvents(in vector<EventSelect> events);
        

        /* --- push interface --- */

        void subscribe(in Consumer consumer);

        int unsubscribe(in Consumer consumer);

        
        /* --- poll interface --- */

        boolean pollEvents(out vector<idl.Event> events);

        boolean pollEventsNb(out vector<idl.Event> events);

    };

    interface Service_1_0_1 {

        constant int INVALID_CHANNEL = 1;
        
        Channel_1_0_1 createChannel();

        int destroyChannel(in Channel_1_0_1 channel);

        void pushEvent(in idl.Event event);

        void pushEvents(in vector<idl.Event> events);

    };

}

#endif