JarCasting
JarCasting JarCasting

tech.guyi.component:message-stream-rabbitmq

Unified message flow API

License

License
GroupId

GroupId

tech.guyi.component
ArtifactId

ArtifactId

message-stream-rabbitmq
Last Version

Last Version

1.0
Release Date

Release Date
Type

Type

jar
Description

Description

Unified message flow API

Download message-stream-rabbitmq

Filename Size
message-stream-rabbitmq-1.0.pom
message-stream-rabbitmq-1.0.jar 8 KB
message-stream-rabbitmq-1.0-sources.jar 4 KB
message-stream-rabbitmq-1.0-javadoc.jar 34 KB
Browse

How to add to project

<!-- https://jarcasting.com/artifacts/tech.guyi.component/message-stream-rabbitmq/ -->
<dependency>
    <groupId>tech.guyi.component</groupId>
    <artifactId>message-stream-rabbitmq</artifactId>
    <version>1.0</version>
</dependency>
// https://jarcasting.com/artifacts/tech.guyi.component/message-stream-rabbitmq/
implementation 'tech.guyi.component:message-stream-rabbitmq:1.0'
// https://jarcasting.com/artifacts/tech.guyi.component/message-stream-rabbitmq/
implementation ("tech.guyi.component:message-stream-rabbitmq:1.0")
'tech.guyi.component:message-stream-rabbitmq:jar:1.0'
<dependency org="tech.guyi.component" name="message-stream-rabbitmq" rev="1.0">
  <artifact name="message-stream-rabbitmq" type="jar" />
</dependency>
@Grapes(
@Grab(group='tech.guyi.component', module='message-stream-rabbitmq', version='1.0')
)
libraryDependencies += "tech.guyi.component" % "message-stream-rabbitmq" % "1.0"
[tech.guyi.component/message-stream-rabbitmq "1.0"]

Dependencies

compile (4)

Group / Artifact Type Version
tech.guyi.component : message-stream-api jar 1.0
com.rabbitmq : amqp-client jar 5.10.0
org.springframework.boot : spring-boot-autoconfigure jar 2.4.1
org.slf4j : slf4j-api jar 2.0.0-alpha1

provided (2)

Group / Artifact Type Version
org.projectlombok : lombok jar 1.18.16
org.springframework.boot : spring-boot-configuration-processor jar 2.4.1

Project Modules

There are no modules declared in this project.

message-stream

为消息消费提供统一的API。

让切换不同的消息来源变得更简单。

根据上层业务无需变动代码, 只需修改配置即可做到切换消息的来源。

如： 将Rabbitmq切换为Kafka, 不需要修改业务侧代码, 只需修改配置即可切换。

还可支持多个消息来源的同时消费与发布。

如：同时消费来自Rabbitmq、Kafka、Websocket的消息, 同时向 Rabbitmq、Kafka、Websocket 发送消息。

随着下层消息流实现的增加, 可以实现更多的消息统一消费方式, 如文件、FTP、OSS、UDP、TCP等等, 终极目标是统一所有的输入及输出。

使用文档

已支持消息流

Versions

Version
1.0