MCPcopy Index your code
hub / github.com/DarkPhoenixs/message-queue-client-framework

github.com/DarkPhoenixs/message-queue-client-framework @v1.5.11

Chat with this repo
repository ↗ · DeepWiki ↗ · release v1.5.11 ↗ · + Follow
977 symbols 3,532 edges 156 files 432 documented · 44%
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

Message Queue Client Framework

Organization Build Status Codecov Maven Central GitHub release License

This is a message queue client framework with Apache Kafka & Apache ActiveMQ & Apache RocketMQ

Documentation

The documentation is available at Wiki.

Download

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>x.x.x</version>
</dependency>

Gradle

compile 'org.darkphoenixs:messagequeue-framework:x.x.x'

SBT

libraryDependencies += "org.darkphoenixs" % "messagequeue-framework" % "x.x.x"

License

Copyright 2015-2020 Dark Phoenix's (Open-Source Organization).

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

     http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

Extension points exported contracts — how you extend this code

MQProducer (Interface)
Title: MQProducer Description: 生产者接口 @author Victor.Zxy @version 1.0 @since 2015-06-01 [6 implementers]
src/main/java/org/darkphoenixs/mq/producer/MQProducer.java
MQMessageDecoder (Interface)
Title: MQMessageDecoder Description: 消息解码器接口 @author Victor.Zxy @version 1.0 @since 2015-06-01 [6 implementers]
src/main/java/org/darkphoenixs/mq/codec/MQMessageDecoder.java
MQConsumer (Interface)
Title: MQConsumer Description: 消费者接口 @author Victor.Zxy @version 1.0 @since 2015-06-01 [8 implementers]
src/main/java/org/darkphoenixs/mq/consumer/MQConsumer.java
MQMessageListener (Interface)
Title: MQMessageListener Description: 消息监听器接口 @author Victor.Zxy @version 1.0 @since 2015-06-01 [12 implementers]
src/main/java/org/darkphoenixs/mq/listener/MQMessageListener.java
MQConsumerFactory (Interface)
Title: MQConsumerFactory Description: 消费者工厂接口 @author Victor.Zxy @version 1.0 @since 2015-06-01 [3 implementers]
src/main/java/org/darkphoenixs/mq/factory/MQConsumerFactory.java

Core symbols most depended-on inside this repo

shutdown
called by 46
src/main/java/org/darkphoenixs/kafka/pool/KafkaMessageReceiverRetry.java
receive
called by 38
src/main/java/org/darkphoenixs/mq/consumer/MQConsumer.java
sendWithKey
called by 36
src/main/java/org/darkphoenixs/kafka/core/KafkaMessageSender.java
send
called by 30
src/main/java/org/darkphoenixs/mq/producer/MQProducer.java
setDestination
called by 23
src/main/java/org/darkphoenixs/kafka/producer/AbstractProducer.java
setMessageTemplate
called by 17
src/main/java/org/darkphoenixs/kafka/producer/AbstractProducer.java
setMessageSenderPool
called by 16
src/main/java/org/darkphoenixs/kafka/core/KafkaMessageTemplate.java
setEncoder
called by 16
src/main/java/org/darkphoenixs/kafka/core/KafkaMessageTemplate.java

Shape

Method 786
Class 175
Interface 12
Enum 4

Languages

Java100%

Modules by API surface

src/main/java/org/darkphoenixs/kafka/pool/KafkaMessageNewReceiverPool.java52 symbols
src/main/java/org/darkphoenixs/kafka/pool/KafkaMessageReceiverPool.java34 symbols
src/main/java/org/darkphoenixs/mq/producer/MQProducerAdapter.java28 symbols
src/test/java/org/darkphoenixs/activemq/convertor/MessageConverterTest.java27 symbols
src/main/java/org/darkphoenixs/kafka/pool/KafkaMessageSenderPool.java26 symbols
src/test/java/org/darkphoenixs/mq/producer/MQProducerAdapterTest.java24 symbols
src/main/java/org/darkphoenixs/rocketmq/producer/AbstractProducer.java22 symbols
src/main/java/org/darkphoenixs/mq/listener/MQMessageListenerAdapter.java20 symbols
src/main/java/org/darkphoenixs/kafka/core/KafkaMessageTemplate.java17 symbols
src/test/java/org/darkphoenixs/kafka/pool/KafkaMessageNewReceiverPoolTest.java16 symbols
src/test/java/org/darkphoenixs/kafka/core/KafkaMessageTemplateTest.java16 symbols
src/test/java/org/darkphoenixs/kafka/pool/KafkaMessageReceiverPoolTest.java15 symbols

For agents

$ claude mcp add message-queue-client-framework \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

Ask about this repo answers extend the page