common/src/main/java/com/cognitree/kronos/queue/QueueService.java
/**
     * Send task (not necessarily ordered)
     *
     * @param task
     * @throws ServiceException
     */
Send task (not necessarily ordered)
@param task
@throws ServiceException
Send task ( not necessarily ordered ) @param task @throws ServiceException
public void send(Task task) throws ServiceException {
        logger.debug("Received request to send task {}", task.getIdentity());
        final String type = task.getType();
        if (!producers.containsKey(type)) {
            createProducer(type);
        }
        try {
            producers.get(type).send(MAPPER.writeValueAsString(task));
        } catch (IOException e) {
            logger.error("Error serializing task {}", task, e);
        }
    }
public void send ( Task task ) throws ServiceException { logger . debug ( "Received request to send task {}" , task . getIdentity ( ) ) ; final String type = task . getType ( ) ; if ( ! producers . containsKey ( type ) ) { createProducer ( type ) ; } try { producers . get ( type ) . send ( MAPPER . writeValueAsString ( task ) ) ; } catch ( IOException e ) { logger . error ( "Error serializing task {}" , task , e ) ; } }
Send task (not necessarily ordered)
 @param task
 @throws ServiceException
Send task ( not necessarily ordered ) @param task @throws ServiceException