def add_result_to_amq(results, credentials, data):
    print (results, credentials)

    if str(credentials) in 'None':
        return
    username = credentials['brokerUsername']
    password = credentials['brokerPassword']
    queue = credentials['brokerQueue']
    host = credentials['brokerURL']
    port = credentials.get('brokerPort', 61613)
    conn = stomp.Connection([(host, port)])
    conn.connect(username, password, wait=True)
    body = {
        'synchronous':'False',
        'input_folder':data['input_folder'],
        'output_folder':data['output_folder'],
        'results':results
        }
    conn.send(body=json.dumps(body), destination=queue)
    time.sleep(2)
    conn.disconnect()