spring-jms

2熱

1答えて

スレッド "main"の例外com.ibm.msg.client.jms.DetailedMessageEOFException：JMSCC0065：メッセージの最後を超えて読み取ろうとしました。

WebSphere MQからメッセージを読み取ろうとしていますが、以下の例外。誰かがなぜこの例外が発生するのか、メッセージを読む正しい方法を教えてください。 public String readMessage() throws JMSException { String message = null; Message msg = getJmsTemplate().receiv

0熱

1答えて

すぐに現在のTXステータスを無視してJMSメッセージを送信する

簡潔に、私は春から入手した超簡単なJMS設定を使用します。ガイド：https://spring.io/guides/gs/messaging-jms/。私の場合は、私はTXが失敗した場合でも、同様STH（kotlinコード）トランザクションメソッドからJMSメッセージを送りたいということです：ない場合 @Service open class MyService(private val t: J

0熱

1答えて

Spring起動時にセッションを閉じるJMS CachingConnectionFactory

私のJMS構成は次のようになっています（Springブート1.3.8）。 @Configuration @EnableJms public class JmsConfig { @Autowired private AppProperties properties; @Bean TopicConnectionFactory topicC

0熱

1答えて

Artemis：エラー時にメッセージを消費するのを止めるには？

ActiveMQ ArtemisまたはSpring JMSクライアントをエラー時に他のメッセージを消費しないように設定する方法はありますか？次のように私は私のブローカーを構成した： <addresses> <address name="SimplePointToPoint"> <anycast> <queue name="SimplePointToPoint"

0熱

1答えて

Spring-boot appがApache Artemisクラスタに接続する

Spring Factoryは、Artemisがクラスパス上で利用可能になると、Connection Factoryを自動構成できます。しかし、SpringネイティブのArtemisクラスタ（複数のノード）にSpringブートアプリケーションを設定する方法

0熱

1答えて

IBM MQとスプリングブート

私はIBM MQ経由でJMSを使用しています。私の差出人コード： @Autowired private JmsTemplate jmsTemplate; public void sendPHRq(String msg) { jmsTemplate.send(AntiFraudRq, session -> { Message message = session.creat

0熱

1答えて

JmsTemplate with CachingConnectionFactory IBM MQキューの接続回復

JmsTemplateを使用して同じクライアントから2つのIBM MQサーバーに接続しています。私はJmsTemplateのreconnectOnExceptionとIBM MQ接続ファクトリのsetClientReconnectOptionsを設定しました。のSpring Bean定義： <bean id="firstMQCachingConnectionFactory" class="or

1熱

1答えて

メッセージを送信した直後に、メッセージを使用せずにJMSヘッダーを取得します。

メッセージを送信した後にJMSメッセージヘッダーを取得する方法はありますか？これはコード jmsTemplate.convertAndSend(que, text, message -> { LOGGER.info("setting JMS Message header values"); message.setStringProperty(RequestContex

1熱

1答えて

JUnitのバネJMSリスナー

私はユニットテストにJUnitのから @Component public class NotificationReader { @JmsListener(destination = "myAppQ") public void receiveMessage(NotificationMessage notificationMessage) { System.out.

0熱

1答えて

Jms Java：weblogicでのバージョンでのデプロイjavax.management.InstanceAlreadyExistsException

weblogicサーバーにJms warがデプロイされています。この戦争を新しいバージョンで更新すると、最初のバージョンが後退するまで同じブローカーtcp://0.0.0.0:61616を使用している2 warがあります。それはにjavax.management.InstanceAlreadyExistsExceptionを投げる：org.apache.activemq：タイプ=ブローカーは、