Может вам подойдёт Akka? Насколько я знаю для очередей сообщений можно указывать storage (уже есть немало адаптеров). Заодно и более-менне лёгкую масштабируемость получить с помощью akka-remote. Но назвать это 100% готовым решением трудно. Да и важно какого рода вам pub/sub нужен, под одни задачи akka даже лучше будет, под другие вообще не подойдёт.
Есть ещё vert.x. С реалтаймом там всё хорошо, а вот с персистентностью — не в курсе. Под vert.x есть разные модули, не удивлюсь если уже реализовано, но придётся поискать или поспрашивать в их коммьюнити.