use upnode to provide message queueing and automatic stream reconnects