Closed mirror6Y closed 3 weeks ago
type rocketmqBroker struct { sync.RWMutex
options broker.Options enableTrace bool nameServers []string nameServerUrl string credentials rocketmqOption.Credentials retryCount int instanceName string groupName string namespace string connected bool producers map[string]rmqClient.Producer consumer rmqClient.SimpleConsumer subscribers *broker.SubscriberSyncMap subscriptionExpressions map[string]*rmqClient.FilterExpression awaitDuration time.Duration maxMessageNum int32 invisibleDuration time.Duration receiveInterval time.Duration producerTracer *tracing.Tracer consumerTracer *tracing.Tracer
}
SimpleConsumer 推荐使用单例模式
mirror6Y
commented
3 weeks ago mirror6Y
commented
3 weeks ago
}