Repository: flink Updated Branches: refs/heads/master bdd7a114d -> e9b865793
[hotfix][docs] Fix RMQ Sink code example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9b86579 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9b86579 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e9b86579 Branch: refs/heads/master Commit: e9b86579384e58fbf58748b2b1a709d3ef754019 Parents: bdd7a11 Author: Robert Metzger <rmetz...@apache.org> Authored: Thu Aug 11 11:16:45 2016 +0200 Committer: Robert Metzger <rmetz...@apache.org> Committed: Thu Aug 11 11:16:45 2016 +0200 ---------------------------------------------------------------------- docs/apis/streaming/connectors/rabbitmq.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/e9b86579/docs/apis/streaming/connectors/rabbitmq.md ---------------------------------------------------------------------- diff --git a/docs/apis/streaming/connectors/rabbitmq.md b/docs/apis/streaming/connectors/rabbitmq.md index df8cf80..0e186e0 100644 --- a/docs/apis/streaming/connectors/rabbitmq.md +++ b/docs/apis/streaming/connectors/rabbitmq.md @@ -116,7 +116,7 @@ Example: RMQConnectionConfig connectionConfig = new RMQConnectionConfig.Builder() .setHost("localhost").setPort(5000).setUserName(..) .setPassword(..).setVirtualHost("/").build(); -stream.addSink(new RMQSink<String>(connectionConfig, "hello", new StringToByteSerializer())); +stream.addSink(new RMQSink<String>(connectionConfig, "hello", new SimpleStringSchema())); {% endhighlight %} </div> <div data-lang="scala" markdown="1"> @@ -124,7 +124,7 @@ stream.addSink(new RMQSink<String>(connectionConfig, "hello", new StringToByteSe val connectionConfig = new RMQConnectionConfig.Builder() .setHost("localhost").setPort(5000).setUserName(..) .setPassword(..).setVirtualHost("/").build() -stream.addSink(new RMQSink[String](connectionConfig, "hello", new StringToByteSerializer)) +stream.addSink(new RMQSink[String](connectionConfig, "hello", new SimpleStringSchema)) {% endhighlight %} </div> </div>
