activemq-artemis

0熱度

1回答

使用案例：需要在隊列上從一臺服務器向另一臺發送大型文件（100 MB的倍數）。目前，我正在使用Activemq Artemis服務器發送大文件作爲ByteMessage，通過tcp協議輸入流的幫助，重新嘗試間隔爲-1，無限次失敗重試。這裏的主要問題是消費者終端連接將大部分是不穩定的，即由於移動性原因斷開與網絡的連接。因此，當在隊列中發送文件時，如果連接斷開並且重新連接的代理應該從事務中斷的地方

1熱度

1回答

Wildfly 10.1羣集中的Spring websockets

將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回答

Artemis mqtt客戶端攔截器：java.lang.ClassNotFoundException

我想攔截mqtt客戶端向artemis broker發送的消息。我正在關注示例「interceptor-client-mqtt」。我的問題是，我總是收到一個錯誤「java.lang.ClassNotFoundException：SimpleMQTTInterceptor」。我的問題是我應該在哪裏放置攔截器類，以便經紀人可以找到它？我應該只放置攔截器的類，還是應該放置一個jar文件？

1熱度

1回答

羣集WildFly 10域消息

我有三臺機器位於不同的網絡：作爲主作爲節點-1 作爲節點-2 在如-master我將WildFly作爲域主機主機，兩個節點將WildFly作爲域主機 - 從機，每個都在全功能服務器組中啓動一個實例。在as-master Web控制檯中，我可以看到full-ha配置文件運行時中的兩個節點，如果我部署WAR，它將在兩個節點上正確啓動。現在，我試圖實現的是兩個WAR實例之間的消息傳遞，即從as-n

0熱度

1回答

阿蒂米斯經紀人攔截MQTT客戶機連接

我加了MQTT攔截到我的ARTEMIS經紀人爲了攔截MQTT客戶機連接： public class SimpleMQTTInterceptor implements MQTTInterceptor { @Override public boolean intercept(final MqttMessage mqttMessage, RemotingConnectio

1熱度

3回答

ArtemisMQ 2.x上的消息重新分配不起作用

我想使用靜態主機在我的雙節點羣集上啓用消息重新分配。但它似乎並不奏效。 1）我有10個生產者寫入隊列「MyTestQueue」節點1（但沒有消費者）。 2）我在節點2（但沒有生產者）上有1個消費者使用來自節點2的消息。我期望節點1將消息重新分配給消費者存在的節點2，但它不會。節點1上的消息數量仍然等於發送到節點1的消息數量。我在broker.xml中擁有以下配置，它將forward-when-

0熱度

1回答

發送數據到Wildfly 10嵌入的Artemis實例並接收它們使用Apache Camel

我試圖發送一些數據到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回答

Wildfly 10.1.0.FINAL上的內存泄漏（java.lang.ref.Finalizer/ActiveMQConnection）

我們有一個java web應用程序，它通過JMS發送（JobsController.java）並接收消息（JMSMessageListener.java）。恆定負載下運行的應用程序24小時，採取堆轉儲後，我觀察內存使用量的不斷增加，應用程序不放手，當處於空閒狀態。我知道這會導致java堆內存不足的問題。 JobsController是一個EJB無狀態Bean和它的資源每次通話後正確銷燬。 JMSM

1熱度

1回答

如何在artemis關閉時從生產者那裏獲取消息？

說明：我有一個消費者和生產者，當我從消費者端向JMS（ARTEMIS）推送消息時，如果artemis宕機，那麼我的消息不被artemis接受。這意味着，當我打開我的artemis消息是不存在他們丟失在artemis隊列bcz。我想知道是否有任何配置（如緩衝區），我們可以在消費者端的context.xml中設置，以便我們保存被推送的消息，同時artemis仍然回到正軌。此刻我有參數。 co