diff --git a/pubsub.go b/pubsub.go index c9ddc3be97bf5de28fe35dc992a8ae1522703f3b..bd1f40e683f2166558acd24d5f52bf6a3fe03aa7 100644 --- a/pubsub.go +++ b/pubsub.go @@ -991,7 +991,7 @@ func (p *PubSub) pushMsg(msg *Message) { return } - err := p.checkSignature(msg) + err := p.checkSigningPolicy(msg) if err != nil { log.Debugf("dropping message from %s: %s", src, err) return @@ -1021,7 +1021,7 @@ func (p *PubSub) pushMsg(msg *Message) { } } -func (p *PubSub) checkSignature(msg *Message) error { +func (p *PubSub) checkSigningPolicy(msg *Message) error { // reject unsigned messages when strict before we even process the id if p.signPolicy.mustVerify() { if p.signPolicy.mustSign() { diff --git a/validation.go b/validation.go index d4ad27d9daeaea3e4379bedd684665384ac486aa..dddddf05c7a2db7ff1b86ff8febfdf77d987b486 100644 --- a/validation.go +++ b/validation.go @@ -216,7 +216,7 @@ func (v *validation) RemoveValidator(req *rmValReq) { func (v *validation) PushLocal(msg *Message) error { v.p.tracer.PublishMessage(msg) - err := v.p.checkSignature(msg) + err := v.p.checkSigningPolicy(msg) if err != nil { return err }