Update for new generic remote storage.
This commit is contained in:
parent
a6931b71e8
commit
d41d91388f
|
@ -74,7 +74,7 @@ func New(o *Options) (*Storage, error) {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
s.queues = append(s.queues, NewStorageQueueManager(c, 100*1024))
|
s.queues = append(s.queues, NewStorageQueueManager(c, nil))
|
||||||
}
|
}
|
||||||
if len(s.queues) == 0 {
|
if len(s.queues) == 0 {
|
||||||
return nil, nil
|
return nil, nil
|
||||||
|
|
Loading…
Reference in New Issue