Repository: qpid-proton Updated Branches: refs/heads/master 4939f7412 -> 33ec78e50
NO-JIRA: [go] Check Sender.Error() before sending Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/33ec78e5 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/33ec78e5 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/33ec78e5 Branch: refs/heads/master Commit: 33ec78e5057dd8028b94e2ae75394d242e12c363 Parents: 4939f74 Author: Alan Conway <acon...@redhat.com> Authored: Tue Oct 23 18:02:48 2018 -0400 Committer: Alan Conway <acon...@redhat.com> Committed: Tue Oct 23 18:02:48 2018 -0400 ---------------------------------------------------------------------- go/src/qpid.apache.org/electron/sender.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/33ec78e5/go/src/qpid.apache.org/electron/sender.go ---------------------------------------------------------------------- diff --git a/go/src/qpid.apache.org/electron/sender.go b/go/src/qpid.apache.org/electron/sender.go index 98e6c9b..b461f08 100644 --- a/go/src/qpid.apache.org/electron/sender.go +++ b/go/src/qpid.apache.org/electron/sender.go @@ -190,7 +190,10 @@ func (s *sender) trySend() { // Called in handler goroutine with credit > 0 func (s *sender) send(sm *sendable) { - var err error + if err := s.Error(); err != nil { + sm.unsent(err) + return + } bytes, err := s.session.connection.mc.Encode(sm.m, nil) close(sm.sent) // Safe to re-use sm.m now if err != nil { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
