Skip to content

Commit

Permalink
arm overflow s/ns fix (#590)
Browse files Browse the repository at this point in the history
  • Loading branch information
jmank88 authored and seiflotfy committed Mar 15, 2017
1 parent ab2e6a8 commit d860dc2
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions api/mqs/ironmq.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ import (
"strconv"
"strings"
"sync"
"time"

"github.com/Sirupsen/logrus"
"github.com/iron-io/functions/api/models"
Expand Down Expand Up @@ -114,7 +113,7 @@ func (mq *IronMQ) Reserve(ctx context.Context) (*models.Task, error) {
var messages []ironmq.Message
var err error
for i := 2; i >= 0; i-- {
messages, err = mq.queues[i].LongPoll(1, int(time.Minute), 0 /* wait */, false /* delete */)
messages, err = mq.queues[i].LongPoll(1, 60, 0 /* wait */, false /* delete */)
if err != nil {
// It is OK if the queue does not exist, it will be created when a message is queued.
if !strings.Contains(err.Error(), "404 Not Found") {
Expand Down

0 comments on commit d860dc2

Please sign in to comment.