---
schema_version: "1"
id: ffda28c0051ecc190b9aeca9d90c176db41084b20ed70f7b1b20e417cc38b4ab
title: メッセージソースからフローへのメッセージのプッシュ
collection: mulesoft
version: current
locale: ja-jp
portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/mule-sdk/1.1/sources-push-message.md
canonical_url: https://docs.mulesoft.com/jp/mule-sdk/1.1/sources-push-message
source_site: docs.mulesoft.com
content_type: documentation
content_hash: a47d697d4d396de29f08119294adc8950438b8bc53e4a458e68fcf1a50247338
description: MuleSoft Documentation Site
release: "1.1"
latest: false
---
# メッセージソースからフローへのメッセージのプッシュ

フローの情報を生成したら、ソースは ​`SourceCallback`​ を使用してフローにその情報を送信します。最小限の HTTP リスナーの例に戻ります。

```java
public class HttpListener extends Source<InputStream, HttpRequestAttributes> {

    @Override
    public void onStart(SourceCallback<InputStream, HttpRequestAttributes> sourceCallback) throws MuleException {
        httpServer = serverProvider.connect(); (1)

        server.listen(path).onRequest(request -> { (2)
            Result<InputStream, HttpRequestAttributes> result = requestToResult(request); (3)
            sourceCallback.handle(result); (4)
        });
    }
}
```

<table><tbody><tr><td><i class="conum" data-value="1"></i><b>1</b></td><td>この例では、ConnectionProvider を使用して ​<code>HttpServer</code>​ を取得します。一般的な接続プロバイダーの場合、適切なホストとポートを使用してすでにサーバーが設定されています。</td></tr><tr><td><i class="conum" data-value="2"></i><b>2</b></td><td>リモートクライアントが HTTP 要求をサーバーにプッシュし、​<code>HttpServer</code>​ コンポーネントが各要求のソースを通知します。次に、ソースが ​<code>SourceCallback</code>​ を使用してメッセージをフローにプッシュします。</td></tr><tr><td><i class="conum" data-value="3"></i><b>3</b></td><td>メッセージは、操作が複雑な出力を伝えるために使用する同じ ​<code>Result</code>​ オブジェクトを利用して表されます。詳細は、​<a href="https://docs.mulesoft.com/jp/mule-sdk/1.1/result-object" class="xref page"><code>Result</code></a>​ オブジェクトについての説明を参照してください。</td></tr><tr><td><i class="conum" data-value="4"></i><b>4</b></td><td>この例では、​<code>SourceCallback</code>​ の ​<code>handle(Result)</code>​ メソッドを使用してメッセージを渡します。</td></tr></tbody></table>

## [](#スレッドモデル)スレッドモデル

`handle(Result)`​ メソッドを介して ​`Result`​ オブジェクトが ​`SourceCallback`​ に渡されると、メソッドを呼び出すスレッドとは異なるスレッドでメッセージ処理が非同期で実行されます。

次のステップでは、フロー処理の結果をキャッチし、必要に応じて応答を送信する方法について説明します。

## [](#次のステップ)次のステップ

- [フロー出力の取得とメッセージソースからの応答の送信](https://docs.mulesoft.com/jp/mule-sdk/1.1/sources-response)