()
| 113 | } |
| 114 | |
| 115 | func (z *zeroQueueConsumer) GetLastMessageIDs() ([]TopicMessageID, error) { |
| 116 | id, err := z.pc.getLastMessageID() |
| 117 | if err != nil { |
| 118 | return nil, err |
| 119 | } |
| 120 | tm := &topicMessageID{topic: z.pc.topic, track: id} |
| 121 | return []TopicMessageID{tm}, nil |
| 122 | } |
| 123 | |
| 124 | func (z *zeroQueueConsumer) Receive(ctx context.Context) (Message, error) { |
| 125 | if state := z.pc.getConsumerState(); state == consumerClosed || state == consumerClosing { |
nothing calls this directly
no test coverage detected