Skip to content

Add support of TLS connections #17

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
speedywizard merged 5 commits into from
Nov 22, 2016
Merged

Add support of TLS connections #17

Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
db97c9e
Add support of TLS connections (amqps://)
Nov 16, 2016
2f246b6
Add support of TLS connections (amqps://)
Nov 16, 2016
1c311a9
Use DialConfig instead of dialTLS
Nov 18, 2016
d557f87
Remove missed testing lines
Nov 18, 2016
31a7476
Set default heartbeat to 10s
Nov 18, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 14 additions & 1 deletion client.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,7 @@ type Client struct {
bo Backoffer
attempt int32
l sync.Mutex
config amqp.Config
}

// Declare used to declare queues/exchanges/bindings.
Expand Down Expand Up @@ -118,7 +119,12 @@ func (c *Client) Loop() bool {
atomic.AddInt32(&c.attempt, 1)
}

conn, err = amqp.Dial(c.addr)
// set default Heartbeat to 10 seconds like in original amqp.Dial
if c.config.Heartbeat == 0 {
c.config.Heartbeat = 10 * time.Second
}

conn, err = amqp.DialConfig(c.addr, c.config)

if c.reportErr(err) {
return true
Expand Down Expand Up @@ -265,3 +271,10 @@ func BlockingChan(blockingChan chan amqp.Blocking) ClientOpt {
c.blocking = blockingChan
}
}

// Config is a functional option, used to setup extended amqp configuration
func Config(config amqp.Config) ClientOpt {
return func(c *Client) {
c.config = config
}
}