| 398 | } |
| 399 | |
| 400 | func (m *manager) GetQueuePool(name string) (broker.AsyncQueuePool, error) { |
| 401 | item, err := m.internalRegistry.Get("queue-"+name, registry.WithType(pb.ItemType_GENERIC)) |
| 402 | if err != nil { |
| 403 | return nil, errors.Wrap(err, "cannot get queue-"+name+" from registry") |
| 404 | } |
| 405 | var pool broker.AsyncQueuePool |
| 406 | if ok := item.As(&pool); !ok { |
| 407 | return nil, errors.New("wrong registry item format for queue-" + name) |
| 408 | } |
| 409 | return pool, nil |
| 410 | } |
| 411 | |
| 412 | func (m *manager) GetCache(ctx context.Context, name string, resolutionData map[string]interface{}) (cache.Cache, error) { |
| 413 | item, err := m.internalRegistry.Get("cache-"+name, registry.WithType(pb.ItemType_GENERIC)) |