diff --git a/crypto/sol/app.py b/crypto/sol/app.py
index d6b4c3c..3ac8efe 100644
--- a/crypto/sol/app.py
+++ b/crypto/sol/app.py
@@ -119,7 +119,12 @@ dexscreener_client = DexscreenerClient()
 
 
 # Initialize Telegram Bot
-bot = Bot(token=TELEGRAM_BOT_TOKEN)
+# Create a custom connection pool
+conn_pool = aiohttp.TCPConnector(limit=100)  # Increase the connection limit
+timeout = aiohttp.ClientTimeout(total=30)  # Set a longer timeout
+
+# Create the bot with the custom connection pool
+bot = Bot(TELEGRAM_BOT_TOKEN, request=aiohttp.ClientSession(connector=conn_pool, timeout=timeout).request)
 
 # Token addresses (initialize with some known tokens)
 TOKEN_ADDRESSES = {
@@ -1257,9 +1262,10 @@ SUBSCRIBE_INTERVAL = 1*60  # Resubscribe every 10 minutes
 #         except websockets.exceptions.ConnectionClosed:
 #             break
 
-first_subscription = True
+_first_subscription = True
+_process_task = None
 async def wallet_watch_loop():
-    global first_subscription
+    global first_subscription, process_task
     reconnect_delay = 5
     max_reconnect_delay = 60
 
@@ -1279,21 +1285,21 @@ async def wallet_watch_loop():
                         subscription_id = await subscribe(websocket)
                         if subscription_id is not None:
                             await send_telegram_message(f"Solana mainnet connected ({subscription_id})...")
-                            if first_subscription:
+                            if _first_subscription:
                                 asyncio.create_task( list_initial_wallet_states())
-                                first_subscription = False   
-                            process_task = asyncio.create_task(process_messages(websocket, subscription_id))
+                                _first_subscription = False   
+                            _process_task = asyncio.create_task(process_messages(websocket, subscription_id))
                             while True:
                                 try:# drop subscription now
                                     await process_messages(websocket, subscription_id)
-                                    # await asyncio.run(process_task)
-                                    # await asyncio.wait_for(process_task, timeout=SUBSCRIBE_INTERVAL)
+                                    # await asyncio.run(_process_task)
+                                    # await asyncio.wait_for(_process_task, timeout=SUBSCRIBE_INTERVAL)
                                 except asyncio.TimeoutError:
                                     # Timeout occurred, time to resubscribe
                                     if not PROCESSING_LOG:
-                                        process_task.cancel()
+                                        _process_task.cancel()
                                         try:
-                                            await process_task
+                                            await _process_task
                                         except asyncio.CancelledError:
                                             pass
                                         await unsubscribe(websocket, subscription_id)