nablarch.integration.messaging.wmq.provider

Class WmqMessagingContext

java.lang.Object

nablarch.fw.messaging.MessagingContext

nablarch.integration.messaging.wmq.provider.WmqMessagingContext

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class WmqMessagingContext
extends MessagingContext

IBM MQを使用したMessagingContextの実装クラス。

Constructor Summary

Constructors

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

Method Summary

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

WmqMessagingContext

public WmqMessagingContext(WmqMessagingProvider provider,
                           com.ibm.mq.MQQueueManager mqQueueManager,
                           java.util.Map<java.lang.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 Detail

getInstance

public static WmqMessagingContext getInstance()

カレントスレッドに紐づけられているWmqMessagingContextを取得する。

Returns:

カレントスレッドに紐づけられているWmqMessagingContext

sendMessage

public java.lang.String sendMessage(SendingMessage sendingMessage)

メッセージを送信する。

WmqMessagingProvider.putMessage(MQQueue, SendingMessage)メソッドに処理を委譲する。

Specified by:

sendMessage in class MessagingContext

Parameters:

sendingMessage - 送信メッセージ

Returns:

送信メッセージのメッセージID

receiveMessage

public ReceivedMessage receiveMessage(java.lang.String receiveQueue,
                                      java.lang.String messageId,
                                      long timeout)

指定した受信キュー上のメッセージを取得する。 messageIdが指定されている場合は、当該のメッセージに対する応答電文を 取得する。messageIdが指定されていないばあいは、受信キュー上の任意の電文 を取得する。 キュー上に取得対象のメッセージが存在しない場合、メッセージを受信するか、 指定した時間が経過する（タイムアウトする）までブロックする。 タイムアウトした場合はnullをかえす。 タイムアウト時間に0以下の数値を設定した場合は 応答電文を受信するまでブロックし続ける。

WmqMessagingProvider.getMessage(MQQueue, String, long, MQQueue)メソッドに処理を委譲する。

Specified by:

receiveMessage in class MessagingContext

Parameters:

receiveQueue - 受信キューの論理名

messageId - 送信電文のメッセージID (応答受信でない場合はnull)

timeout - 応答タイムアウト (単位：ミリ秒、0以下の数値の場合はブロックし続ける)

Returns:

受信したメッセージ（タイムアウトした場合はnull）

checkReceivedQueueName

protected void checkReceivedQueueName(java.lang.String receiveQueue)
                               throws MessagingException

指定された受信キュー名に対応するキューが登録されているか否かをチェックする。

Parameters:

receiveQueue - 受信キュー名

Throws:

MessagingException - 指定されたキュー名に対するMQQueueが登録されていなかった場合

getMQQueue

protected com.ibm.mq.MQQueue getMQQueue(java.util.Map<java.lang.String,com.ibm.mq.MQQueue> mqQueues,
                                        java.lang.String queueName)
                                 throws MessagingException

MQQueueマップから指定されたキュー名のMQQueueを取得する。

Parameters:

mqQueues - MQQueueマップ

queueName - キュー名

Returns:

MQQueue

Throws:

MessagingException - 指定されたキュー名に対するMQQueueが登録されていなかった場合

close

public void close()

現在のセッションを終了し、保持しているリソースを開放する。

WmqMessagingProvider.close(Map)メソッド、 WmqMessagingProvider.close(MQQueue)メソッド、 WmqMessagingProvider.disconnect(MQQueueManager)メソッド を順に呼び出し、処理を委譲する。

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in class MessagingContext

getJdbcConnection

public java.sql.Connection getJdbcConnection(javax.sql.XADataSource xaDataSource)
                                      throws java.sql.SQLException,
                                             javax.transaction.xa.XAException

MQQueueManagerからConnectionを取得する。

WmqMessagingProvider.getJdbcConnection(MQQueueManager, XADataSource)メソッドに処理を委譲する。

Parameters:

xaDataSource - XAデータソース

Returns:

Connection

Throws:

java.sql.SQLException - Connectionの取得に失敗した場合

javax.transaction.xa.XAException - Connectionの取得に失敗した場合

begin

public void begin()

分散トランザクションを開始する。

WmqMessagingProvider.begin(MQQueueManager)メソッドに処理を委譲する。

commit

public void commit()

分散トランザクションをコミットする。

WmqMessagingProvider.commit(MQQueueManager)メソッドに処理を委譲する。

backout

public void backout()

分散トランザクションをバックアウトする。

WmqMessagingProvider.backout(MQQueueManager)メソッドに処理を委譲する。