diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go
index 7cf4a332..271797e9 100644
--- a/server/jetstream_cluster.go
+++ b/server/jetstream_cluster.go
@@ -3640,7 +3640,7 @@ func (js *jetStream) processClusterCreateConsumer(ca *consumerAssignment, state
 	var didCreate, isConfigUpdate, needsLocalResponse bool
 	if o == nil {
 		// Add in the consumer if needed.
-		if o, err = mset.addConsumerWithAssignment(ca.Config, ca.Name, ca, false) {
+		if o, err = mset.addConsumerWithAssignment(ca.Config, ca.Name, ca, false); err == nil {
 			didCreate = true
 		}
 	} else {