diff --git a/main.go b/main.go
index 02f71c5..c419317 100644
--- a/main.go
+++ b/main.go
@@ -11,6 +11,9 @@ import (
 
 	"eosio-ship-trace-reader/config"
 	"eosio-ship-trace-reader/internal/redis"
+	"eosio-ship-trace-reader/transport"
+	"eosio-ship-trace-reader/transport/redis_pubsub"
+
 	"github.com/nikoksr/notify"
 	"github.com/nikoksr/notify/service/telegram"
 
@@ -39,6 +42,8 @@ var (
 
 var abi_mgr *abi.AbiManager
 
+var publisher transport.Publisher
+
 var redisNs redis.Namespace
 
 // Reader states
@@ -220,6 +225,9 @@ func main() {
 		return
 	}
 
+	// Setup publisher
+	publisher = redis_pubsub.New(redis.Client())
+
 	// Connect client and get chain info.
 	log.Printf("Get chain info from api at: %s", conf.Api)
 	eosClient = eos.New(conf.Api)