加载中
聊聊rocketmq-client-go的strategy

序 本文主要研究一下rocketmq-client-go的strategy AllocateStrategy rocketmq-client-go-v2.0.0/consumer/strategy.go type AllocateStrategy func(string, string, []*primitive.MessageQ...

2020/07/13 22:28
126
聊聊rocketmq-client-go的remoteBrokerOffsetStore

序 本文主要研究一下rocketmq-client-go的remoteBrokerOffsetStore remoteBrokerOffsetStore rocketmq-client-go-v2.0.0/consumer/offset_store.go type remoteBrokerOffsetStore struct { ...

2020/07/12 10:35
55
聊聊rocketmq-client-go的localFileOffsetStore

序 本文主要研究一下rocketmq-client-go的localFileOffsetStore OffsetStore rocketmq-client-go-v2.0.0/consumer/offset_store.go type OffsetStore interface { persist(mqs []*primitive...

2020/07/11 10:20
39
聊聊rocketmq-client-go的pushConsumer

序 本文主要研究一下rocketmq-client-go的pushConsumer pushConsumer rocketmq-client-go-v2.0.0/consumer/push_consumer.go type pushConsumer struct { *defaultConsumer queueFlowContro...

2020/07/10 22:02
142
聊聊rocketmq-client-go的PullConsumer

序 本文主要研究一下rocketmq-client-go的PullConsumer PullConsumer rocketmq-client-go-v2.0.0/consumer/pull_consumer.go type PullConsumer interface { // Start Start() // Shutdown ...

聊聊rocketmq-client-go的ACLInterceptor

序 本文主要研究一下rocketmq-client-go的ACLInterceptor ACLInterceptor rocketmq-client-go-v2.0.0/internal/remote/interceptor.go func ACLInterceptor(credentials primitive.Credenti...

2020/07/08 22:30
86
聊聊rocketmq-client-go的TraceInterceptor

序 本文主要研究一下rocketmq-client-go的TraceInterceptor TraceInterceptor rocketmq-client-go-v2.0.0/producer/interceptor.go // WithTrace support rocketmq trace: https://github.c...

2020/07/07 21:07
86
聊聊rocketmq-client-go的transactionProducer

序 本文主要研究一下rocketmq-client-go的transactionProducer transactionProducer rocketmq-client-go-v2.0.0/producer/producer.go type transactionProducer struct { producer *defaul...

2020/07/06 23:23
109
聊聊rocketmq-client-go的defaultProducer

序 本文主要研究一下rocketmq-client-go的defaultProducer defaultProducer rocketmq-client-go-v2.0.0/producer/producer.go type defaultProducer struct { group string client internal...

2020/07/05 10:51
79
聊聊rocketmq-client-go的api.go

序 本文主要研究一下rocketmq-client-go的api.go Producer rocketmq-client-go-v2.0.0/api.go type Producer interface { Start() error Shutdown() error SendSync(ctx context.Context, m...

2020/07/04 10:18
153
artemis小结

序 本文主要小结一下artemis的一些知识点 artemis知识点 消息模型 它实现了mqtt、aqmp、stomp协议,jms的api,还提供了rest的api;其模型跟aqmp很像,用address、queue来抽象,其Routing Typ...

2020/02/22 22:05
725
聊聊artemis的ResourceLimitSettings

序 本文主要研究一下artemis的ResourceLimitSettings ResourceLimitSettings activemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/settings/impl/Resou...

2020/02/21 20:04
121
聊聊artemis的DelayedAddRedistributor

序 本文主要研究一下artemis的DelayedAddRedistributor addRedistributor activemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl....

2020/02/20 20:59
132
聊聊artemis的ConnectionLoadBalancingPolicy

序 本文主要研究一下artemis的ConnectionLoadBalancingPolicy ServerLocatorImpl.selectConnector activemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis...

2020/02/19 21:03
166
聊聊artemis的handleConnectionFailure

序 本文主要研究一下artemis的handleConnectionFailure handleConnectionFailure activemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/imp...

2020/02/18 20:27
176
聊聊artemis的callFailoverTimeout

序 本文主要研究一下artemis的callFailoverTimeout establishNewConnection activemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/Cli...

2020/02/17 20:06
119
聊聊artemis的MessageLoadBalancingType

序 本文主要研究一下artemis的MessageLoadBalancingType MessageLoadBalancingType activemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluste...

2020/02/16 11:25
139
聊聊artemis的HAManager

序 本文主要研究一下artemis的HAManager HAManager activemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ha/HAManager.java public int...

2020/02/15 10:10
139
聊聊artemis的FederatedQueue

序 本文主要研究一下artemis的FederatedQueue FederatedQueue activemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/federation/queue/Federated...

2020/02/14 19:39
113
聊聊artemis的FederationManager

序 本文主要研究一下artemis的FederationManager FederationManager activemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/federation/Federatio...

2020/02/13 20:43
110

没有更多内容

加载失败,请刷新页面

返回顶部
顶部