amqpbasic

package

v0.0.0-...-75a6351 Latest Latest Go to latest Published: May 23, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const MAXCLIENT int = 3

View Source

const MAXSESSION int = 20

View Source

const RMESSAGEMAX int = 10

This section is empty.

func ReceiveThread(ctx context.Context)

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

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

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

func (as *AmqpSessionHandler) LinkConfig(option LinkOptions) int

func (as *AmqpSessionHandler) LinkCreate(linkid string) int

func (as *AmqpSessionHandler) LinkDelete(id string, ctx context.Context) int

func (as *AmqpSessionHandler) ReceiverData(linkid string, num int) ([][]byte, int)

The function aims to receive message form the linkhandler and process this data.

func (as *AmqpSessionHandler) SessionConfig(option *SessionOptions) int

func (as *AmqpSessionHandler) SessionDelete(timeout int, ctx context.Context)

func (as *AmqpSessionHandler) SessionFindLinkIndex(id string) int

func (as *AmqpSessionHandler) SessionInit(id *SessionIdentify, try int, ctx context.Context) int

func (as *AmqpSessionHandler) SessionSelectIndex() int

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

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

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

func SessionIdentifyInit(address string, username string, password string, sname string) *SessionIdentify

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