diff --git a/pybtc/connector/block_loader.py b/pybtc/connector/block_loader.py
index 5a4d7b6..2d27a56 100644
--- a/pybtc/connector/block_loader.py
+++ b/pybtc/connector/block_loader.py
@@ -10,7 +10,7 @@ import sys
 import aiojsonrpc
 import traceback
 from pybtc.connector.utils import decode_block_tx
-import msgpack
+from pickle import loads, dumps
 from lru import LRU
 
 
@@ -162,7 +162,7 @@ class BlockLoader:
 
             if msg_type == b'result':
                 self.worker_busy[index] = False
-                blocks = msgpack.loads(msg)
+                blocks = loads(msg)
 
                 for i in blocks:
                     self.parent.block_preload.set(i, blocks[i])
@@ -258,7 +258,7 @@ class Worker:
 
                 # blocks[x] = msgpack.dumps(blocks[x])
 
-            self.pipe_sent_msg(b'result', msgpack.dumps(blocks))
+            self.pipe_sent_msg(b'result', dumps(blocks))
         except:
             self.log.critical(str(traceback.format_exc()))
 
diff --git a/pybtc/connector/connector.py b/pybtc/connector/connector.py
index 4cad3a5..ca8ee40 100644
--- a/pybtc/connector/connector.py
+++ b/pybtc/connector/connector.py
@@ -12,7 +12,7 @@ import zmq
 import zmq.asyncio
 import asyncio
 import time
-import msgpack
+from pickle import loads, dumps
 
 class Connector:
     def __init__(self, node_rpc_url, node_zerromq_url, logger,