private void sendToIndex ( String message ) { try { getMessaging ( ) . queueMessage ( SolrWrapperQueueConsumer . QUEUE_ID , message ) ; } catch ( MessagingException ex ) { log . error ( "Unable to send message: " , ex ) ; } }
To put events to subscriber queue