Endpoint模块 提供了一些内置的接收服务类型，但是你也可以自定义或扩展其他类型的接收服务。要实现这个功能，你需要遵循以下步骤：

1. 实现Message接口 (opens new window) 。Message接口是一个用来抽象不同输入源数据的接口，它定义了一些方法来获取或设置消息的内容、头部、来源、参数、状态码等。你需要为你的接收服务类型实现这个接口，使得你的消息类型可以和endpoint包中的其他类型进行交互。
2. 实现Endpoint接口 (opens new window) 。Endpoint接口是一个用来定义不同接收服务类型的接口，它定义了一些方法来启动、停止、添加路由和拦截器等。你需要为你的接收服务类型实现这个接口，使得你的服务类型可以和endpoint包中的其他类型进行交互。

以上就是扩展endpoint包的基本步骤，你可以参考已经有的endpoint类型实现来编写你自己的代码：

• rest (opens new window)
• websocket (opens new window)
• mqtt (opens new window)
• schedule (opens new window)
• tcp/udp (opens new window)
• Kafka (opens new window) （扩展组件库）