EmulatorEventsQueue creates an in process instance of events services.PushQueue
()
| 516 | |
| 517 | // EmulatorEventsQueue creates an in process instance of events services.PushQueue |
| 518 | func (container *Container) EmulatorEventsQueue() (queue services.PushQueue) { |
| 519 | container.logger.Debug("creating emulator events services.PushQueue") |
| 520 | return services.EmulatorPushQueue( |
| 521 | container.Logger(), |
| 522 | container.Tracer(), |
| 523 | container.HTTPClient("emulator_events_queue"), |
| 524 | container.EventsQueueConfiguration(), |
| 525 | ) |
| 526 | } |
| 527 | |
| 528 | // CloudTaskEventsQueue creates a Google cloud task instance of events services.PushQueue |
| 529 | func (container *Container) CloudTaskEventsQueue() (queue services.PushQueue) { |
no test coverage detected