(config adka2a.ExecutorConfig)
| 16 | } |
| 17 | |
| 18 | func newExecutorWrapper(config adka2a.ExecutorConfig) *executorWrapper { |
| 19 | return &executorWrapper{ |
| 20 | executor: adka2a.NewExecutor(config), |
| 21 | } |
| 22 | } |
| 23 | |
| 24 | func (w *executorWrapper) Execute(ctx context.Context, reqCtx *a2asrv.RequestContext, queue eventqueue.Queue) error { |
| 25 | // Create a wrapping queue that fixes events before sending them |