Skip to content

Commit

Permalink
Merge pull request #52 from haskell-works/no-event-poll-on-message
Browse files Browse the repository at this point in the history
No event poll on message
  • Loading branch information
AlexeyRaga authored Mar 15, 2018
2 parents cbfac15 + 956e832 commit db7acdf
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion hw-kafka-client.cabal
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
name: hw-kafka-client
version: 2.3.3
version: 2.4.0
homepage: https://github.com/haskell-works/hw-kafka-client
bug-reports: https://github.com/haskell-works/hw-kafka-client/issues
license: MIT
Expand Down
2 changes: 1 addition & 1 deletion src/Kafka/Consumer.hs
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ pollMessage :: MonadIO m
-> Timeout -- ^ the timeout, in milliseconds
-> m (Either KafkaError (ConsumerRecord (Maybe BS.ByteString) (Maybe BS.ByteString))) -- ^ Left on error or timeout, right for success
pollMessage c@(KafkaConsumer _ (KafkaConf _ qr _)) (Timeout ms) = liftIO $ do
pollConsumerEvents c Nothing
-- pollConsumerEvents c Nothing
mbq <- readIORef qr
case mbq of
Nothing -> return . Left $ KafkaBadSpecification "Messages queue is not configured, internal error, fatal."
Expand Down

0 comments on commit db7acdf

Please sign in to comment.