Indexing new objects

The indexing procedure of the particular indexes is initiated by consuming the corresponding input queues containing the objects to be indexed:

• Event index – populated by messages consumed from the ION-BodEvent-Q-environment_name queue

  This queue is populated by ION, when any event happens.

• Message index – populated by messages consumed from the ION-BodEvent-Q-environment_name-MSG queue

  This queue is populated by OneView. Only events of a particular type (BOD entered ION) are forwarded to this queue.

• Statistics index – populated by messages consumed from the ION-BodEvent-Q-environment_name-ENR queue

  This queue is populated by OneView. Events of a particular type are forwarded to this queue.

Each consumed message is processed by the corresponding processor in the specific manner based on the type of the message, but all messages use a similar process:

• Consume object from queue
• Transform to the desired format
• Indexing

For indexing purposes, batching (io.searchbox.core.Bulk) is used.