Skip to content

RabbitListener can not Manual ack calls are supported #44

@maringpcoder

Description

@maringpcoder

In RabbitListener I see the following

go func() {
			for d := range msg {

				if err := q.handler.Consume(string(d.Body)); err != nil {
					logx.Errorf("Error on consuming: %s, error: %v", string(d.Body), err)
				}
			}
		}()

Is it possible to call AutoAck manually like this:

go func() {
			for d := range msg {

				if err := q.handler.Consume(string(d.Body)); err != nil {
					logx.Errorf("Error on consuming: %s, error: %v", string(d.Body), err)
				}else if !que.AutoAck {
					d.Ack(que.AutoAck)
				}
			}
		}()

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions