Implemented message expiration and connection start/stop behavior. Temporary queues should also be cleaned up properly now.