TODO.

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.

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.

* * <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.

MockOffsetStore is a mock of OffsetStore interface.

MockOffsetStoreMockRecorder is the mock recorder for MockOffsetStore.

go:generate mockgen -source offset_store.go -destination mock_offset_store.go -self_package github.com/swift9/rocketmq-client-go/consumer --package consumer OffsetStore.

Consuming point on consumer booting.

Message model defines the way how messages are delivered to each consumer clients.