gearpump-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (GEARPUMP-303) add a RabbitMQ sink to integrate with gearpump
Date Fri, 05 May 2017 09:47:04 GMT

    [ https://issues.apache.org/jira/browse/GEARPUMP-303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998006#comment-15998006
] 

ASF GitHub Bot commented on GEARPUMP-303:
-----------------------------------------

Github user huafengw commented on a diff in the pull request:

    https://github.com/apache/incubator-gearpump/pull/178#discussion_r114962623
  
    --- Diff: external/rabbitmq/README.md ---
    @@ -0,0 +1,21 @@
    +# Gearpump RabbitMQ
    +
    +Gearpump integration for [RabbitMQ](https://www.rabbitmq.com/)
    +
    +## Usage
    +
    +The message type that RMQSink is able to handle including:
    +
    + 1. String
    + 2. Array[Byte]
    + 3. Sequence of type 1 and 2
    +
    +Suppose there is a DataSource Task will output above-mentioned messages, you can write
a simple application then:
    +
    +```scala
    +val sink = new RMQSink(UserConfig.empty, "$tableName")
    +val sinkProcessor = DataSinkProcessor(sink, "$sinkNum")
    +val split = Processor[DataSource]("$splitNum")
    +val computation = split ~> sinkProcessor
    +val application = StreamApplication("RabbitMQ", Graph(computation), UserConfig.empty)
    +```
    --- End diff --
    
    Probably we also need some configuration doc here, like  `rabbitmq.connection.host ` etc.


> add a RabbitMQ sink to integrate with gearpump
> ----------------------------------------------
>
>                 Key: GEARPUMP-303
>                 URL: https://issues.apache.org/jira/browse/GEARPUMP-303
>             Project: Apache Gearpump
>          Issue Type: Task
>          Components: connectors
>            Reporter: yanghua
>            Assignee: yanghua
>




--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message