EventsQueue creates a new instance of services.PushQueue
()
| 505 | |
| 506 | // EventsQueue creates a new instance of services.PushQueue |
| 507 | func (container *Container) EventsQueue() (queue services.PushQueue) { |
| 508 | container.logger.Debug("creating events services.PushQueue") |
| 509 | |
| 510 | if os.Getenv("EVENTS_QUEUE_TYPE") == "emulator" { |
| 511 | return container.EmulatorEventsQueue() |
| 512 | } |
| 513 | |
| 514 | return container.CloudTaskEventsQueue() |
| 515 | } |
| 516 | |
| 517 | // EmulatorEventsQueue creates an in process instance of events services.PushQueue |
| 518 | func (container *Container) EmulatorEventsQueue() (queue services.PushQueue) { |
no test coverage detected