diff --git a/cluster/cluster_impl/forking_cluster_invoker.go b/cluster/cluster_impl/forking_cluster_invoker.go index c4a59a799e38dccf9443672b0136e304ae649929..d6cf2f4b89ab4f322fa758deecae90c60742ef49 100644 --- a/cluster/cluster_impl/forking_cluster_invoker.go +++ b/cluster/cluster_impl/forking_cluster_invoker.go @@ -30,6 +30,7 @@ import ( import ( "github.com/apache/dubbo-go/cluster" "github.com/apache/dubbo-go/common/constant" + "github.com/apache/dubbo-go/common/logger" "github.com/apache/dubbo-go/protocol" ) @@ -75,7 +76,10 @@ func (invoker *forkingClusterInvoker) Invoke(invocation protocol.Invocation) pro for _, ivk := range selected { go func(k protocol.Invoker) { result := k.Invoke(invocation) - resultQ.Put(result) + err := resultQ.Put(result) + if err != nil { + logger.Errorf("resultQ put failed with exception: %v.\n", err) + } }(ivk) } diff --git a/config/testdata/consumer_config.yml b/config/testdata/consumer_config.yml index 373871dccbc6c3f7272b7abcb1a9a104c8f13090..372873abbb258e03acfe8e9e00d03aa2f77fb9a9 100644 --- a/config/testdata/consumer_config.yml +++ b/config/testdata/consumer_config.yml @@ -47,6 +47,7 @@ references: params: "serviceid": "soa.com.ikurento.user.UserProvider" + "forks": 5 protocol_conf: dubbo: