diff --git a/app/ship_processor.go b/app/ship_processor.go index 456505c..589d346 100644 --- a/app/ship_processor.go +++ b/app/ship_processor.go @@ -13,15 +13,13 @@ import ( ) type ShipProcessor struct { - ns transport.Namespace abi *abi.AbiManager publisher transport.Publisher shClient *shipclient.ShipClient } -func SpawnProccessor(shClient *shipclient.ShipClient, ns transport.Namespace, publisher transport.Publisher, abi *abi.AbiManager) { +func SpawnProccessor(shClient *shipclient.ShipClient, publisher transport.Publisher, abi *abi.AbiManager) { processor := &ShipProcessor{ - ns: ns, abi: abi, publisher: publisher, shClient: shClient, diff --git a/main.go b/main.go index 2b586e0..f49d4a4 100644 --- a/main.go +++ b/main.go @@ -241,10 +241,6 @@ func main() { app.SpawnProccessor( shClient, - transport.Namespace{ - Prefix: conf.Redis.Prefix, - ChainID: chainInfo.ChainID.String(), - }, redis_pubsub.New(rdb), abi.NewAbiManager(rdb, eosClient, conf.Redis.CacheID), )