Skip to content

Commit e130268

Browse files
committed
formatting
Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>
1 parent 6e42aba commit e130268

1 file changed

Lines changed: 1 addition & 5 deletions

File tree

pkg/rabbitmqamqp/amqp_connection.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -333,13 +333,9 @@ func (a *AmqpConnection) NewRequester(ctx context.Context, options *RequesterOpt
333333
done: make(chan struct{}),
334334
}
335335

336-
settleStrategy := ExplicitSettle
337-
if options.SettleStrategy == DirectReplyTo {
338-
settleStrategy = DirectReplyTo
339-
}
340336
// Create consumer for receiving replies
341337
consumer, err := a.NewConsumer(ctx, queueName, &ConsumerOptions{
342-
SettleStrategy: settleStrategy,
338+
SettleStrategy: options.SettleStrategy,
343339
})
344340
if err != nil {
345341
_ = publisher.Close(ctx) // cleanup publisher on failure

0 commit comments

Comments
 (0)