(ctx context.Context, _ *MessageIncoming)
| 355 | db := openDB(t) |
| 356 | queueName := t.Name() |
| 357 | _, _ = db.ExecContext(ctx, schema.GenerateDropTableQuery(queueName)) |
| 358 | _, err := db.ExecContext(ctx, generateCreateTableWithoutIndexesQuery(queueName)) |
| 359 | require.NoError(t, err) |
| 360 | t.Cleanup(func() { |
| 361 | db := openDB(t) |
| 362 | _, err := db.ExecContext(ctx, schema.GenerateDropTableQuery(queueName)) |
| 363 | require.NoError(t, err) |
nothing calls this directly
no outgoing calls
no test coverage detected