java 消息处理组件有哪些？

例子：
   模块A和B分别布署在不同机器上，A和B建立Socket进行通讯,当Socket异常中断时,模块A里的消息有可能发送不到B中去.
要求:
   当A与B的Socket重新建立后,A中上次未发送成功的消息能再次发送到B中.
疑问:
   我不知道java里有哪些处理消息的组件可以处理上面提到的异常情况,我对MSMQ有点了解,它可以把消息存储在内存中或者是物理文件中,有两种方式发送:快递方式(express)和可恢复模式（recoverable）.以可恢复模式发送的消息可以恢复到故障发生之前的状态.不知道java里有没有哪些组件功能上与MSMQ是类似的,各位大虾推荐下,小弟在此谢过了...