我正在使用 BrokerFilter 为我的 ActiveMQ 代理创建自己的身份验证插件。我按照本指南中的步骤操作:
http://mariuszprzydatek.com/2014/01/04/ip-based-authentication-plugin-for-activemq/
在独立模式下一切正常。但是,当我尝试部署代理集群时,代理之间的网络连接已被我的 addConnection() 方法拦截,并且由于它没有通过我的身份验证逻辑,因此无法连接集群。
简而言之,我的问题是:在我的上下文中,如何区分来自客户端的连接和来自其他代理的连接?我查看了 ConnectionContext 和 ConnectionInfo 对象,但似乎它们都不起作用。
非常感谢。