review comment

smartcontractkit · Dec 17, 2024 · 1c3d92f · 1c3d92f
1 parent 6edeaa2
commit 1c3d92f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/capabilities/remote/trigger_subscriber.go b/core/capabilities/remote/trigger_subscriber.go
@@ -139,7 +139,7 @@ func (s *triggerSubscriber) UnregisterTrigger(ctx context.Context, request commo
 	return nil
 }
 
-func (s *triggerSubscriber) responseChannelRegister(workflowID string) bool {
+func (s *triggerSubscriber) isWorkflowRegistered(workflowID string) bool {
 	s.mu.RLock()
 	defer s.mu.RUnlock()
 	_, found := s.responseChannels[workflowID]
@@ -183,7 +183,7 @@ func (s *triggerSubscriber) Receive(_ context.Context, msg *types.MessageBody) {
 			meta.WorkflowIds = meta.WorkflowIds[:maxBatchedWorkflowIDs]
 		}
 		for _, workflowID := range meta.WorkflowIds {
-			registered := s.responseChannelRegister(workflowID)
+			registered := s.isWorkflowRegistered(workflowID)
 			if !registered {
 				s.lggr.Errorw("received message for unregistered workflow", "capabilityId", s.capInfo.ID, "workflowID", SanitizeLogString(workflowID), "sender", sender)
 				continue