A scalable communication middleware for real-time data collection of dangerous goods vehicle activities