diff --git a/src/components/com_tjcertificate/administrator/controllers/bulktrainingrecord.json.php b/src/components/com_tjcertificate/administrator/controllers/bulktrainingrecord.json.php
index 492ac0d..5fe3201 100644
--- a/src/components/com_tjcertificate/administrator/controllers/bulktrainingrecord.json.php
+++ b/src/components/com_tjcertificate/administrator/controllers/bulktrainingrecord.json.php
@@ -17,6 +17,7 @@
 use Joomla\CMS\Session\Session;
 use Joomla\CMS\Response\JsonResponse;
 use Joomla\CMS\Component\ComponentHelper;
+use TJQueue\Admin\TJQueueProduce;
 
 /**
  * The Tj Certificate Training Records controller
@@ -91,7 +92,8 @@ public function save($key = null, $urlVar = null)
 			$data['is_external'] = 1;
 
 			unset($data['assigned_user_id']);
-
+			$queueProducer = new TJQueueProduce;
+			
 			foreach ($userIds as $userId)
 			{
 				if (ComponentHelper::isEnabled($this->comMultiAgency) && $params->get('enable_multiagency'))
@@ -132,7 +134,7 @@ public function save($key = null, $urlVar = null)
 				if (ComponentHelper::isEnabled('com_tjqueue') && $params->get('tjqueue_records'))
 				{
 					$recordsModel      = TJCERT::model('BulkTrainingRecord', array('ignore_request' => true));
-					$response          = $recordsModel->addToQueue($data);
+					$response          = $recordsModel->addToQueue($data, $queueProducer);
 					$msg               = $response ? Text::_("COM_TJCERTIFICATE_RECORDS_ADDED_TO_QUEUE_SUCCESSFULLY") : Text::_("COM_TJCERTIFICATE_RECORDS_FAILED");
 					$returnData['msg'] = $msg;
 				}
diff --git a/src/components/com_tjcertificate/administrator/models/bulktrainingrecord.php b/src/components/com_tjcertificate/administrator/models/bulktrainingrecord.php
index d7d2c36..56b9a29 100644
--- a/src/components/com_tjcertificate/administrator/models/bulktrainingrecord.php
+++ b/src/components/com_tjcertificate/administrator/models/bulktrainingrecord.php
@@ -107,14 +107,14 @@ public function validate($form, $data, $group = null)
 	 *
 	 * @since __DEPLOY_VERSION__
 	 */
-	public function addToQueue($data)
+	public function addToQueue($data, $queueProducer = null)
 	{
 		$return      = array();
 		$messageBody = (object) $data;
+		$TJQueueProduce = $queueProducer ?: new TJQueueProduce;
 
 		try
 		{
-			$TJQueueProduce = new TJQueueProduce;
 
 			// Set message body
 			$TJQueueProduce->message->setBody(json_encode($messageBody));