diff --git a/server/accounting/pbs/pbs-job-export.js b/server/accounting/pbs/pbs-job-export.js
index 136203b89..b5b5fadcd 100644
--- a/server/accounting/pbs/pbs-job-export.js
+++ b/server/accounting/pbs/pbs-job-export.js
@@ -543,10 +543,10 @@ async function GetVehicleData(socket, ownerRef) {
     if (Vehicles.length === 1) {
       return Vehicles[0];
     } else {
-      CdkBase.createLogEvent(socket, "ERROR", `Error in Getting Vehicle Data - ${Vehicles.length} vehicle(s) found`);
+      WsLogger.createLogEvent(socket, "ERROR", `Error in Getting Vehicle Data - ${Vehicles.length} vehicle(s) found`);
     }
   } catch (error) {
-    CdkBase.createLogEvent(socket, "ERROR", `Error in UpsertVehicleData - ${error}`);
+    WsLogger.createLogEvent(socket, "ERROR", `Error in UpsertVehicleData - ${error}`);
     throw new Error(error);
   }
 }
@@ -709,7 +709,7 @@ async function CreateRepairOrderInPBS(socket) {
     if (RepairOrders.length === 0) {
       const InsertedRepairOrder = await RepairOrderChange(socket);
       socket.InsertedRepairOrder = InsertedRepairOrder;
-      CdkBase.createLogEvent(socket, "INFO", `No repair orders found for vehicle. Inserting record.`);
+      WsLogger.createLogEvent(socket, "INFO", `No repair orders found for vehicle. Inserting record.`);
     } else if (RepairOrders.length > 0) {
       //Find out if it's a matching RO.
       //This logic is used because the integration will simply add another line to an open RO if it exists.
@@ -717,11 +717,11 @@ async function CreateRepairOrderInPBS(socket) {
         ro.Memo?.toLowerCase()?.includes(socket.JobData.ro_number.toLowerCase())
       );
       if (!matchingRo) {
-        CdkBase.createLogEvent(socket, "INFO", `ROs found for vehicle, but none match. Inserting record.`);
+        WsLogger.createLogEvent(socket, "INFO", `ROs found for vehicle, but none match. Inserting record.`);
         const InsertedRepairOrder = await RepairOrderChange(socket);
         socket.InsertedRepairOrder = InsertedRepairOrder;
       } else {
-        CdkBase.createLogEvent(
+        WsLogger.createLogEvent(
           socket,
           "WARN",
           `Repair order appears to already exist in PBS. ${matchingRo.RepairOrderNumber}`
@@ -729,7 +729,7 @@ async function CreateRepairOrderInPBS(socket) {
       }
     }
   } catch (error) {
-    CdkBase.createLogEvent(socket, "ERROR", `Error in CreateRepairOrderInPBS - ${error} - ${JSON.stringify(error)}`);
+    WsLogger.createLogEvent(socket, "ERROR", `Error in CreateRepairOrderInPBS - ${error} - ${JSON.stringify(error)}`);
   }
 }
 
@@ -761,7 +761,7 @@ async function RepairOrderGet(socket) {
     CheckForErrors(socket, RepairOrderGet);
     return RepairOrderGet;
   } catch (error) {
-    CdkBase.createLogEvent(socket, "ERROR", `Error in RepairOrderChange - ${error}`);
+    WsLogger.createLogEvent(socket, "ERROR", `Error in RepairOrderChange - ${error}`);
     throw new Error(error);
   }
 }
@@ -856,7 +856,7 @@ async function RepairOrderChange(socket) {
     CheckForErrors(socket, RepairOrderChangeResponse);
     return RepairOrderChangeResponse;
   } catch (error) {
-    CdkBase.createLogEvent(socket, "ERROR", `Error in RepairOrderChange - ${error}`);
+    WsLogger.createLogEvent(socket, "ERROR", `Error in RepairOrderChange - ${error}`);
     throw new Error(error);
   }
 }