Documentation
¶
Index ¶
- Constants
- func ConsumeMQ(mqCategory string, consumeProxy *mqenv.MQConsumerProxy) error
- func GetKafka(name string) (*kafka.Kafka, error)
- func GetMQRoutes() map[string]Config
- func GetRabbitMQ(name string) (*rabbitmq.RabbitMQ, error)
- func Init(mqConfigFile string, mqConfigs map[string]mqenv.MQConnectorConfig) error
- func InitMQWithRPC(key string, rpcType int, connCfg *mqenv.MQConnectorConfig, mqCfg *Config) error
- func PublishMQ(mqCategory string, publishMsg *mqenv.MQPublishMessage) error
- type Config
- type Exchange
- type RoutesEnv
Constants ¶
View Source
const ( DriverTypeAMQP = mqenv.DriverTypeAMQP DriverTypeKafka = mqenv.DriverTypeKafka MQTypeConsumer = mqenv.MQTypeConsumer MQTypePublisher = mqenv.MQTypePublisher MQEventCodeOk = mqenv.MQEventCodeOk MQEventCodeFailed = mqenv.MQEventCodeFailed )
Constants
Variables ¶
This section is empty.
Functions ¶
func ConsumeMQ ¶
func ConsumeMQ(mqCategory string, consumeProxy *mqenv.MQConsumerProxy) error
ConsumeMQ consume
func GetRabbitMQ ¶
GetRabbitMQ get rabbitmq
func Init ¶
func Init(mqConfigFile string, mqConfigs map[string]mqenv.MQConnectorConfig) error
Init initializer
func InitMQWithRPC ¶
InitMQWithRPC init mq with RPC
Types ¶
type Config ¶
type Config struct { Instance string `yaml:"instance"` // RabbitMQ parameters Queue string `yaml:"queue"` Exchange Exchange `yaml:"exchange"` BindingKey string `yaml:"bindingKey"` RoutingKeys map[string]string `yaml:"routingKeys"` Durable bool `yaml:"durable"` RPCEnabled bool `yaml:"rpcEnabled"` // Kafka parameters Topic string `yaml:"topic"` GroupID string `yaml:"groupId"` }
Config struct
Click to show internal directories.
Click to hide internal directories.