diff --git a/example/Dev.tsx b/example/Dev.tsx
index da0db6a4..4d8da97b 100644
--- a/example/Dev.tsx
+++ b/example/Dev.tsx
@@ -259,153 +259,156 @@ const Dev = (): ReactElement => {
 						}}
 					/>
 
-					<Button
-						title={'Add Peers'}
-						onPress={async (): Promise<void> => {
-							try {
-								const peersRes = await Promise.all(
-									Object.keys(peers).map(async (peer) => {
-										const addPeer = await lm.addPeer({
-											...peers[peer],
-											timeout: 5000,
-										});
-										if (addPeer.isErr()) {
-											setMessage(addPeer.error.message);
-											return;
-										}
-										return addPeer.value;
-									}),
-								);
-								setMessage(JSON.stringify(peersRes));
-							} catch (e) {
-								setMessage(e.toString());
-							}
-						}}
-					/>
-
-					<Button
-						title={'List peers'}
-						onPress={async (): Promise<void> => {
-							try {
-								const listPeers = await ldk.listPeers();
-								if (listPeers.isErr()) {
-									setMessage(listPeers.error.message);
-									return;
-								}
-								setMessage(JSON.stringify(listPeers.value));
-							} catch (e) {
-								setMessage(e.toString());
-							}
-						}}
-					/>
-
-					<Button
-						title={'List channels'}
-						onPress={async (): Promise<void> => {
-							try {
-								const listChannels = await ldk.listChannels();
-								if (listChannels.isErr()) {
-									setMessage(listChannels.error.message);
-									return;
+					<View style={styles.buttonRow}>
+						<Button
+							title={'Add Peers'}
+							onPress={async (): Promise<void> => {
+								try {
+									const peersRes = await Promise.all(
+										Object.keys(peers).map(async (peer) => {
+											const addPeer = await lm.addPeer({
+												...peers[peer],
+												timeout: 5000,
+											});
+											if (addPeer.isErr()) {
+												setMessage(addPeer.error.message);
+												return;
+											}
+											return addPeer.value;
+										}),
+									);
+									setMessage(JSON.stringify(peersRes));
+								} catch (e) {
+									setMessage(e.toString());
 								}
-								if (listChannels.value.length < 1) {
-									setMessage('No channels detected.');
-									return;
+							}}
+						/>
+						<Button
+							title={'List peers'}
+							onPress={async (): Promise<void> => {
+								try {
+									const listPeers = await ldk.listPeers();
+									if (listPeers.isErr()) {
+										setMessage(listPeers.error.message);
+										return;
+									}
+									setMessage(JSON.stringify(listPeers.value));
+								} catch (e) {
+									setMessage(e.toString());
 								}
+							}}
+						/>
+					</View>
 
-								let msg = '';
-								// Sort Channels
-								await Promise.all(
-									listChannels.value.map(async (channel) => {
-										const sorted = Object.keys(channel)
-											.sort()
-											.reduce((obj, key) => {
-												obj[key] = channel[key];
-												return obj;
-											}, {});
-										// Append channel info to msg.
-										await Promise.all(
-											Object.keys(sorted).map((key) => {
-												msg += `${key}: ${sorted[key]}\n`;
-											}),
-										);
-									}),
-								);
-
-								setMessage(msg);
-							} catch (e) {
-								setMessage(e.toString());
-							}
-						}}
-					/>
+					<View style={styles.buttonRow}>
+						<Button
+							title={'List channels'}
+							onPress={async (): Promise<void> => {
+								try {
+									const listChannels = await ldk.listChannels();
+									if (listChannels.isErr()) {
+										setMessage(listChannels.error.message);
+										return;
+									}
+									if (listChannels.value.length < 1) {
+										setMessage('No channels detected.');
+										return;
+									}
 
-					<Button
-						title={'Close channel'}
-						onPress={async (): Promise<void> => {
-							try {
-								const listChannels = await ldk.listChannels();
-								if (listChannels.isErr()) {
-									setMessage(listChannels.error.message);
-									return;
-								}
-								if (listChannels.value.length < 1) {
-									setMessage('No channels detected.');
-									return;
+									let msg = '';
+									// Sort Channels
+									await Promise.all(
+										listChannels.value.map(async (channel) => {
+											const sorted = Object.keys(channel)
+												.sort()
+												.reduce((obj, key) => {
+													obj[key] = channel[key];
+													return obj;
+												}, {});
+											// Append channel info to msg.
+											await Promise.all(
+												Object.keys(sorted).map((key) => {
+													msg += `${key}: ${sorted[key]}\n`;
+												}),
+											);
+										}),
+									);
+
+									setMessage(msg);
+								} catch (e) {
+									setMessage(e.toString());
 								}
-
-								const { channel_id, counterparty_node_id } =
-									listChannels.value[0];
-
-								const close = async (force: boolean): Promise<void> => {
-									setMessage(`Closing ${channel_id}...`);
-
-									const res = await ldk.closeChannel({
-										channelId: channel_id,
-										counterPartyNodeId: counterparty_node_id,
-										force,
-									});
-									if (res.isErr()) {
-										setMessage(res.error.message);
+							}}
+						/>
+						<Button
+							title={'Close channel'}
+							onPress={async (): Promise<void> => {
+								try {
+									const listChannels = await ldk.listChannels();
+									if (listChannels.isErr()) {
+										setMessage(listChannels.error.message);
+										return;
+									}
+									if (listChannels.value.length < 1) {
+										setMessage('No channels detected.');
 										return;
 									}
-									setMessage(res.value);
-								};
 
-								Alert.alert('Close channel', `Peer ${counterparty_node_id}`, [
-									{
-										text: 'Cancel',
-										onPress: () => console.log('Cancel Pressed'),
-										style: 'cancel',
-									},
-									{
-										text: 'Close channel',
-										onPress: async (): Promise<void> => close(false),
-									},
-									{
-										text: 'Force close',
-										onPress: async (): Promise<void> => close(true),
-									},
-								]);
-							} catch (e) {
-								setMessage(e.toString());
-							}
-						}}
-					/>
+									const { channel_id, counterparty_node_id } =
+										listChannels.value[0];
 
-					<Button
-						title={'List watch transactions'}
-						onPress={async (): Promise<void> => {
-							console.log(lm.watchTxs);
-							setMessage(`Watch TXs: ${JSON.stringify(lm.watchTxs)}`);
-						}}
-					/>
+									const close = async (force: boolean): Promise<void> => {
+										setMessage(`Closing ${channel_id}...`);
 
-					<Button
-						title={'List watch outputs'}
-						onPress={async (): Promise<void> => {
-							setMessage(`Watch Outputs: ${JSON.stringify(lm.watchOutputs)}`);
-						}}
-					/>
+										const res = await ldk.closeChannel({
+											channelId: channel_id,
+											counterPartyNodeId: counterparty_node_id,
+											force,
+										});
+										if (res.isErr()) {
+											setMessage(res.error.message);
+											return;
+										}
+										setMessage(res.value);
+									};
+
+									Alert.alert('Close channel', `Peer ${counterparty_node_id}`, [
+										{
+											text: 'Cancel',
+											onPress: () => console.log('Cancel Pressed'),
+											style: 'cancel',
+										},
+										{
+											text: 'Close channel',
+											onPress: async (): Promise<void> => close(false),
+										},
+										{
+											text: 'Force close',
+											onPress: async (): Promise<void> => close(true),
+										},
+									]);
+								} catch (e) {
+									setMessage(e.toString());
+								}
+							}}
+						/>
+					</View>
+
+					<View style={styles.buttonRow}>
+						<Button
+							title={'List watch transactions'}
+							onPress={async (): Promise<void> => {
+								console.log(lm.watchTxs);
+								setMessage(`Watch TXs: ${JSON.stringify(lm.watchTxs)}`);
+							}}
+						/>
+						<Button
+							title={'List watch outputs'}
+							onPress={async (): Promise<void> => {
+								setMessage(`Watch Outputs: ${JSON.stringify(lm.watchOutputs)}`);
+							}}
+						/>
+					</View>
 
 					<Button
 						title={'🤑Get Address Balance'}
@@ -433,112 +436,118 @@ const Dev = (): ReactElement => {
 						}}
 					/>
 
-					<Button
-						title={'Get claimed payments'}
-						onPress={async (): Promise<void> => {
-							setMessage('Getting all claimed payments...');
-							const res = await lm.getLdkPaymentsClaimed();
-							setMessage(JSON.stringify(res));
-						}}
-					/>
-					<Button
-						title={'Get sent payments'}
-						onPress={async (): Promise<void> => {
-							setMessage('Getting all sent payments...');
-							const res = await lm.getLdkPaymentsSent();
-							setMessage(JSON.stringify(res));
-						}}
-					/>
-
-					<Button
-						title={'Create invoice'}
-						onPress={async (): Promise<void> => {
-							const createInvoice = async (
-								amountSats?: number,
-							): Promise<void> => {
-								try {
-									const createPaymentRequest =
-										await lm.createAndStorePaymentRequest({
-											amountSats,
-											description: 'paymeplz 🤑',
-											expiryDeltaSeconds: 999999,
-										});
-
-									if (createPaymentRequest.isErr()) {
-										setMessage(createPaymentRequest.error.message);
-										return;
-									}
+					<View style={styles.buttonRow}>
+						<Button
+							title={'Get claimed payments'}
+							onPress={async (): Promise<void> => {
+								setMessage('Getting all claimed payments...');
+								const res = await lm.getLdkPaymentsClaimed();
+								setMessage(JSON.stringify(res));
+							}}
+						/>
+						<Button
+							title={'Get sent payments'}
+							onPress={async (): Promise<void> => {
+								setMessage('Getting all sent payments...');
+								const res = await lm.getLdkPaymentsSent();
+								setMessage(JSON.stringify(res));
+							}}
+						/>
+					</View>
 
-									const { to_str } = createPaymentRequest.value;
-									console.log(to_str);
-									Clipboard.setString(to_str);
-									setMessage(to_str);
-								} catch (e) {
-									setMessage(e.toString());
-								}
-							};
-
-							const amountSats = 100;
-							Alert.alert('Create invoice', 'Specify amount?', [
-								{
-									text: 'Cancel',
-									onPress: () => console.log('Cancel Pressed'),
-									style: 'cancel',
-								},
-								{
-									text: `${amountSats} sats`,
-									onPress: async (): Promise<void> => createInvoice(amountSats),
-								},
-								{
-									text: "Don't specify",
-									onPress: async (): Promise<void> => createInvoice(),
-								},
-							]);
-						}}
-					/>
+					<View style={styles.buttonRow}>
+						<Button
+							title={'Create invoice'}
+							onPress={async (): Promise<void> => {
+								const createInvoice = async (
+									amountSats?: number,
+								): Promise<void> => {
+									try {
+										const createPaymentRequest =
+											await lm.createAndStorePaymentRequest({
+												amountSats,
+												description: 'paymeplz 🤑',
+												expiryDeltaSeconds: 999999,
+											});
 
-					<Button
-						title={'Pay invoice'}
-						onPress={async (): Promise<void> => {
-							const paymentRequest = await Clipboard.getString();
-							const decode = await ldk.decode({ paymentRequest });
-							if (decode.isErr()) {
-								return setMessage(decode.error.message);
-							}
+										if (createPaymentRequest.isErr()) {
+											setMessage(createPaymentRequest.error.message);
+											return;
+										}
 
-							const { amount_satoshis, description } = decode.value;
+										const { to_str } = createPaymentRequest.value;
+										console.log(to_str);
+										Clipboard.setString(to_str);
+										setMessage(to_str);
+									} catch (e) {
+										setMessage(e.toString());
+									}
+								};
 
-							const ownAmountSats = 1000;
-							Alert.alert(
-								amount_satoshis
-									? `Pay ${amount_satoshis ?? 0}`
-									: 'Zero sat invoice found',
-								description,
-								[
+								const amountSats = 100;
+								Alert.alert('Create invoice', 'Specify amount?', [
 									{
 										text: 'Cancel',
 										onPress: () => console.log('Cancel Pressed'),
 										style: 'cancel',
 									},
 									{
-										text: 'Pay',
-										onPress: async (): Promise<void> => {
-											const pay = await lm.payWithTimeout({
-												paymentRequest,
-												amountSats: amount_satoshis ? undefined : ownAmountSats,
-												timeout: 20000,
-											});
-											if (pay.isErr()) {
-												return setMessage(pay.error.message);
-											}
+										text: `${amountSats} sats`,
+										onPress: async (): Promise<void> =>
+											createInvoice(amountSats),
+									},
+									{
+										text: "Don't specify",
+										onPress: async (): Promise<void> => createInvoice(),
+									},
+								]);
+							}}
+						/>
+						<Button
+							title={'Pay invoice'}
+							onPress={async (): Promise<void> => {
+								const paymentRequest = await Clipboard.getString();
+								const decode = await ldk.decode({ paymentRequest });
+								if (decode.isErr()) {
+									return setMessage(decode.error.message);
+								}
 
-											setMessage(pay.value.payment_id);
+								const { amount_satoshis, description } = decode.value;
+
+								const ownAmountSats = 1000;
+								Alert.alert(
+									amount_satoshis
+										? `Pay ${amount_satoshis ?? 0}`
+										: 'Zero sat invoice found',
+									description,
+									[
+										{
+											text: 'Cancel',
+											onPress: () => console.log('Cancel Pressed'),
+											style: 'cancel',
 										},
-									},
-								],
-							);
-						}}
-					/>
+										{
+											text: 'Pay',
+											onPress: async (): Promise<void> => {
+												const pay = await lm.payWithTimeout({
+													paymentRequest,
+													amountSats: amount_satoshis
+														? undefined
+														: ownAmountSats,
+													timeout: 20000,
+												});
+												if (pay.isErr()) {
+													return setMessage(pay.error.message);
+												}
+
+												setMessage(pay.value.payment_id);
+											},
+										},
+									],
+								);
+							}}
+						/>
+					</View>
 
 					<Button
 						title={'Get network graph nodes'}
@@ -773,6 +782,10 @@ const styles = StyleSheet.create({
 		color: 'green',
 		fontSize: 10,
 	},
+	buttonRow: {
+		flexDirection: 'row',
+		gap: 2.5,
+	},
 });
 
 export default Dev;
diff --git a/example/index.js b/example/index.js
index 9b739329..d4145fbc 100644
--- a/example/index.js
+++ b/example/index.js
@@ -2,6 +2,8 @@
  * @format
  */
 
+import './utils/ignoreLogs';
+
 import { AppRegistry } from 'react-native';
 import App from './App';
 import { name as appName } from './app.json';
diff --git a/example/utils/ignoreLogs.ts b/example/utils/ignoreLogs.ts
new file mode 100644
index 00000000..0094c6f6
--- /dev/null
+++ b/example/utils/ignoreLogs.ts
@@ -0,0 +1,49 @@
+import { LogBox } from 'react-native';
+
+const ENABLE_LOGBOX = true;
+const ENABLE_LDK_LOGS = true;
+const ENABLE_TX_LOGS = true;
+
+if (__DEV__) {
+	const ignoredLogs: string[] = [];
+	const ignoredInfo: string[] = [];
+	const ignoredWarnings: string[] = [];
+	const ignoredErrors: string[] = [];
+
+	if (!ENABLE_LOGBOX) {
+		LogBox.ignoreAllLogs();
+	}
+
+	if (!ENABLE_LDK_LOGS) {
+		ignoredLogs.push('LDK:', 'react-native-ldk:', 'DEBUG (JS)', 'ERROR (JS)');
+	}
+
+	if (!ENABLE_TX_LOGS) {
+		ignoredLogs.push('INFO (JS)', 'broadcastTransaction');
+	}
+
+	const withoutIgnored = (
+		logger: (...data: any[]) => void,
+		ignoreList: string[],
+	): any => {
+		return (...args): void => {
+			let output: string;
+			try {
+				output = args.join(' ');
+			} catch (err) {
+				// if we can't check if the log should be ignored, just log it
+				logger(...args);
+				return;
+			}
+
+			if (!ignoreList.some((log) => output.includes(log))) {
+				logger(...args);
+			}
+		};
+	};
+
+	console.log = withoutIgnored(console.log, ignoredLogs);
+	console.info = withoutIgnored(console.info, ignoredInfo);
+	console.warn = withoutIgnored(console.warn, ignoredWarnings);
+	console.error = withoutIgnored(console.error, ignoredErrors);
+}
diff --git a/lib/src/lightning-manager.ts b/lib/src/lightning-manager.ts
index fc8a1f7b..05aa727c 100644
--- a/lib/src/lightning-manager.ts
+++ b/lib/src/lightning-manager.ts
@@ -69,6 +69,8 @@ import * as bitcoin from 'bitcoinjs-lib';
 import networks from './utils/networks';
 import { EmitterSubscription } from 'react-native';
 
+const MAX_PENDING_PAY_AGE = 1000 * 60 * 60; // 1 hour
+
 //TODO startup steps
 // Step 0: Listen for events ✅
 // Step 1: Initialize the FeeEstimator ✅
@@ -486,6 +488,8 @@ class LightningManager {
 
 		//Can continue in the background
 		this.syncLdk().catch(console.error);
+		this.removeExpiredAndUnclaimedInvoices().catch(console.error);
+		this.removeStalePaymentClaims().catch(console.error);
 
 		//Writes node state to log files
 		ldk.nodeStateDump().catch(console.error);
@@ -1375,8 +1379,6 @@ class LightningManager {
 		return [];
 	};
 
-	//TODO Remove any stale payments from storage if stuck for 60min. No payment claim should be stuck that long.
-
 	/**
 	 * Returns the previously created bolt11 invoices.
 	 * @returns {@link TBolt11Invoices}
@@ -1956,6 +1958,86 @@ class LightningManager {
 		await this.addPeers();
 		await this.syncLdk();
 	}
+
+	/**
+	 * Called with each sync to remove expired and unclaimed invoices.
+	 * An invoice is expired if there is no payments claimed (received) for it
+	 * after MAX_PENDING_PAY_AGE.
+	 */
+	private async removeExpiredAndUnclaimedInvoices(): Promise<void> {
+		const invoices = await this.getBolt11Invoices();
+		const claimedPayments = await this.getLdkPaymentsClaimed();
+		const expiredAndUnclaimedInvoices: TBolt11Invoices = [];
+
+		for (let index = 0; index < invoices.length; index++) {
+			const paymentRequest = invoices[index];
+			const invoiceRes = await ldk.decode({ paymentRequest });
+			if (invoiceRes.isOk()) {
+				const invoice = invoiceRes.value;
+				const invoiceAge = Date.now() - invoice.timestamp * 1000;
+				const isOld = invoiceAge > MAX_PENDING_PAY_AGE;
+				if (isOld) {
+					const payment = claimedPayments.find(
+						(it) => it.payment_hash === invoice.payment_hash,
+					);
+					const isClaimed = payment?.state === 'successful';
+					if (!isClaimed) {
+						expiredAndUnclaimedInvoices.push(paymentRequest);
+					}
+				}
+			}
+		}
+
+		if (expiredAndUnclaimedInvoices.length === 0) {
+			return;
+		}
+
+		const filteredInvoices = invoices.filter(
+			(it) => !expiredAndUnclaimedInvoices.includes(it),
+		);
+
+		await ldk.writeToLogFile(
+			'info',
+			`Removing ${expiredAndUnclaimedInvoices.length} expired and unclaimed invoices.`,
+		);
+		await ldk.writeToFile({
+			fileName: ELdkFiles.bolt11_invoices,
+			content: JSON.stringify(filteredInvoices),
+			remotePersist: false,
+		});
+	}
+
+	private async removeStalePaymentClaims(): Promise<void> {
+		const claims = await this.getLdkPaymentsClaimed();
+		const staleClaims: TChannelManagerClaim[] = [];
+
+		for (let index = 0; index < claims.length; index++) {
+			const payment = claims[index];
+			const isPending = payment.state === 'pending';
+			const age = Date.now() - payment.unix_timestamp * 1000;
+			const isStale = age > MAX_PENDING_PAY_AGE;
+			if (isPending && isStale) {
+				staleClaims.push(payment);
+			}
+		}
+
+		if (staleClaims.length === 0) {
+			return;
+		}
+
+		const filteredClaims = claims.filter((it) => !staleClaims.includes(it));
+
+		await ldk.writeToLogFile(
+			'info',
+			`Removing ${staleClaims.length} stale payment claims.`,
+		);
+
+		await ldk.writeToFile({
+			fileName: ELdkFiles.payments_claimed,
+			content: JSON.stringify(filteredClaims),
+			remotePersist: true,
+		});
+	}
 }
 
 export default new LightningManager();