1 files changed, 8 insertions, 3 deletions
diff --git a/examples/v1arch/asyncore/manager/cmdgen/broadcast-agent-discovery.py b/examples/v1arch/asyncore/manager/cmdgen/broadcast-agent-discovery.py
index 40eb0698..2fe5db4b 100644
--- a/examples/v1arch/asyncore/manager/cmdgen/broadcast-agent-discovery.py
+++ b/examples/v1arch/asyncore/manager/cmdgen/broadcast-agent-discovery.py
@@ -62,19 +62,25 @@ def cbTimerFun(timeNow):
 # noinspection PyUnusedLocal,PyUnusedLocal
 def cbRecvFun(transportDispatcher, transportDomain, transportAddress,
               wholeMsg, reqPDU=reqPDU):
+
     while wholeMsg:
         rspMsg, wholeMsg = decoder.decode(wholeMsg, asn1Spec=pMod.Message())
         rspPDU = pMod.apiMessage.getPDU(rspMsg)
+
         # Match response to request
         if pMod.apiPDU.getRequestID(reqPDU) == pMod.apiPDU.getRequestID(rspPDU):
+
             # Check for SNMP errors reported
             errorStatus = pMod.apiPDU.getErrorStatus(rspPDU)
             if errorStatus:
                 print(errorStatus.prettyPrint())
+
             else:
                 for oid, val in pMod.apiPDU.getVarBinds(rspPDU):
                     print('%s = %s' % (oid.prettyPrint(), val.prettyPrint()))
+
             transportDispatcher.jobFinished(1)
+
     return wholeMsg
 
 
@@ -98,7 +104,6 @@ transportDispatcher.jobStarted(1, maxNumberResponses)
 # Dispatcher will finish as all jobs counter reaches zero
 try:
     transportDispatcher.runDispatcher()
-except StopWaiting:
+
+finally:
     transportDispatcher.closeDispatcher()
-else:
-    raise