flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject flink git commit: [hotfix][docs] Fix RMQ Sink code example
Date Thu, 11 Aug 2016 09:17:33 GMT
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 <rmetzger@apache.org>
Authored: Thu Aug 11 11:16:45 2016 +0200
Committer: Robert Metzger <rmetzger@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>


Mime
View raw message