activemq

package module
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2020 License: MIT Imports: 9 Imported by: 0

README

activemq-connector

Refs:

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Connector 

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

func Open 

func Open(s *Setting) (*Connector, error)

func (*Connector) Close 

func (c *Connector) Close() error

func (*Connector) CompleteJob 

func (c *Connector) CompleteJob(ctx context.Context, input *jobworker.CompleteJobInput) (*jobworker.CompleteJobOutput, error)

func (*Connector) Enqueue 

func (c *Connector) Enqueue(ctx context.Context, input *jobworker.EnqueueInput) (*jobworker.EnqueueOutput, error)

func (*Connector) EnqueueBatch 

func (c *Connector) EnqueueBatch(ctx context.Context, input *jobworker.EnqueueBatchInput) (*jobworker.EnqueueBatchOutput, error)

func (*Connector) FailJob 

func (c *Connector) FailJob(ctx context.Context, input *jobworker.FailJobInput) (*jobworker.FailJobOutput, error)

func (*Connector) Name 

func (c *Connector) Name() string

func (*Connector) SetLoggerFunc 

func (c *Connector) SetLoggerFunc(f jobworker.LoggerFunc)

func (*Connector) Subscribe 

func (c *Connector) Subscribe(ctx context.Context, input *jobworker.SubscribeInput) (*jobworker.SubscribeOutput, error)

type Provider 

type Provider struct {
}

func (Provider) Open 

func (Provider) Open(attrs map[string]interface{}) (jobworker.Connector, error)

type Setting 

type Setting struct {
	Network       string
	Addr          string
	Config        *tls.Config // tls only
	Opts          []func(*stomp.Conn) error
	AckMode       stomp.AckMode
	Persistent    bool
	NumMaxRetries int
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.