Notifications workflows using the CERN IT central messaging infrastructure

In the CERN IT agile infrastructure (AI), Puppet, the CERN IT central messaging infrastructure (MI) and the Roger application are the key constituents handling the configuration of the machines of the computer centre. The machine configuration at any given moment depends on its declared state in Roger and Puppet ensures the actual implementation of the desired configuration by running the Puppet agent on the machine at regular intervals, typically every 90 minutes. Sometimes it is preferable that the configuration change is propagated immediately to the targeted machine, ahead of the next scheduled Puppet agent run on this machine. The particular need of handling notifications in a highly scalable manner for a large scale infrastructure has been satisfied with the implementation of the CERNMegabus architecture, based on the ActiveMQ messaging system. The design and implementation of the CERNMegabus architecture are introduced, followed by the implementation of the Roger notification workflow. The choice of ActiveMQ is analysed and the message flow between the Roger notification producer and the CASTOR, EOS, BATCH and Load Balancing consumers are presented. The employment of predefined consumer modules in order to speed up the on-boarding of new CERNMegabus use cases is also described.