ServiceName = cp.get('VendingMachine', 'ServiceName')
ServicePassword = cp.get('VendingMachine', 'Password')
-
- rfh, wfh = connect_to_vend(options, DBServer, DBName, DBUser, DBPassword, ServiceName, ServicePassword)
- run_forever(rfh, wfh)
+
+ while True:
+ rfh, wfh = connect_to_vend(options, DBServer, DBName, DBUser, DBPassword, ServiceName, ServicePassword)
+ try:
+ run_forever(rfh, wfh)
+ except VendingException:
+ print "Connection died, trying again..."
+