()
| 3780 | } |
| 3781 | |
| 3782 | func (p AckPolicy) String() string { |
| 3783 | switch p { |
| 3784 | case AckNonePolicy: |
| 3785 | return "AckNone" |
| 3786 | case AckAllPolicy: |
| 3787 | return "AckAll" |
| 3788 | case AckExplicitPolicy: |
| 3789 | return "AckExplicit" |
| 3790 | case ackPolicyNotSet: |
| 3791 | return "Not Initialized" |
| 3792 | default: |
| 3793 | return "Unknown AckPolicy" |
| 3794 | } |
| 3795 | } |
| 3796 | |
| 3797 | // ReplayPolicy determines how the consumer should replay messages it already has queued in the stream. |
| 3798 | type ReplayPolicy int |
no outgoing calls
no test coverage detected