common/src/main/java/com/cognitree/kronos/queue/QueueService.java
/**
     * Broadcast control messages
     *
     * @param controlMessage
     * @throws ServiceException
     */
Broadcast control messages
@param controlMessage
@throws ServiceException
Broadcast control messages @param controlMessage @throws ServiceException
public void send(ControlMessage controlMessage) throws ServiceException {
        logger.debug("Received request to send task control message {}", controlMessage);
        if (!producers.containsKey(controlQueue)) {
            createProducer(controlQueue);
        }
        try {
            producers.get(controlQueue).broadcast(MAPPER.writeValueAsString(controlMessage));
        } catch (IOException e) {
            logger.error("Error serializing control message {}", controlMessage, e);
        }
    }
public void send ( ControlMessage controlMessage ) throws ServiceException { logger . debug ( "Received request to send task control message {}" , controlMessage ) ; if ( ! producers . containsKey ( controlQueue ) ) { createProducer ( controlQueue ) ; } try { producers . get ( controlQueue ) . broadcast ( MAPPER . writeValueAsString ( controlMessage ) ) ; } catch ( IOException e ) { logger . error ( "Error serializing control message {}" , controlMessage , e ) ; } }
Broadcast control messages
 @param controlMessage
 @throws ServiceException
Broadcast control messages @param controlMessage @throws ServiceException