jadudm/liteq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

pool size of 1

Browse Source
This commit is contained in:
Seb
2024-02-20 16:10:55 -08:00
parent 043c5c2703
commit a0757c7ec6
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
internal/jobs_test.go
View File

@@ -224,7 +224,7 @@ func Test_Consume(t *testing.T) {
go func() { go func() {
jqueue.Consume(ctx, internal.ConsumeParams{ jqueue.Consume(ctx, internal.ConsumeParams{
Queue: "q1", Queue: "q1",
PoolSize: 10, PoolSize: 1,
Worker: func(ctx context.Context, job *internal.Job) error { Worker: func(ctx context.Context, job *internal.Job) error {
q1 <- job.Job q1 <- job.Job
if job.Job == "q1-99" { if job.Job == "q1-99" {
@@ -243,7 +243,7 @@ func Test_Consume(t *testing.T) {
go func() { go func() {
jqueue.Consume(ctx2, internal.ConsumeParams{ jqueue.Consume(ctx2, internal.ConsumeParams{
Queue: "q2", Queue: "q2",
PoolSize: 7, PoolSize: 1,
Worker: func(ctx context.Context, job *internal.Job) error { Worker: func(ctx context.Context, job *internal.Job) error {
q2 <- job.Job q2 <- job.Job
if job.Job == "q2-99" { if job.Job == "q2-99" {
@@ -357,7 +357,7 @@ func Test_VisibilityTimeout(t *testing.T) {
go func() { go func() {
jqueue.Consume(ctx, internal.ConsumeParams{ jqueue.Consume(ctx, internal.ConsumeParams{
Queue: "", Queue: "",
PoolSize: 6, PoolSize: 1,
VisibilityTimeout: 1, VisibilityTimeout: 1,
OnEmptySleep: 100 * time.Millisecond, OnEmptySleep: 100 * time.Millisecond,
Worker: func(ctx context.Context, job *internal.Job) error { Worker: func(ctx context.Context, job *internal.Job) error {