我正在尝试使用 ActiveMQ Artemis Core API 连接到在 docker 容器中运行的 ActiveMQ Artemis。
我正在使用以下代码尝试连接。
Map<String,Object> connectionParams = new HashMap<String, Object>();
connectionParams.put(TransportConstants.PORT_PROP_NAME, "61616");
connectionParams.put(TransportConstants.HOST_PROP_NAME, "localhost");
TransportConfiguration tc = new TransportConfiguration(NettyConnectorFactory.class.getName(),connectionParams);
ServerLocator locator = ActiveMQClient.createServerLocatorWithoutHA(tc);
ClientSessionFactory queueFactory = locator.createSessionFactory();
运行时,当我尝试创建会话工厂时出现以下错误。
ActiveMQNotConnectedException[errorType=NOT_CONNECTED message=AMQ119007: Cannot connect to server(s). Tried with all available servers.]
在尝试连接到 ActiveMQ Artemis 代理时,我似乎错过了一个关键的配置步骤。我是否需要将 XML 文件放在我的 Java 客户端应用程序中的某个位置,或者我可以在代码中设置正确的设置吗?
我正在使用的 AtiveMQ Artemis 的 Docker 映像: