diff --git a/rq/scripts/rq.py b/rq/scripts/rq.py
index 882195c..668a58b 100755
--- a/rq/scripts/rq.py
+++ b/rq/scripts/rq.py
@@ -39,7 +39,7 @@ def empty(queues):
         queues = (get_failed_queue(),)
     for queue in queues:
         num_jobs = queue.empty()
-        print('{} jobs removed from {} queue'.format(num_jobs, queue.name))
+        click.echo('{} jobs removed from {} queue'.format(num_jobs, queue.name))
 
 
 @rq.command()
@@ -47,14 +47,14 @@ def requeue():
     """Requeue all failed jobs in failed queue"""
     failed_queue = get_failed_queue()
     job_ids = failed_queue.job_ids
-    print('Requeuing {} failed jobs......'.format(len(job_ids)))
+    click.echo('Requeuing {} failed jobs......'.format(len(job_ids)))
     requeue_failed_num = 0
     for job_id in job_ids:
         try:
             failed_queue.requeue(job_id)
         except InvalidJobOperationError:
-            print('Requeue job({}) failed'.format(job_id))
+            click.echo('Requeue job({}) failed'.format(job_id))
             requeue_failed_num += 1
 
-    print('Requeue over with {} jobs requeuing failed'.format(
-        requeue_failed_num))
+    click.secho('Requeue over with {} jobs requeuing failed'.format(
+        requeue_failed_num), fg='red')