AMQP、SQL ServerおよびXA

Question

：

• スタンドアロン春3.1.0.RELEASEアプリケーション
• 休止3.6.7.FinalとJPA
• AMQP（RabbitMQのようクライアントとしてサーバー、春AMQP）私たちは、RabbitMQのAとの間の取引を同期する必要があるのjTDSドライバ

と

SQL Server 2008のSQL Serverを使用しているため、atomikosでXAをセットアップしようとしています。問題は、実際に動作しているその状況のた​​めの単一のスプリングサンプル構成ファイルを見つけることができないことです。私たちは、Springのドキュメンテーション、Google、フォーラムなどのサンプルを使って非常に多くの組み合わせを試しました。何かが欠けています。

誰かが私たちの設定用のテンプレートとして使用できるように、このようなファイルを提供してもらえますか？

P.S. 本当にXAが必要ですか？

ありがとうございました。

Answer 1

様々な候補解（Change Data Captureの使用、SQL Server Service Broker用のアダプタ、およびMSMQからRabbitMQのに可能な変換）を掘り後、私はあなたのために働く必要があるソリューションに来ました。

WCFクライアントとサービス契約をSQL Serverにバインドすることができます。ここから、RabbitMQ's AMQP binding for WCFを使用して、前述のPDFドキュメントと同様に、メッセージを前後に翻訳できます。

ここではXAなどの追加のトランザクションマネージャが必要かどうかは不明ですが、トランザクションの重複、ループ、および不一致に問題がある場合は、接続の仲介者として検討する価値があります。あなたがそのルートに行くなら、あなたはあなたが問題のステートメントで定義したのと同じ方法であなたのゲートウェイにそれを溶接する必要があります。これに明確化が必要な場合は、私はここでこれを拡張することができます。

あなたのアプリケーションに最適です。外部からのインテグレーション・ヒドラのように聞こえますが、一度すべてのことを話すとうまくいくはずです。

Answer 2

私が知っているように、RabbitMQ はがXAスタイルのトランザクションをサポートしていません。

そして、はい、あなたはJavaでそれを行うことができます。

TestConfiguration.java

import org.springframework.amqp.core.Queue; 
import org.springframework.amqp.rabbit.config.AbstractRabbitConfiguration; 
import org.springframework.amqp.rabbit.connection.ConnectionFactory; 
import org.springframework.amqp.rabbit.connection.SingleConnectionFactory; 
import org.springframework.amqp.rabbit.core.RabbitTemplate; 
import org.springframework.context.annotation.Bean; 
import org.springframework.context.annotation.Configuration; 

@Configuration 
public class TestConfiguration extends AbstractRabbitConfiguration { 

    private String routingKey = "test.queue"; 
    private String testQueueName = "test.queue"; 

    public ConnectionFactory getConnectionFactory() { 
     SingleConnectionFactory connectionFactory = new SingleConnectionFactory("localhost"); 
     connectionFactory.setUsername("guest"); 
     connectionFactory.setPassword("guest"); 
     return connectionFactory; 
    } 

    @Override 
    public RabbitTemplate rabbitTemplate() { 
     RabbitTemplate rabbitTemplate = new RabbitTemplate(getConnectionFactory()); 
     rabbitTemplate.setRoutingKey(routingKey); 
     rabbitTemplate.setQueue(testQueueName); 
     return rabbitTemplate; 

送信の簡単な例：

import org.springframework.amqp.core.AmqpTemplate; 
import org.springframework.beans.factory.annotation.Autowired; 

public class MessageSender { 

    @Autowired 
    private AmqpTemplate template; 

    public void send(String text) { 
     template.convertAndSend(text); 
    } 
} 

...そして、受信：ここ

• import org.springframework.amqp.core.Message; 
  import org.springframework.amqp.core.MessageListener; 
  public class MessageHandler implements MessageListener { 
      @Override 
      public void onMessage(Message message) { 
       System.out.println("Received message: " + message); 
      } 
  } 
  

  は、いくつかの参照
• Using RabbitMQ, Spring AMQP and Spring Integration
• Spring Framework AMQP RabbitMQ Connection
• Blog
  • Spring AMQP - Reference Documentation（場合にはJavaで構成する必要があるすべてのプロセスについての詳細な説明をしています1つのアプリケーションイベント管理の）