|
void | run (bool async, bool terminate_control=true) |
|
void | shutdown () |
|
void | join () |
|
void | terminate () |
|
virtual uniset::ObjectType | getType () override |
|
virtual Poco::JSON::Object::Ptr | httpGetByName (const std::string &name, const Poco::URI::QueryParameters &p) override |
|
virtual Poco::JSON::Array::Ptr | httpGetObjectsList (const Poco::URI::QueryParameters &p) override |
|
virtual Poco::JSON::Object::Ptr | httpHelpByName (const std::string &name, const Poco::URI::QueryParameters &p) override |
|
virtual Poco::JSON::Object::Ptr | httpRequestByName (const std::string &name, const std::string &req, const Poco::URI::QueryParameters &p) override |
|
| UniSetManager (uniset::ObjectId id) |
|
| UniSetManager (const std::string &name, const std::string §ion) |
|
virtual void | broadcast (const uniset::TransportMessage &msg) override |
|
virtual uniset::SimpleInfoSeq * | getObjectsInfo (CORBA::Long MaxLength=300, const char *userparam=0) override |
|
virtual bool | add (const std::shared_ptr< UniSetObject > &obj) |
|
virtual bool | remove (const std::shared_ptr< UniSetObject > &obj) |
|
size_t | objectsCount () const |
|
PortableServer::POA_ptr | getPOA () |
|
PortableServer::POAManager_ptr | getPOAManager () |
|
std::shared_ptr< UniSetManager > | get_mptr () |
|
| UniSetObject (const std::string &name, const std::string §ion) |
|
| UniSetObject (uniset::ObjectId id) |
|
virtual CORBA::Boolean | exist () override |
|
virtual uniset::ObjectId | getId () override |
|
const uniset::ObjectId | getId () const |
|
std::string | getName () const |
|
const std::string | getStrType () |
|
virtual uniset::SimpleInfo * | getInfo (const char *userparam="") override |
|
virtual uniset::SimpleInfo * | apiRequest (const char *query) override |
|
virtual void | push (const uniset::TransportMessage &msg) override |
| поместить сообщение в очередь Подробнее...
|
|
virtual void | pushMessage (const char *msg, ::CORBA::Long mtype, const ::uniset::Timespec &tm, const ::uniset::ProducerInfo &pi, ::CORBA::Long priority, ::CORBA::Long consumer) override |
| поместить текстовое сообщение в очередь Подробнее...
|
|
virtual Poco::JSON::Object::Ptr | httpGet (const Poco::URI::QueryParameters &p) override |
|
virtual Poco::JSON::Object::Ptr | httpHelp (const Poco::URI::QueryParameters &p) override |
|
uniset::ObjectPtr | getRef () const |
|
std::shared_ptr< UniSetObject > | get_ptr () |
|
virtual timeout_t | askTimer (uniset::TimerId timerid, timeout_t timeMS, clock_t ticks=-1, uniset::Message::Priority p=uniset::Message::High) override |
|
timeout_t | checkTimers (UniSetObject *obj) |
|
timeout_t | getTimeInterval (uniset::TimerId timerid) const |
|
timeout_t | getTimeLeft (uniset::TimerId timerid) const |
|
virtual Poco::JSON::Object::Ptr | httpRequest (const std::string &req, const Poco::URI::QueryParameters &p) |
|
Создает POA менеджер и регистрирует в нем объекты. Для обработки CORBA-запросов создается поток или передаются ресурсы главного потока см. void activate(bool thread)
- Предупреждения
- Активатор может быть создан только один. Для его создания используйте код:
...
auto act = UniSetActivator::Instance()
...
Активатор в свою очередь сам является менеджером(и объектом) и обладает всеми его свойствами
REST API
UniSetActivator выступает в роли http-сервера и реализует первичную обработку запросов и перенаправление их указанным объектам. Помимо этого UniSetActivator реализует обработку команд /conf/.. Для запуска http-сервера необходимо в аргументах командной строки указать –activator-run-httpserver Помимо этого можно задать параметры –activator-httpserver-host и –activator-httpserver-port. –activator-httpserver-cors-allow addr - (CORS): Access-Control-Allow-Origin. Default: *.