receive

package
v0.0.0-...-478090f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 7, 2020 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AmqpReceiver

type AmqpReceiver struct {
	// contains filtered or unexported fields
}

amqp信息结构体

func (*AmqpReceiver) Run

func (am *AmqpReceiver) Run(ctx context.Context, consumerGroupId string, mqType string) error

type MqttReceiver

type MqttReceiver struct {
	// contains filtered or unexported fields
}

amqp信息结构体

func RunMqtt

func RunMqtt(topic string) *MqttReceiver

func (*MqttReceiver) DisConn

func (mq *MqttReceiver) DisConn()

func (*MqttReceiver) Sub

func (mq *MqttReceiver) Sub() *MqttReceiver

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL