diff --git a/README.md b/README.md index ea879ce..cf361d5 100644 --- a/README.md +++ b/README.md @@ -42,7 +42,7 @@ Queue Handlers are simple Go functions that accept a `Context` parameter. **Example**: Add a listener on the `hello_world` queue ```go -nq, _ := neoq.New(neoq.ConnectionString("postgres://postgres:postgres@localhost:5432/neoq?sslmode=disable")) +nq, _ := neoq.New(neoq.ConnectionString("postgres://postgres:postgres@localhost:5432/neoq")) nq.Listen("hello_world", neoq.NewHandler(func(ctx context.Context) (err error) { j, err := neoq.JobFromContext(ctx) log.Println("got job id:", j.ID, "messsage:", j.Payload["message"]) @@ -55,7 +55,7 @@ nq.Listen("hello_world", neoq.NewHandler(func(ctx context.Context) (err error) { **Example**: Add a "Hello World" job to the `hello_world` queue ```go -nq, _ := neoq.New(neoq.ConnectionString("postgres://postgres:postgres@localhost:5432/neoq?sslmode=disable")) +nq, _ := neoq.New(neoq.ConnectionString("postgres://postgres:postgres@localhost:5432/neoq")) jid, _ := nq.Enqueue(neoq.Job{ Queue: "hello_world", Payload: map[string]interface{}{ diff --git a/examples/listen_for_jobs/main.go b/examples/listen_for_jobs/main.go index 92808a9..6aad8f8 100644 --- a/examples/listen_for_jobs/main.go +++ b/examples/listen_for_jobs/main.go @@ -11,7 +11,7 @@ func main() { var err error const queue = "foobar" // - nq, _ := neoq.New("postgres://postgres:postgres@127.0.0.1:5432/neoq?sslmode=disable") + nq, _ := neoq.New(neoq.ConnectionString("postgres://postgres:postgres@127.0.0.1:5432/neoq")) handler := neoq.NewHandler(func(ctx context.Context) (err error) { var j *neoq.Job diff --git a/neoq.go b/neoq.go index f81df89..f01707f 100644 --- a/neoq.go +++ b/neoq.go @@ -32,7 +32,7 @@ const ( JobStatusNew = "new" JobStatusProcessed = "processed" JobStatusFailed = "failed" - DefaultPgConnectionString = "postgres://postgres:postgres@127.0.0.1:5432/neoq?sslmode=disable" + DefaultPgConnectionString = "postgres://postgres:postgres@127.0.0.1:5432/neoq" DefaultTransactionTimeout = 60000 //ms DefaultHandlerDeadline = 30000 //ms DuplicateJobID = -1 diff --git a/neoq_test.go b/neoq_test.go index 772885b..4930941 100644 --- a/neoq_test.go +++ b/neoq_test.go @@ -11,7 +11,7 @@ import ( func TestWorkerListenConn(t *testing.T) { const queue = "foobar" - pgBackend, err := NewPgBackend("postgres://postgres:postgres@127.0.0.1:5432/neoq?sslmode=disable") + pgBackend, err := NewPgBackend("postgres://postgres:postgres@127.0.0.1:5432/neoq") if err != nil { t.Fatal(err) }