nablarch.test.core.messaging

クラス EmbeddedMessagingProvider

java.lang.Object

nablarch.fw.messaging.provider.JmsMessagingProvider

nablarch.test.core.messaging.EmbeddedMessagingProvider

すべての実装されたインタフェース:

Initializable, MessagingProvider

public class EmbeddedMessagingProvider
extends JmsMessagingProvider
implements Initializable

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

ネストされたクラスのサマリー

クラスから継承されたネストされたクラス/インタフェース nablarch.fw.messaging.provider.JmsMessagingProvider

JmsMessagingProvider.Context

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
EmbeddedMessagingProvider() コンストラクタ

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	initialize() 初期化処理を行う。
EmbeddedMessagingProvider	setQueueNames(java.util.List<java.lang.String> names) このキューマネージャが管理するキューの論理名を設定する。
static void	stopServer() 内蔵サーバを停止する。
static void	waitUntilServerStarted() 内蔵サーバが起動するまでカレントスレッドを待機させる。

クラスから継承されたメソッド nablarch.fw.messaging.provider.JmsMessagingProvider

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

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

EmbeddedMessagingProvider

public EmbeddedMessagingProvider()

コンストラクタ

メソッドの詳細

stopServer

public static void stopServer()

内蔵サーバを停止する。

waitUntilServerStarted

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

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

例外:

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

setQueueNames

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

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

パラメータ:

names - キュー名の一覧

戻り値:

このオブジェクト自体

initialize

public void initialize()

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

定義:

initialize インタフェース内 Initializable