beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jean-Baptiste Onofré (JIRA) <>
Subject [jira] [Created] (BEAM-569) JMS IO should be able to wait for messages (timeout)
Date Fri, 19 Aug 2016 11:34:21 GMT
Jean-Baptiste Onofré created BEAM-569:

             Summary: JMS IO should be able to wait for messages (timeout)
                 Key: BEAM-569
             Project: Beam
          Issue Type: Improvement
          Components: sdk-java-extensions
            Reporter: Jean-Baptiste Onofré
            Assignee: Jean-Baptiste Onofré

Right now, the JMS IO source doesn't wait for new message on the JMS destination (it uses
{{receiveNoWait()}} method on the consumer).

I think, it's worth to give the possibility for the user to define the behavior.

I propose to introduce {{withTimeout()}} configuration on JMS IO:
- if the user defines {{-1}}, it means infinite timeout, so the reader will use {{consumer.receive()}}
and the source will wait for new messages on the destination
- if the user defines {{0}}, it means the current behavior (and default): the reader will
use {{consumer.receiveNoWait()}}.
- if the user defines any positive value, it's actually the timeout to wait for new messages:
the reader will use {{consumer.receive(timeout)}}.

This message was sent by Atlassian JIRA

View raw message