nablarch.test.core.messaging

Class EmbeddedMessagingProvider

java.lang.Object

nablarch.fw.messaging.provider.JmsMessagingProvider

nablarch.test.core.messaging.EmbeddedMessagingProvider

All Implemented Interfaces:

Initializable, MessagingProvider

public class EmbeddedMessagingProvider
extends JmsMessagingProvider
implements Initializable

JVM内蔵式メッセージングサーバによる簡易メッセージングプロバイダ実装。 この実装では、サブスレッド上で動作するJMSプロバイダ実装を内蔵しており、 そこに接続して動作する。 これにより、外部のMOMを用意すること無くメッセージング処理を含んだ業務機能の 単体テストを実施することが可能である。 現時点の実装では、自動テストでの利用のみを想定しているため、 リモートキューへの転送はサポートしていない。 また、内部的にActiveMQのメッセージブローカーとvm:// プロトコルを使用しているため、 本機能を利用する場合は、ActiveMQのライブラリをクラスパスに含める必要がある。

Nested Class Summary

Nested classes/interfaces inherited from class nablarch.fw.messaging.provider.JmsMessagingProvider

JmsMessagingProvider.Context

Constructor Summary

Constructors

Constructor and Description
EmbeddedMessagingProvider() コンストラクタ

Method Summary

Modifier and Type	Method and Description
void	initialize() 初期化処理を行う。
EmbeddedMessagingProvider	setQueueNames(java.util.List<java.lang.String> names) このキューマネージャが管理するキューの論理名を設定する。 (既存の設定は全て削除される。)
static void	stopServer() 内蔵サーバを停止する。
static void	waitUntilServerStarted() 内蔵サーバが起動するまでカレントスレッドを待機させる。

Methods inherited from class nablarch.fw.messaging.provider.JmsMessagingProvider

createContext, getConnectionFactory, setConnectionFactory, setDefaultPoisonQueue, setDefaultResponseTimeout, setDefaultTimeToLive, setDestinations, setMessagingExceptionFactory, setPoisonQueueNamePattern, setRedeliveryLimit

Methods inherited from class java.lang.Object

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

Constructor Detail

EmbeddedMessagingProvider

public EmbeddedMessagingProvider()

コンストラクタ

Method Detail

stopServer

public static void stopServer()

内蔵サーバを停止する。

waitUntilServerStarted

public static void waitUntilServerStarted()
                                   throws java.lang.InterruptedException

内蔵サーバが起動するまでカレントスレッドを待機させる。

Throws:

java.lang.InterruptedException - 割り込み要求が発生した場合。もしくは、5分以上経過しても 起動が完了しなかった場合。

setQueueNames

public EmbeddedMessagingProvider setQueueNames(java.util.List<java.lang.String> names)

このキューマネージャが管理するキューの論理名を設定する。 (既存の設定は全て削除される。)

Parameters:

names - キュー名の一覧

Returns:

このオブジェクト自体

initialize

public void initialize()

初期化処理を行う。
他の実装クラスとインタフェースを合わせるためにInitializableを実装する。 Initializableを実装することで、リクエスト単体テスト時に ApplicationInitializerの リポジトリ設定の上書きを不要にしている。 本メソッドは何も処理しない。

Specified by:

initialize in interface Initializable