activemq-artemis

    0热度

    1回答

    使用案例:需要在队列上从一台服务器向另一台发送大型文件(100 MB的倍数)。 目前,我正在使用Activemq Artemis服务器发送大文件作为ByteMessage,通过tcp协议输入流的帮助,重新尝试间隔为-1,无限次失败重试。这里的主要问题是消费者终端连接将大部分是不稳定的,即由于移动性原因断开与网络的连接。 因此,当在队列中发送文件时,如果连接断开并且重新连接的代理应该从事务中断的地方

    1热度

    1回答

    将Wildfly 10.1 standalone-full-ha.xml与ActiveMQ Artemis 1.1.0一起使用。通过将该对ActiveMQ的配置启用STOMP:基于https://spring.io/guides/gs/messaging-stomp-websocket/ <acceptor name="stomp-acceptor" factory-class="org.apac

    0热度

    1回答

    我想拦截mqtt客户端向artemis broker发送的消息。 我正在关注示例“interceptor-client-mqtt”。 我的问题是,我总是收到一个错误“java.lang.ClassNotFoundException:SimpleMQTTInterceptor”。 我的问题是我应该在哪里放置拦截器类,以便经纪人可以找到它? 我应该只放置拦截器的类,还是应该放置一个jar文件?

    1热度

    1回答

    我有三台机器位于不同的网络: 作为主 作为节点-1 作为节点-2 在如-master我将WildFly作为域主机主机,两个节点将WildFly作为域主机 - 从机,每个都在全功能服务器组中启动一个实例。在as-master Web控制台中,我可以看到full-ha配置文件运行时中的两个节点,如果我部署WAR,它将在两个节点上正确启动。 现在,我试图实现的是两个WAR实例之间的消息传递,即从as-n

    0热度

    1回答

    我加了MQTT拦截到我的ARTEMIS经纪人为了拦截MQTT客户机连接: public class SimpleMQTTInterceptor implements MQTTInterceptor { @Override public boolean intercept(final MqttMessage mqttMessage, RemotingConnectio

    1热度

    3回答

    我想使用静态主机在我的双节点群集上启用消息重新分配。但它似乎并不奏效。 1)我有10个生产者写入队列“MyTestQueue”节点1(但没有消费者)。 2)我在节点2(但没有生产者)上有1个消费者使用来自节点2的消息。 我期望节点1将消息重新分配给消费者存在的节点2,但它不会。节点1上的消息数量仍然等于发送到节点1的消息数量。 我在broker.xml中拥有以下配置,它将forward-when-

    0热度

    1回答

    我试图发送一些数据到Wildfly 10 Artemis实例并使用Apache Camel接收它们。 在这里,我知道,这可以使用camel-jms组件完成。 在这种情况下,我首先创建了一个简单的示例来检查这是否工作正常。 但是,它在ConnectionFactory创建点处给出了以下例外。 Exception in thread "main" javax.naming.NamingExceptio

    -1热度

    2回答

    接收来自wildfly JMS队列消息从wildfly JMS队列接收消息时,我遇到了一个棘手的问题,我的代码是打击: Session produceSession = connectionFactory.createConnection().createSession(false, Session .CLIENT_ACKNOWLEDGE); Session con

    0热度

    1回答

    我们有一个java web应用程序,它通过JMS发送(JobsController.java)并接收消息(JMSMessageListener.java)。恒定负载下运行的应用程序24小时,采取堆转储后,我观察内存使用量的不断增加,应用程序不放手,当处于空闲状态。我知道这会导致java堆内存不足的问题。 JobsController是一个EJB无状态Bean和它的资源每次通话后正确销毁。 JMSM

    1热度

    1回答

    说明: 我有一个消费者和生产者,当我从消费者端向JMS(ARTEMIS)推送消息时,如果artemis宕机 ,那么我的消息不被artemis接受。 这意味着,当我打开我的artemis消息是不存在他们丢失在artemis队列bcz。 我想知道是否有任何配置(如缓冲区),我们可以在消费者端的context.xml中设置,以便我们保存被推送的消息,同时artemis仍然回到正轨。 此刻我有参数。 co