Package nablarch.integration.messaging.wmq.provider

Class WmqMessagingContext

java.lang.Object
nablarch.fw.messaging.MessagingContext
nablarch.integration.messaging.wmq.provider.WmqMessagingContext
All Implemented Interfaces:
Closeable, AutoCloseable
public class WmqMessagingContext extends MessagingContext
IBM MQを使用したMessagingContextの実装クラス。

  • Constructor Summary

    Constructors
    Constructor
    Description
    WmqMessagingContext(WmqMessagingProvider provider, com.ibm.mq.MQQueueManager mqQueueManager, Map<String,com.ibm.mq.MQQueue> sendingMqQueues, com.ibm.mq.MQQueue receivedMqQueue, com.ibm.mq.MQQueue poisonMqQueue)
    コンストラクタ。

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    backout()
    分散トランザクションをバックアウトする。
    void
    begin()
    分散トランザクションを開始する。
    protected void
    checkReceivedQueueName(String receiveQueue)
    指定された受信キュー名に対応するキューが登録されているか否かをチェックする。
    void
    close()
    現在のセッションを終了し、保持しているリソースを開放する。
    void
    commit()
    分散トランザクションをコミットする。
    static WmqMessagingContext
    getInstance()
    カレントスレッドに紐づけられているWmqMessagingContextを取得する。
    Connection
    getJdbcConnection(XADataSource xaDataSource)
    MQQueueManagerからConnectionを取得する。
    protected com.ibm.mq.MQQueue
    getMQQueue(Map<String,com.ibm.mq.MQQueue> mqQueues, String queueName)
    MQQueueマップから指定されたキュー名のMQQueueを取得する。
    ReceivedMessage
    receiveMessage(String receiveQueue, String messageId, long timeout)
    指定した受信キュー上のメッセージを取得する。 messageIdが指定されている場合は、当該のメッセージに対する応答電文を 取得する。messageIdが指定されていないばあいは、受信キュー上の任意の電文 を取得する。 キュー上に取得対象のメッセージが存在しない場合、メッセージを受信するか、 指定した時間が経過する（タイムアウトする）までブロックする。 タイムアウトした場合はnullをかえす。 タイムアウト時間に0以下の数値を設定した場合は 応答電文を受信するまでブロックし続ける。
    String
    sendMessage(SendingMessage sendingMessage)
    メッセージを送信する。

    Methods inherited from class nablarch.fw.messaging.MessagingContext

    attach, detach, emitLog, receiveSync, receiveSync, receiveSync, send, sendSync, sendSync

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • WmqMessagingContext

      public WmqMessagingContext(WmqMessagingProvider provider, com.ibm.mq.MQQueueManager mqQueueManager, Map<String,com.ibm.mq.MQQueue> sendingMqQueues, com.ibm.mq.MQQueue receivedMqQueue, com.ibm.mq.MQQueue poisonMqQueue)
      コンストラクタ。
      Parameters:
      provider - WmqMessagingProvider
      mqQueueManager - MQQueueManager
      sendingMqQueues - 送信先MQQueueマップ(キーはキュー名)
      receivedMqQueue - 受信先MQQueue
      poisonMqQueue - ポイズンメッセージ送信先MQQueue

  • Method Details