diff --git a/android/app/src/main/java/com/vernu/sms/receivers/SMSBroadcastReceiver.java b/android/app/src/main/java/com/vernu/sms/receivers/SMSBroadcastReceiver.java
new file mode 100644
index 0000000..24cc63a
--- /dev/null
+++ b/android/app/src/main/java/com/vernu/sms/receivers/SMSBroadcastReceiver.java
@@ -0,0 +1,99 @@
+package com.vernu.sms.receivers;
+
+import android.content.BroadcastReceiver;
+import android.content.Context;
+import android.content.Intent;
+import android.provider.Telephony;
+import android.telephony.SmsMessage;
+import android.util.Log;
+import com.vernu.sms.ApiManager;
+import com.vernu.sms.AppConstants;
+import com.vernu.sms.database.local.AppDatabase;
+import com.vernu.sms.database.local.SMS;
+import com.vernu.sms.dtos.SMSDTO;
+import com.vernu.sms.dtos.SMSForwardResponseDTO;
+import com.vernu.sms.helpers.SharedPreferenceHelper;
+
+import java.util.Date;
+import java.util.Objects;
+import java.util.concurrent.Executors;
+
+import retrofit2.Call;
+import retrofit2.Response;
+
+public class SMSBroadcastReceiver extends BroadcastReceiver {
+    private static final String TAG = "SMSBroadcastReceiver";
+
+    @Override
+    public void onReceive(Context context, Intent intent) {
+        Log.d(TAG, "onReceive: " + intent.getAction());
+
+        if (!Objects.equals(intent.getAction(), Telephony.Sms.Intents.SMS_RECEIVED_ACTION)) {
+            Log.d(TAG, "Not Valid intent");
+            return;
+        }
+
+        SmsMessage[] messages = Telephony.Sms.Intents.getMessagesFromIntent(intent);
+        if (messages == null) {
+            Log.d(TAG, "No messages found");
+            return;
+        }
+
+        String deviceId = SharedPreferenceHelper.getSharedPreferenceString(context, AppConstants.SHARED_PREFS_DEVICE_ID_KEY, "");
+        String apiKey = SharedPreferenceHelper.getSharedPreferenceString(context, AppConstants.SHARED_PREFS_API_KEY_KEY, "");
+        boolean receiveSMSEnabled = SharedPreferenceHelper.getSharedPreferenceBoolean(context, AppConstants.SHARED_PREFS_RECEIVE_SMS_ENABLED_KEY, false);
+
+        if (deviceId.isEmpty() || apiKey.isEmpty() || !receiveSMSEnabled) {
+            Log.d(TAG, "Device ID or API Key is empty or Receive SMS Feature is disabled");
+            return;
+        }
+
+        SMS localReceivedSMS = new SMS();
+        localReceivedSMS.setType("RECEIVED");
+        for (SmsMessage message : messages) {
+            localReceivedSMS.setMessage(localReceivedSMS.getMessage() + message.getMessageBody());
+            localReceivedSMS.setSender(message.getOriginatingAddress());
+            localReceivedSMS.setReceivedAt(new Date(message.getTimestampMillis()));
+        }
+
+        SMSDTO receivedSMSDTO = new SMSDTO();
+        receivedSMSDTO.setSender(localReceivedSMS.getSender());
+        receivedSMSDTO.setMessage(localReceivedSMS.getMessage());
+        receivedSMSDTO.setReceivedAt(localReceivedSMS.getReceivedAt());
+
+        Call<SMSForwardResponseDTO> apiCall = ApiManager.getApiService().sendReceivedSMS(deviceId, apiKey, receivedSMSDTO);
+        apiCall.enqueue(new retrofit2.Callback<SMSForwardResponseDTO>() {
+            @Override
+            public void onResponse(Call<SMSForwardResponseDTO> call, Response<SMSForwardResponseDTO> response) {
+                Date now = new Date();
+                if (response.isSuccessful()) {
+                    Log.d(TAG, "SMS sent to server successfully");
+                    localReceivedSMS.setLastAcknowledgedRequestAt(now);
+                    localReceivedSMS.setServerAcknowledgedAt(now);
+                    updateLocalReceivedSMS(localReceivedSMS, context);
+                } else {
+                    Log.e(TAG, "Failed to send SMS to server");
+                    localReceivedSMS.setServerAcknowledgedAt(null);
+                    localReceivedSMS.setLastAcknowledgedRequestAt(now);
+                    // localReceivedSMS.setRetryCount(localReceivedSMS.getRetryCount() + 1);
+                    updateLocalReceivedSMS(localReceivedSMS, context);
+                }
+            }
+            @Override
+            public void onFailure(Call<SMSForwardResponseDTO> call, Throwable t) {
+                Log.e(TAG, "Failed to send SMS to server", t);
+                localReceivedSMS.setServerAcknowledgedAt(null);
+                localReceivedSMS.setLastAcknowledgedRequestAt(new Date());
+                updateLocalReceivedSMS(localReceivedSMS, context);
+            }
+        });
+    }
+
+    private void updateLocalReceivedSMS(SMS localReceivedSMS, Context context) {
+        Executors.newSingleThreadExecutor().execute(() -> {
+            AppDatabase appDatabase = AppDatabase.getInstance(context);
+            appDatabase.localReceivedSMSDao().insertAll(localReceivedSMS);
+        });
+
+    }
+}
\ No newline at end of file