Categorygithub.com/wfusion/gofusioncommoninfrawatermillpubsubrocketmq
package
1.1.15
Repository: https://github.com/wfusion/gofusion.git
Documentation: pkg.go.dev
Overview
Versions
2
Dependencies
9
Dependents
0
Files
237 SLOC

# Functions

DefaultSendAsyncCallback default SendAsyncCallback.
NewPublisher creates a new RocketMQ Publisher.

# Constants

Async the async mode.
OneWay the one way mode, no resule.
Sync the syns mode.

# Structs

DefaultMarshaler default message mashaler.
Publisher the rocketmq publisher.
PublisherConfig the rocketmq publisher config.

# Interfaces

Marshaler marshals Watermill's message to Kafka message.
MarshalerUnmarshaler un/marshaler interface for rocketmq message.
Unmarshaler unmarshals Kafka's message to Watermill's message.

# Type aliases

SendAsyncCallback callback for each message send aysnc result.
SendMode send mode.