alihan/fn-serverless
1
0
Fork 0
mirror of https://github.com/fnproject/fn.git synced 2022-10-28 21:29:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

arm overflow s/ns fix (#590)

Browse Source
This commit is contained in:
Jordan Krage
2017-03-15 09:06:09 -05:00
committed by Seif Lotfy سيف لطفي
parent ab2e6a812b
commit d860dc28fb
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
api/mqs/ironmq.go
View File

@@ -8,7 +8,6 @@ import (
"strconv"
"strings"
"sync"
"time"
"github.com/Sirupsen/logrus"
"github.com/iron-io/functions/api/models"
@@ -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") {