Skip to content

Commit

Permalink
Merge pull request nsqio#87 from mreiferson/fix_disable_identify_87
Browse files Browse the repository at this point in the history
Config doesn't accept -1 for output_buffer_timeout
  • Loading branch information
jehiah committed Oct 24, 2014
2 parents 61012eb + 30442ee commit 760d55a
Showing 1 changed file with 10 additions and 2 deletions.
12 changes: 10 additions & 2 deletions conn.go
Original file line number Diff line number Diff line change
Expand Up @@ -280,10 +280,18 @@ func (c *Conn) identify() (*IdentifyResponse, error) {
ci["deflate_level"] = c.config.DeflateLevel
ci["snappy"] = c.config.Snappy
ci["feature_negotiation"] = true
ci["heartbeat_interval"] = int64(c.config.HeartbeatInterval / time.Millisecond)
if c.config.HeartbeatInterval == -1 {
ci["heartbeat_interval"] = -1
} else {
ci["heartbeat_interval"] = int64(c.config.HeartbeatInterval / time.Millisecond)
}
ci["sample_rate"] = c.config.SampleRate
ci["output_buffer_size"] = c.config.OutputBufferSize
ci["output_buffer_timeout"] = int64(c.config.OutputBufferTimeout / time.Millisecond)
if c.config.OutputBufferTimeout == -1 {
ci["output_buffer_timeout"] = -1
} else {
ci["output_buffer_timeout"] = int64(c.config.OutputBufferTimeout / time.Millisecond)
}
ci["msg_timeout"] = int64(c.config.MsgTimeout / time.Millisecond)
cmd, err := Identify(ci)
if err != nil {
Expand Down

0 comments on commit 760d55a

Please sign in to comment.