diff --git a/AbandonedCart/Model/AbandonedCartSendData.php b/AbandonedCart/Model/AbandonedCartSendData.php
index 945b7f5..38d49bc 100644
--- a/AbandonedCart/Model/AbandonedCartSendData.php
+++ b/AbandonedCart/Model/AbandonedCartSendData.php
@@ -226,7 +226,8 @@ public function sendAbandonedCartData($quoteId = null): array
             $abandonedCarts->addFieldToFilter('entity_id', ['eq' => $quoteId]);
         }
         $abandonedCarts->setPageSize($numberOfAbandonedCart);
-
+        $abandonedCarts->getSelect()->join(array('address' => $abandonedCarts->getResource()->getTable('quote_address')),'main_table.entity_id = address.quote_id')
+            ->where("address.address_type='billing' and (main_table.customer_email is not null or  address.email is not null)");
         foreach ($abandonedCarts as $abandonedCart) {
             $connectionId = $this->coreHelper->getConnectionId($abandonedCart->getStoreId());