diff --git a/config/services.yaml b/config/services.yaml
index a5d7d05f..05756f7f 100644
--- a/config/services.yaml
+++ b/config/services.yaml
@@ -328,3 +328,9 @@ services:
     App\Service\WarrantySerialLoadLogger:
         arguments:
             $em: "@doctrine.orm.entity_manager"
+
+    # drive hub manager
+    App\Service\DriveHubManager:
+        arguments:
+            $em: "@doctrine.orm.entity_manager"
+            $callback_url: "%env(DRIVEHUB_CALLBACK_URL)%"
diff --git a/src/Command/FulfillOldJobOrderCommand.php b/src/Command/FulfillOldJobOrderCommand.php
index dcf9d761..caa8ac90 100644
--- a/src/Command/FulfillOldJobOrderCommand.php
+++ b/src/Command/FulfillOldJobOrderCommand.php
@@ -16,15 +16,19 @@ use App\Entity\User;
 use App\Ramcar\JOStatus;
 use App\Ramcar\JOEventType;
 
+use App\Service\DriveHubManager;
+
 use DateTime;
 
 class FulfillOldJobOrderCommand extends Command
 {
     protected $em;
+    protected $dh_manager;
 
-    public function __construct(EntityManagerInterface $em)
+    public function __construct(EntityManagerInterface $em, DriveHubManager $dh_manager)
     {
         $this->em = $em;
+        $this->dh_manager = $dh_manager;
 
         parent::__construct();
     }
@@ -67,12 +71,23 @@ class FulfillOldJobOrderCommand extends Command
             $jo->fulfill();
 
             // add event
-			$event = new JOEvent();
-			$event->setDateHappen(new DateTime())
-				->setTypeID(JOEventType::FULFILL)
-				->setUser($user)
-				->setJobOrder($jo);
-			$em->persist($event);
+            $event = new JOEvent();
+            $event->setDateHappen(new DateTime())
+                ->setTypeID(JOEventType::FULFILL)
+                ->setUser($user)
+                ->setJobOrder($jo);
+            $em->persist($event);
+
+            // check if JO source is third party
+            if ($jo->getSource() == TransactionOrigin::THIRD_PARTY)
+            {
+                $jo_status_data = [
+                    'id' => $jo->getID(),
+                    'status_name' => $jo->getStatus(),
+                ];
+
+                $this->dh_manager->sendJOStatusChange($jo_status_data);
+            }
         }
 
         $em->flush();
diff --git a/src/Command/FulfillOpenJobOrderCommand.php b/src/Command/FulfillOpenJobOrderCommand.php
index 2e3f3b9e..a310ac3d 100644
--- a/src/Command/FulfillOpenJobOrderCommand.php
+++ b/src/Command/FulfillOpenJobOrderCommand.php
@@ -22,6 +22,9 @@ use App\Ramcar\WarrantyClass;
 use App\Ramcar\ServiceType;
 use App\Ramcar\WarrantySource;
 use App\Ramcar\WarrantyStatus;
+use App\Ramcar\TransactionOrigin;
+
+use App\Service\DriveHubManager;
 
 use DateTime;
 use DateInterval;
@@ -34,10 +37,12 @@ class FulfillOpenJobOrderCommand extends Command
     protected $em;
     protected $batt_hash;
     protected $sap_batt_hash;
+    protected $dh_manager;
 
-    public function __construct(EntityManagerInterface $em)
+    public function __construct(EntityManagerInterface $em, DriveHubManager $dh_manager)
     {
         $this->em = $em;
+        $this->dh_manager = $dh_manager;
 
         parent::__construct();
     }
@@ -76,7 +81,7 @@ class FulfillOpenJobOrderCommand extends Command
         $conn = $this->em->getConnection();
 
         $jo_sql = 'SELECT jo.id AS jo_id, c.id AS c_id, cv.id AS cv_id, 
-            jo.service_type, jo.warranty_class, jo.rider_id, jo.date_schedule
+            jo.service_type, jo.warranty_class, jo.rider_id, jo.date_schedule, jo.source
             FROM job_order jo, customer c, customer_vehicle cv
             WHERE jo.customer_id = c.id AND jo.cvehicle_id = cv.id
             AND jo.status IN (\'pending\', \'rider_assign\', \'assigned\', \'in_transit\', \'in_progress\')
@@ -107,6 +112,7 @@ class FulfillOpenJobOrderCommand extends Command
             $warranty_class = $jo_row['warranty_class'];
             $rider_id = $jo_row['rider_id'];
             $str_date_schedule = $jo_row['date_schedule'];
+            $source = $jo_row['source'];
 
             $jo_ctr++;
 
@@ -116,6 +122,9 @@ class FulfillOpenJobOrderCommand extends Command
             // create JO event
             $jo_evt_data[] = $this->createJOEvent($conn, $jo_id, $str_current_date, $rider_id);
 
+            // send to drivehub if JO is third party
+            $this->sendJOStatus($jo_id, $source);
+
             // error_log($jo_ctr . ' Processing JO ' . $jo_id);
 
             // check service type
@@ -378,6 +387,20 @@ class FulfillOpenJobOrderCommand extends Command
         // TODO: delete file?
     }
 
+    protected function sendJOStatus($jo_id, $source)
+    {
+        // check if JO source is third party
+        if ($source == TransactionOrigin::THIRD_PARTY)
+        {
+            $jo_status_data = [
+                'id' => $jo_id,
+                'status_name' => JOStatus::FULFILLED,
+            ];
+
+            $this->dh_manager->sendJOStatusChange($jo_status_data);
+        }
+    }
+
     protected function getCustomerInfo($conn, $id)
     {
         $cust_info = [];
diff --git a/src/Command/FulfillPendingJobOrderCommand.php b/src/Command/FulfillPendingJobOrderCommand.php
index 1ff47e8e..d6492cb1 100644
--- a/src/Command/FulfillPendingJobOrderCommand.php
+++ b/src/Command/FulfillPendingJobOrderCommand.php
@@ -16,15 +16,19 @@ use App\Entity\User;
 use App\Ramcar\JOStatus;
 use App\Ramcar\JOEventType;
 
+use App\Service\DriveHubManager;
+
 use DateTime;
 
 class FulfillPendingJobOrderCommand extends Command
 {
     protected $em;
+    protected $dh_manager;
 
-    public function __construct(EntityManagerInterface $em)
+    public function __construct(EntityManagerInterface $em, DriveHubManager $dh_manager)
     {
         $this->em = $em;
+        $this->dh_manager = $dh_manager;
 
         parent::__construct();
     }
@@ -70,12 +74,23 @@ class FulfillPendingJobOrderCommand extends Command
             $jo->fulfill();
 
             // add event
-			$event = new JOEvent();
-			$event->setDateHappen(new DateTime())
-				->setTypeID(JOEventType::FULFILL)
-				->setUser($user)
-				->setJobOrder($jo);
-			$em->persist($event);
+            $event = new JOEvent();
+            $event->setDateHappen(new DateTime())
+                ->setTypeID(JOEventType::FULFILL)
+                ->setUser($user)
+                ->setJobOrder($jo);
+            $em->persist($event);
+
+            // check if JO source is third party
+            if ($jo->getSource() == TransactionOrigin::THIRD_PARTY)
+            {
+                $jo_status_data = [
+                    'id' => $jo->getID(),
+                    'status_name' => $jo->getStatus(),
+                ];
+
+                $this->dh_manager->sendJOStatusChange($jo_status_data);
+            }
         }
 
         $em->flush();
diff --git a/src/Command/UpdateUnacceptedJobOrdersCommand.php b/src/Command/UpdateUnacceptedJobOrdersCommand.php
index 2a9ba2c6..d5b5d8ee 100644
--- a/src/Command/UpdateUnacceptedJobOrdersCommand.php
+++ b/src/Command/UpdateUnacceptedJobOrdersCommand.php
@@ -10,6 +10,9 @@ use Symfony\Component\Console\Output\OutputInterface;
 use Doctrine\ORM\EntityManagerInterface;
 
 use App\Service\MQTTClient;
+use App\Service\DriveHubManager;
+
+use App\Ramcar\TransactionOrigin;
 
 use App\Entity\JobOrder;
 use App\Entity\Rider;
@@ -20,11 +23,13 @@ class UpdateUnacceptedJobOrdersCommand extends Command
 {
     protected $em;
     protected $mclient;
+    protected $dh_manager;
 
-    public function __construct(EntityManagerInterface $em, MQTTClient $mclient)
+    public function __construct(EntityManagerInterface $em, MQTTClient $mclient, DriveHubManager $dh_manager)
     {
         $this->em = $em;
         $this->mclient = $mclient;
+        $this->dh_manager = $dh_manager;
 
         parent::__construct();
     }
@@ -49,10 +54,11 @@ class UpdateUnacceptedJobOrdersCommand extends Command
         // pdo connection
         $db = $em->getConnection();
 
-        // since we need the actual job orders for mqtt events, we need to get the ids of the job orders
-        // that will be updated
-        // need rider id to set rider to available since rider becomes unavailable 
+        // since we need the actual job orders for mqtt events, we 
+        // (1) need to get the ids of the job orders that will be updated
+        // (2) need rider id to set rider to available since rider becomes unavailable 
         // the minute JO is assigned to rider
+        // (3) need to get the source of the JO to check if it's a third party JO
         $query_sql = 'SELECT id FROM job_order WHERE status = :current_status and TIMESTAMPDIFF(MINUTE, date_assign, NOW()) >= :timeout';
 
         $query_stmt = $db->prepare($query_sql);
@@ -109,6 +115,18 @@ class UpdateUnacceptedJobOrdersCommand extends Command
                 $mclient->sendEvent($jo, $payload);
             }
 
+            // check if JO source is third party
+            // use new_status since the jo that we have doesn't have the updated status
+            if ($jo->getSource() == TransactionOrigin::THIRD_PARTY)
+            {
+                $jo_status_data = [
+                    'id' => $jo->getID(),
+                    'status_name' => $new_status,
+                ];
+
+                $this->dh_manager->sendJOStatusChange($jo_status_data);
+            }
+
             $rider = $jo->getRider();
             if ($rider != null)
             {
diff --git a/src/Controller/CAPI/RiderAppController.php b/src/Controller/CAPI/RiderAppController.php
index 1a293058..4495f3c4 100644
--- a/src/Controller/CAPI/RiderAppController.php
+++ b/src/Controller/CAPI/RiderAppController.php
@@ -32,6 +32,7 @@ use App\Service\JobOrderHandlerInterface;
 use App\Service\InvoiceGeneratorInterface;
 use App\Service\RisingTideGateway;
 use App\Service\RiderTracker;
+use App\Service\DriveHubManager;
 
 use App\Ramcar\ServiceType;
 use App\Ramcar\TradeInType;
@@ -42,6 +43,7 @@ use App\Ramcar\ModeOfPayment;
 use App\Ramcar\InvoiceCriteria;
 use App\Ramcar\WarrantySource;
 use App\Ramcar\DeliveryStatus;
+use App\Ramcar\TransactionOrigin;
 
 use DateTime;
 
@@ -388,7 +390,7 @@ class RiderAppController extends APIController
 
     }
 
-    public function acceptJobOrder(Request $req, EntityManagerInterface $em)
+    public function acceptJobOrder(Request $req, EntityManagerInterface $em, DriveHubManager $dh_manager)
     {
         $required_params = ['jo_id'];
 
@@ -432,12 +434,23 @@ class RiderAppController extends APIController
 
         $em->flush();
 
+        // check if JO source is third party
+        if ($jo->getSource() == TransactionOrigin::THIRD_PARTY)
+        {
+            $jo_status_data = [
+                'id' => $jo->getID(),
+                'status_name' => $jo->getStatus(),
+            ];
+
+            $dh_manager->sendJOStatusChange($jo_status_data);
+        }
+
         $data = [];
         return new APIResponse(true, 'Job order accepted.', $data);
 
     }
 
-    public function cancelJobOrder(Request $req, EntityManagerInterface $em, MQTTClient $mclient)
+    public function cancelJobOrder(Request $req, EntityManagerInterface $em, MQTTClient $mclient, DriveHubManager $dh_manager)
     {
         $required_params = ['jo_id'];
 
@@ -483,6 +496,17 @@ class RiderAppController extends APIController
         ];
         $mclient->sendEvent($jo, $payload);
 
+        // check if JO source is third party
+        if ($jo->getSource() == TransactionOrigin::THIRD_PARTY)
+        {
+            $jo_status_data = [
+                'id' => $jo->getID(),
+                'status_name' => $jo->getStatus(),
+            ];
+
+            $dh_manager->sendJOStatusChange($jo_status_data);
+        }
+
         $data = [];
         return new APIResponse(true, 'Job order requeued.', $data);
     }
@@ -648,7 +672,7 @@ class RiderAppController extends APIController
 
     }
 
-    public function arrive(Request $req, EntityManagerInterface $em, MQTTClient $mclient)
+    public function arrive(Request $req, EntityManagerInterface $em, MQTTClient $mclient, DriveHubManager $dh_manager)
     {
         $required_params = ['jo_id'];
 
@@ -698,6 +722,17 @@ class RiderAppController extends APIController
         ];
         $mclient->sendEvent($jo, $payload);
 
+        // check if JO source is third party
+        if ($jo->getSource() == TransactionOrigin::THIRD_PARTY)
+        {
+            $jo_status_data = [
+                'id' => $jo->getID(),
+                'status_name' => $jo->getStatus(),
+            ];
+
+            $dh_manager->sendJOStatusChange($jo_status_data);
+        }
+
         $data = [];
         return new APIResponse(true, 'Rider arrived at customer location.', $data);
     }
@@ -749,7 +784,8 @@ class RiderAppController extends APIController
     }
 
     public function payment(Request $req, EntityManagerInterface $em, JobOrderHandlerInterface $jo_handler,
-                            RisingTideGateway $rt, WarrantyHandler $wh, MQTTClient $mclient, TranslatorInterface $translator)
+                            RisingTideGateway $rt, WarrantyHandler $wh, MQTTClient $mclient, TranslatorInterface $translator,
+                            DriveHubManager $dh_manager)
     {
         $required_params = ['jo_id'];
 
@@ -871,6 +907,17 @@ class RiderAppController extends APIController
         ];
         $mclient->sendEvent($jo, $payload);
 
+        // check if JO source is third party
+        if ($jo->getSource() == TransactionOrigin::THIRD_PARTY)
+        {
+            $jo_status_data = [
+                'id' => $jo->getID(),
+                'status_name' => $jo->getStatus(),
+            ];
+
+            $dh_manager->sendJOStatusChange($jo_status_data);
+        }
+
         $data = [];
         return new APIResponse(true, 'Job order paid and fulfilled.', $data);
     }
diff --git a/src/Service/DriveHubManager.php b/src/Service/DriveHubManager.php
new file mode 100644
index 00000000..c639a0cf
--- /dev/null
+++ b/src/Service/DriveHubManager.php
@@ -0,0 +1,50 @@
+<?php
+
+namespace App\Service;
+
+use Doctrine\ORM\EntityManagerInterface;
+
+class DriveHubManager
+{
+    protected $em;
+    protected $callback_url;
+
+    public function __construct(EntityManagerInterface $em, $callback_url)
+    {
+        $this->em = $em;
+        $this->callback_url = $callback_url;
+    }
+
+    public function sendJOStatusChange($jo_data)
+    {
+        // jo_info = [
+        //     'id' => jo_id,
+        //     'status_id' => jo status id,  --> for resq2
+        //     'status_name' => jo status name,
+        // ]
+
+        $body = json_encode($jo_data);
+
+        // send status back to callback url as POST in json format
+
+        $curl = curl_init();
+
+        $options = [
+            CURLOPT_URL => $this->callback_url,
+            CURLOPT_POST => true,
+            CURLOPT_RETURNTRANSFER => true,
+            CURLOPT_POSTFIELDS => $body,
+            CURLOPT_HTTPHEADER => [
+                'Content-Type: application/json',
+            ],
+        ];
+
+        curl_setopt_array($curl, $options);
+        $res = curl_exec($curl);
+
+        curl_close($curl);
+
+        // check result
+        // error_log('Result '  . $res);
+    }
+}
diff --git a/src/Service/JobOrderHandler/ResqJobOrderHandler.php b/src/Service/JobOrderHandler/ResqJobOrderHandler.php
index 5f88b057..4aa3ba70 100644
--- a/src/Service/JobOrderHandler/ResqJobOrderHandler.php
+++ b/src/Service/JobOrderHandler/ResqJobOrderHandler.php
@@ -64,6 +64,7 @@ use App\Service\PromoLogger;
 use App\Service\HubSelector;
 use App\Service\HubDistributor;
 use App\Service\HubFilteringGeoChecker;
+use App\Service\DriveHubManager;
 
 use CrEOF\Spatial\PHP\Types\Geometry\Point;
 
@@ -90,6 +91,7 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
     protected $hub_geofence;
     protected $cust_distance_limit;
     protected $hub_filter_enable;
+    protected $dh_manager;
 
     protected $template_hash;
 
@@ -98,7 +100,7 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
                                 TranslatorInterface $translator, RiderAssignmentHandlerInterface $rah, 
                                 string $country_code, WarrantyHandler $wh, RisingTideGateway $rt,
                                 PromoLogger $promo_logger, HubDistributor $hub_dist, HubFilteringGeoChecker $hub_geofence,
-                                string $cust_distance_limit, string $hub_filter_enabled)
+                                string $cust_distance_limit, string $hub_filter_enabled, DriveHubManager $dh_manager)
     {
         $this->em = $em;
         $this->ic = $ic;
@@ -114,6 +116,7 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
         $this->hub_geofence = $hub_geofence;
         $this->cust_distance_limit = $cust_distance_limit;
         $this->hub_filter_enabled = $hub_filter_enabled;
+        $this->dh_manager = $dh_manager;
 
         $this->loadTemplates();
     }
@@ -984,6 +987,17 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
 
             // update redis hub jo count
             $this->hub_dist->incrementJoCountForHub($hub);
+
+            // check if JO source is third party
+            if ($obj->getSource() == TransactionOrigin::THIRD_PARTY)
+            {
+                $jo_status_data = [
+                    'id' => $obj->getID(),
+                    'status_name' => $obj->getStatus(),
+                ];
+
+                $this->dh_manager->sendJOStatusChange($jo_status_data);
+            }
         }
 
         return $error_array;
@@ -1140,6 +1154,18 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
 
             // call rider assignment handler's assignJobOrder
             $this->rah->assignJobOrder($obj, $rider);
+
+            // check if JO source is third party
+            if ($obj->getSource() == TransactionOrigin::THIRD_PARTY)
+            {
+                $jo_status_data = [
+                    'id' => $obj->getID(),
+                    'status_name' => $obj->getStatus(),
+                ];
+
+                $this->dh_manager->sendJOStatusChange($jo_status_data);
+            }
+
         }
 
         return $error_array;
@@ -1331,6 +1357,18 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
             $phone_number = $this->country_code . $obj->getCustomer()->getPhoneMobile();
             if (!empty($phone_number))
                 $this->sendSMSToCustomer($phone_number);
+
+            // check if JO source is third party
+            if ($obj->getSource() == TransactionOrigin::THIRD_PARTY)
+            {
+                $jo_status_data = [
+                    'id' => $obj->getID(),
+                    'status_name' => $obj->getStatus(),
+                ];
+
+                $this->dh_manager->sendJOStatusChange($jo_status_data);
+            }
+
         }
 
         return $error_array;
@@ -1382,6 +1420,18 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
         ];
         $mclient->sendEvent($obj, $payload);
         $mclient->sendRiderEvent($obj, $payload);
+
+        // check if JO source is third party
+        if ($obj->getSource() == TransactionOrigin::THIRD_PARTY)
+        {
+            $jo_status_data = [
+                'id' => $obj->getID(),
+                'status_name' => $obj->getStatus(),
+            ];
+
+            $this->dh_manager->sendJOStatusChange($jo_status_data);
+        }
+
     }
 
     // set hub for job order
@@ -1465,8 +1515,13 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
         // get previously assigned rider, if any
         $old_rider = $obj->getRider();
 
+        // get previous JO status, if any
+        // this will be used for third party JOs. If new JO status is same as old JO status,
+        // we don't tell drive hub.
+        $old_jo_status = $obj->getStatus();
+
         if (empty($error_array))
-                {
+        {
             // rider mqtt event
             // NOTE: need to send this before saving because rider will be cleared
             $rider_payload = [
@@ -1566,6 +1621,22 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
                 $this->hub_dist->decrementJoCountForHub($old_hub);
             if ($hub != null)
                 $this->hub_dist->incrementJoCountForHub($hub);
+
+            // check if JO source is third party
+            if ($obj->getSource() == TransactionOrigin::THIRD_PARTY)
+            {
+                // check if the new status is the same as the old status
+                // if yes, we don't tell drive hub, otherwise, we send
+                if ($old_jo_status != $obj->getStatus())
+                {
+                    $jo_status_data = [
+                        'id' => $obj->getID(),
+                        'status_name' => $obj->getStatus(),
+                    ];
+
+                    $this->dh_manager->sendJOStatusChange($jo_status_data);
+                }
+            }
         }
 
         return $error_array;
@@ -1739,6 +1810,11 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
         $ownertype_id = $req->request->get('ownership_type', 0);
         $owner_type = $em->getRepository(OwnershipType::class)->find($ownertype_id);
 
+        // get previous JO status, if any
+        // this will be used for third party JOs. If new JO status is same as old JO status,
+        // we don't tell drive hub.
+        $old_jo_status = $obj->getStatus();
+
         if (empty($error_array)) {
             // rider mqtt event
             // NOTE: need to send this before saving because rider will be cleared
@@ -1840,6 +1916,22 @@ class ResqJobOrderHandler implements JobOrderHandlerInterface
             ];
             $mclient->sendEvent($obj, $payload);
             $mclient->sendRiderEvent($obj, $payload);
+
+            // check if JO source is third party
+            if ($obj->getSource() == TransactionOrigin::THIRD_PARTY)
+            {
+                // check if the new status is the same as the old status
+                // if yes, we don't tell drive hub, otherwise, we send
+                if ($old_jo_status != $obj->getStatus())
+                {
+                    $jo_status_data = [
+                        'id' => $obj->getID(),
+                        'status_name' => $obj->getStatus(),
+                    ];
+                    
+                    $this->dh_manager->sendJOStatusChange($jo_status_data);
+                }
+            }
         }
 
         return $error_array;