现在我们的项目里有这样的需求:
用JAVA代码向远端的ActiveMQ服务器发送消息。
但如果用客户端的JAVA代码的MessageProducer向远端的ActiveMQ服务器直接发送消息的话,如果本地或远端服务器的网线断开,或出现其他网络不通的情况,则发送不能成功,将报异常,并且发送的消息将丢失。我现在想在在本地和远端同时开启ActiveMQ服务器,本地的JAVA代码将消息内容直接发给本地ActiveMQ服务器,本地ActiveMQ服务器服务将消息发送给远程ActiveMQ服务器,如果网络不通,消息将暂时持久化在本地ActiveMQ服务器中,等网络通了以后,本地ActiveMQ服务器再将消息发送给远端ActiveMQ服务器。
不知在JAVA代码或本地ActiveMQ服务器中应如何设置,才能实现此需求?
各位大哥多帮帮忙,多谢!!!