diff options
Diffstat (limited to 'client/lib/rendezvous.go')
| -rw-r--r-- | client/lib/rendezvous.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/client/lib/rendezvous.go b/client/lib/rendezvous.go index 908b2ff..f25212c 100644 --- a/client/lib/rendezvous.go +++ b/client/lib/rendezvous.go @@ -94,11 +94,11 @@ func newBrokerChannelFromConfig(config ClientConfig) (*BrokerChannel, error) { if config.AmpCacheURL != "" || config.BrokerURL != "" { log.Fatalln("Multiple rendezvous methods specified. " + rendezvousErrorMsg) } - if config.SQSAccessKeyID == "" || config.SQSSecretKey == "" { - log.Fatalln("sqsakid and sqsskey must be specified to use SQS rendezvous method.") + if config.SQSCredsStr == "" { + log.Fatalln("sqscreds must be specified to use SQS rendezvous method.") } log.Println("Through SQS queue at:", config.SQSQueueURL) - rendezvous, err = newSQSRendezvous(config.SQSQueueURL, config.SQSAccessKeyID, config.SQSSecretKey, brokerTransport) + rendezvous, err = newSQSRendezvous(config.SQSQueueURL, config.SQSCredsStr, brokerTransport) } else if config.AmpCacheURL != "" && config.BrokerURL != "" { log.Println("Through AMP cache at:", config.AmpCacheURL) rendezvous, err = newAMPCacheRendezvous( |