diff --git a/server.go b/server.go
index 6dbc9a2..f5b34c0 100644
--- a/server.go
+++ b/server.go
@@ -443,7 +443,7 @@ func (s *server) directSAMSChRead() {
 				// fmt.Printf(" * DEBUG: directSAMSChRead: <- sams = %v\n", sams)
 				// Range over all the sams, find the process, check if the method exists, and
 				// handle the message by starting the correct method handler.
-				for i := range sams {
+				for i, sam := range sams {
 					processName := processNameGet(sams[i].Subject.name(), processKindSubscriberNats)
 
 					s.processes.active.mu.Lock()
@@ -456,7 +456,7 @@ func (s *server) directSAMSChRead() {
 					mh, ok := p.methodsAvailable.CheckIfExists(sams[i].Message.Method)
 					if !ok {
 						er := fmt.Errorf("error: subscriberHandler: method type not available: %v", p.subject.Method)
-						p.errorKernel.errSend(p, sams[i].Message, er, logError)
+						p.errorKernel.errSend(p, sam.Message, er, logError)
 						continue
 					}