# Functions
TODO.
CreateReplyMessage build reply message from the request message.
NewMockOffsetStore creates a new mock instance.
WithGroupName set group name address.
WithChainConsumerInterceptor returns a ConsumerOption that specifies the chained interceptor for consumer.
WithMaxReconsumeTimes set MaxReconsumeTimes of options, if message reconsume greater than MaxReconsumeTimes, it will be sent to retry or dlq topic.
WithNameServer set NameServer address, only support one NameServer cluster in alpha2.
WithNameServerDomain set NameServer domain.
WithNamespace set the namespace of consumer.
WithNsResolver set nameserver resolver to fetch nameserver addr.
WithRetry return a Option that specifies the retry times when send failed.
WithTrace support rocketmq trace: https://github.com/apache/rocketmq/wiki/RIP-6-Message-Trace.
WithUnitName set the name of specified unit.
# Constants
*
* <ul>
* Keywords:
* <li>{@code AND, OR, NOT, BETWEEN, IN, TRUE, FALSE, IS, NULL}</li>
* </ul>
* <p/>
* <ul>
* Data type:
* <li>Boolean, like: TRUE, FALSE</li>
* <li>String, like: 'abc'</li>
* <li>Decimal, like: 123</li>
* <li>Float number, like: 3.1415</li>
* </ul>
* <p/>
* <ul>
* Grammar:
* <li>{@code AND, OR}</li>
* <li>{@code >, >=, <, <=, =}</li>
* <li>{@code BETWEEN A AND B}, equals to {@code >=A AND <=B}</li>
* <li>{@code NOT BETWEEN A AND B}, equals to {@code >B OR <A}</li>
* <li>{@code IN ('a', 'b')}, equals to {@code ='a' OR ='b'}, this operation only support String type.</li>
* <li>{@code IS NULL}, {@code IS NOT NULL}, check parameter whether is null, or not.</li>
* <li>{@code =TRUE}, {@code =FALSE}, check parameter whether is true, or false.</li>
* </ul>
* <p/>
* <p>
* Example:
* (a > 10 AND a < 100) OR (b IS NOT NULL AND b=TRUE)
* </p>
*/.
*
* Only support or operation such as
* "tag1 || tag2 || tag3", <br>
* If null or * expression, meaning subscribe all.
# Variables
ErrNoNewMsg returns a "no new message found".
# Structs
MockOffsetStore is a mock of OffsetStore interface.
MockOffsetStoreMockRecorder is the mock recorder for MockOffsetStore.
# Interfaces
go:generate mockgen -source offset_store.go -destination mock_offset_store.go -self_package github.com/apache/rocketmq-client-go/v2/consumer --package consumer OffsetStore.
# Type aliases
Consuming point on consumer booting.
Message model defines the way how messages are delivered to each consumer clients.