|
|
@ -87,7 +87,7 @@ if err != nil { |
|
|
### Default options |
|
|
### Default options |
|
|
|
|
|
|
|
|
```go |
|
|
```go |
|
|
publisher, returns, err := rabbitmq.NewPublisher("amqp://user:pass@localhost", amqp091.Config{}) |
|
|
|
|
|
|
|
|
publisher, err := rabbitmq.NewPublisher("amqp://user:pass@localhost", amqp091.Config{}) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
log.Fatal(err) |
|
|
log.Fatal(err) |
|
|
} |
|
|
} |
|
|
@ -100,7 +100,7 @@ if err != nil { |
|
|
### With options |
|
|
### With options |
|
|
|
|
|
|
|
|
```go |
|
|
```go |
|
|
publisher, returns, err := rabbitmq.NewPublisher( |
|
|
|
|
|
|
|
|
publisher, err := rabbitmq.NewPublisher( |
|
|
"amqp://user:pass@localhost", |
|
|
"amqp://user:pass@localhost", |
|
|
amqp091.Config{}, |
|
|
amqp091.Config{}, |
|
|
// can pass nothing for no logging |
|
|
// can pass nothing for no logging |
|
|
|