SingleNodeIntegrationTestSupport (Spring XD 1.3.2.RELEASE API)

java.lang.Object
- org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport

```
public class SingleNodeIntegrationTestSupport
extends java.lang.Object
```
SingleNodeApplication でストリームをテストするために使用されるメソッドを提供するヘルパークラス。ストリームの作成、デプロイ、破棄に使用されるコンポーネントとメソッドを公開し、MessageBus へのアクセスを提供します。さらに、ローカルリソースの場所 (デフォルト: "file:./config") に含まれるモジュールの登録をサポートします。予想される状態が検証されるか、操作がタイムアウトするまで、すべての操作がブロックされることに注意してください。
作成者:
David Turanski, Ilayaperumal Gopinathan

コンストラクター概要

コンストラクター
コンストラクターと説明
`SingleNodeIntegrationTestSupport(SingleNodeApplication application)` カスタムモジュールのテストに便利なコンストラクター

方法の概要

メソッド
修飾子と型	メソッドと説明
`void`	`addModuleRegistry(ModuleRegistry moduleRegistry)`
`void`	`addPathListener(java.lang.String path, org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener)` 指定されたパスに `PathChildrenCacheListener` を追加します。
`boolean`	`createAndDeployStream(StreamDefinition definition)` ストリームを作成してデプロイします。
`void`	`deleteStream(java.lang.String name)` ストリームを削除します。
`boolean`	`deployStream(StreamDefinition definition)` ストリームをデプロイします。
`boolean`	`deployStream(StreamDefinition definition, java.util.Map<java.lang.String,java.lang.String> properties)` プロパティを使用してストリームをデプロイします。
`boolean`	`deployStream(StreamDefinition definition, java.util.Map<java.lang.String,java.lang.String> properties, boolean allowIncomplete)` プロパティ付きのストリームをデプロイし、不完全なデプロイで戻りを許可する
`java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,Module>>`	`getDeployedModules()` 現在デプロイされているすべてのモジュールを取得します。
`Module`	`getModule(java.lang.String streamName, java.lang.String moduleName, int index)` デプロイされたモジュールインスタンスを取得します。
`JobDefinitionRepository`	`jobDefinitionRepository()`
`JobRepository`	`jobRepository()`
`ResourceStateVerifier`	`jobStateVerifier()`
`MessageBusSupport`	`messageBus()`
`void`	`removePathListener(java.lang.String path, org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener)` 指定されたパスの `PathChildrenCacheListener` を削除します。
`StreamDefinitionRepository`	`streamDefinitionRepository()`
`StreamDeployer`	`streamDeployer()`
`StreamRepository`	`streamRepository()`
`ResourceStateVerifier`	`streamStateVerifier()`
`boolean`	`undeployAndDestroyStream(StreamDefinition definition)` ストリームをアンデプロイして破棄します。
`boolean`	`undeployStream(StreamDefinition definition)` ストリームをアンデプロイします。
`ZooKeeperConnection`	`zooKeeperConnection()`

クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- コンストラクターの詳細
  - SingleNodeIntegrationTestSupport
```
public SingleNodeIntegrationTestSupport(SingleNodeApplication application)
```
    カスタムモジュールのテストに便利なコンストラクター
    パラメーター:
    application - SingleNodeApplication
- メソッドの詳細
  - addModuleRegistry
```
public final void addModuleRegistry(ModuleRegistry moduleRegistry)
```
  - getDeployedModules
```
public final java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,Module>> getDeployedModules()
```
    現在デプロイされているすべてのモジュールを取得します。
    戻り値:
    ストリーム名をキーとするマップ。各エントリは、モジュールインデックス (ストリームの左から右の順序) によるモジュールのマップです。
  - streamDeployer
```
public final StreamDeployer streamDeployer()
```
  - streamRepository
```
public final StreamRepository streamRepository()
```
  - streamStateVerifier
```
public final ResourceStateVerifier streamStateVerifier()
```
  - jobStateVerifier
```
public final ResourceStateVerifier jobStateVerifier()
```
  - jobRepository
```
public final JobRepository jobRepository()
```
  - jobDefinitionRepository
```
public final JobDefinitionRepository jobDefinitionRepository()
```
  - streamDefinitionRepository
```
public final StreamDefinitionRepository streamDefinitionRepository()
```
  - messageBus
```
public final MessageBusSupport messageBus()
```
  - deployStream
```
public final boolean deployStream(StreamDefinition definition)
```
    ストリームをデプロイします。
    パラメーター:
    definition - ストリーム定義
    戻り値:
    操作が成功した場合は true
  - deployStream
```
public final boolean deployStream(StreamDefinition definition,
                   java.util.Map<java.lang.String,java.lang.String> properties)
```
    プロパティを使用してストリームをデプロイします。
    パラメーター:
    definition - ストリーム定義
    properties - デプロイプロパティ
    戻り値:
    操作が成功した場合は true
  - deployStream
```
public final boolean deployStream(StreamDefinition definition,
                   java.util.Map<java.lang.String,java.lang.String> properties,
                   boolean allowIncomplete)
```
    プロパティ付きのストリームをデプロイし、不完全なデプロイで戻りを許可する
    パラメーター:
    definition - ストリーム定義
    properties - デプロイプロパティ
    allowIncomplete - 未完了の状態とデプロイ済みの状態を許可する
    戻り値:
    操作が成功した場合は true
  - createAndDeployStream
```
public final boolean createAndDeployStream(StreamDefinition definition)
```
    ストリームを作成してデプロイします。
    パラメーター:
    definition - ストリーム定義
    戻り値:
    操作が成功した場合は true です。
  - undeployStream
```
public final boolean undeployStream(StreamDefinition definition)
```
    ストリームをアンデプロイします。
    パラメーター:
    definition - ストリーム定義
    戻り値:
    操作が成功した場合は true
  - undeployAndDestroyStream
```
public final boolean undeployAndDestroyStream(StreamDefinition definition)
```
    ストリームをアンデプロイして破棄します。
    パラメーター:
    definition - ストリーム定義
    戻り値:
    操作が成功した場合は true
  - deleteStream
```
public final void deleteStream(java.lang.String name)
```
    ストリームを削除します。
    パラメーター:
    name - ストリーム名
  - getModule
```
public final Module getModule(java.lang.String streamName,
               java.lang.String moduleName,
               int index)
```
    デプロイされたモジュールインスタンスを取得します。
    パラメーター:
    streamName - ストリーム名
    moduleName - モジュール名
    index - ストリーム内のモジュールのインデックス。0 から始まり、左から右に順序付けられます。
    戻り値:
    モジュール
  - zooKeeperConnection
```
public ZooKeeperConnection zooKeeperConnection()
```
    戻り値:
    zookeeperConnection
  - addPathListener
```
public void addPathListener(java.lang.String path,
                   org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener)
```
    指定されたパスに PathChildrenCacheListener を追加します。
    パラメーター:
    path - 子供たちの言うことを聞ける道
    listener - 子供たちの聞き手
  - removePathListener
```
public void removePathListener(java.lang.String path,
                      org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener)
```
    指定されたパスの PathChildrenCacheListener を削除します。
    パラメーター:
    path - 子供たちの言うことを聞ける道
    listener - 子供たちの聞き手

クラス SingleNodeIntegrationTestSupport

コンストラクター概要

方法の概要

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

コンストラクターの詳細

SingleNodeIntegrationTestSupport

メソッドの詳細

addModuleRegistry

getDeployedModules

streamDeployer

streamRepository

streamStateVerifier

jobStateVerifier

jobRepository

jobDefinitionRepository

streamDefinitionRepository

messageBus

deployStream

deployStream

deployStream

createAndDeployStream

undeployStream

undeployAndDestroyStream

deleteStream

getModule

zooKeeperConnection

addPathListener

removePathListener