diff --git a/amqpjobs/listener.go b/amqpjobs/listener.go
index 2cd6ef4..bf78d8b 100644
--- a/amqpjobs/listener.go
+++ b/amqpjobs/listener.go
@@ -38,6 +38,7 @@ func (d *Driver) listener(deliv <-chan amqp.Delivery) {
 					del.headers = nil
 					del.Options = nil
 				}
+				span.End()
 				continue
 			}