File tree Expand file tree Collapse file tree 2 files changed +1
-8
lines changed Expand file tree Collapse file tree 2 files changed +1
-8
lines changed Original file line number Diff line number Diff line change 19
19
examples /examples
20
20
vet
21
21
.DS_Store
22
- perfTest /
23
22
.vagrant /
24
23
local /
25
24
tls-gen /
Original file line number Diff line number Diff line change @@ -309,13 +309,7 @@ func handleConsumerClose(channelClose stream.ChannelClose) {
309
309
func startConsumer (consumerName string , streamName string ) error {
310
310
311
311
handleMessages := func (consumerContext stream.ConsumerContext , message * amqp.Message ) {
312
- //logError("consumerMessageCount StoreOffset: %s", consumerMessageCount)
313
- if atomic .AddInt32 (& consumerMessageCount , 1 )% 500 == 0 {
314
- err := consumerContext .Consumer .StoreOffset ()
315
- if err != nil {
316
- logError ("Error StoreOffset: %s" , err )
317
- }
318
- }
312
+ atomic .AddInt32 (& consumerMessageCount , 1 )
319
313
}
320
314
consumer , err := simulEnvironment .NewConsumer (
321
315
streamName ,
You can’t perform that action at this time.
0 commit comments