From 557b1da99f5a6b274214c72714511131bd099550 Mon Sep 17 00:00:00 2001 From: Gregory Eremin Date: Thu, 11 Sep 2014 14:27:34 +0400 Subject: [PATCH] Fix storage --- storage/storage.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/storage/storage.go b/storage/storage.go index 1adf629..c593f9b 100644 --- a/storage/storage.go +++ b/storage/storage.go @@ -36,7 +36,7 @@ func New(path string) (s *Storage, err error) { } func (s *Storage) Get(queue string) (message []byte, ok bool) { - if _, ok := s.counters[queue]; !ok { + if _, exist := s.counters[queue]; !exist { return } if size := s.counters[queue].distance(); size == 0 { @@ -51,14 +51,14 @@ func (s *Storage) Get(queue string) (message []byte, ok bool) { } key := makeKey(queue, index) - ok = true - - if message, err := s.kyoto.Get(key); err != nil { + message, err := s.kyoto.Get(key) + if err != nil { panic(err) } if err := s.kyoto.Remove(key); err != nil { panic(err) } + ok = true return }