agave-jobs/jobs-core/src/main/java/org/iplantc/service/jobs/managers/JobEventProcessor.java
/**
     * Processes a custom user-defined runtime job event by throwing the event onto the 
     * notification queue for the job, but replacing the standard serialized json content 
     * with the runtime data. The 
     * @param customRuntimeJsonBody the JSON object sent from the job to forward on in the notification callback 
     */
Processes a custom user-defined runtime job event by throwing the event onto the
notification queue for the job, but replacing the standard serialized json content
with the runtime data. The
@param customRuntimeJsonBody the JSON object sent from the job to forward on in the notification callback
Processes a custom user - defined runtime job event by throwing the event onto the notification queue for the job but replacing the standard serialized json content with the runtime data . The @param customRuntimeJsonBody the JSON object sent from the job to forward on in the notification callback
public void processJobRuntimeCallbackEvent(JsonNode customRuntimeJsonBody) {    
    	if (customRuntimeJsonBody == null) {
            processSingleJobEvent(getEvent().getJob().getUuid(), getEvent().getStatus(), getEvent().getCreatedBy(), "{}");
        }
    	else if (StringUtils.length(customRuntimeJsonBody.toString()) > 5120) {
    		log.error("Failed to send " + getEvent().getStatus() + " custom runtime event for job " + 
    				getEvent().getJob().getUuid() + " because the message content exceeds the max " +
    				"job callback message size of 5k");
	    }
    	else {
            processSingleJobEvent(getEvent().getJob().getUuid(), getEvent().getStatus(), getEvent().getCreatedBy(), customRuntimeJsonBody.toString());
        }
    }
public void processJobRuntimeCallbackEvent ( JsonNode customRuntimeJsonBody ) { if ( customRuntimeJsonBody == null ) { processSingleJobEvent ( getEvent ( ) . getJob ( ) . getUuid ( ) , getEvent ( ) . getStatus ( ) , getEvent ( ) . getCreatedBy ( ) , "{}" ) ; } else if ( StringUtils . length ( customRuntimeJsonBody . toString ( ) ) > 5120 ) { log . error ( "Failed to send " + getEvent ( ) . getStatus ( ) + " custom runtime event for job " + getEvent ( ) . getJob ( ) . getUuid ( ) + " because the message content exceeds the max " + "job callback message size of 5k" ) ; } else { processSingleJobEvent ( getEvent ( ) . getJob ( ) . getUuid ( ) , getEvent ( ) . getStatus ( ) , getEvent ( ) . getCreatedBy ( ) , customRuntimeJsonBody . toString ( ) ) ; } }
Processes a custom user-defined runtime job event by throwing the event onto the
 notification queue for the job, but replacing the standard serialized json content
 with the runtime data.
Processes a custom user - defined runtime job event by throwing the event onto the notification queue for the job but replacing the standard serialized json content with the runtime data .
// Send the job event itself // else make sure payload is under 5k so we don't blow out our queue with // user data