rmqworker

package module

Go to main page

Versions in this module

v1

v1.13.2

Oct 21, 2021

v1.13.1

Oct 20, 2021

v1.13.0

Oct 19, 2021

v1.12.0

Oct 16, 2021

v1.11.2

Oct 15, 2021

Changes in this version

type RMQWorker

+ func (w *RMQWorker) SetAutoAckByLib(autoAck bool) *RMQWorker

v1.11.1

Oct 15, 2021

v1.11.0

Oct 15, 2021

Changes in this version

type RMQHandler

+ Cron *simplecron.CronObject

v1.10.0

Oct 12, 2021

v1.9.3

Oct 10, 2021

v1.9.2

Oct 9, 2021

v1.9.1

Oct 9, 2021

v1.9.0

Oct 9, 2021

v1.8.11

Oct 8, 2021

v1.8.10

Oct 8, 2021

v1.8.9

Oct 8, 2021

v1.8.8

Oct 8, 2021

v1.8.7

Oct 8, 2021

v1.8.6

Oct 8, 2021

v1.8.5

Oct 8, 2021

v1.8.4

Oct 8, 2021

v1.8.3

Oct 8, 2021

v1.8.2

Oct 8, 2021

v1.8.1

Oct 8, 2021

v1.8.0

Oct 8, 2021

Changes in this version

type RMQMonitoringWorker

+ func (w *RMQMonitoringWorker) GetID() string

+ func (w *RMQMonitoringWorker) GetName() string

type RMQWorker

+ func (w *RMQWorker) GetID() string

+ func (w *RMQWorker) GetName() string

v1.7.7

Oct 8, 2021

v1.7.6

Oct 7, 2021

v1.7.5

Oct 7, 2021

v1.7.4

Oct 7, 2021

v1.7.3

Oct 7, 2021

v1.7.2

Oct 7, 2021

v1.7.1

Oct 7, 2021

v1.7.0

Oct 7, 2021

v1.6.10

Oct 7, 2021

v1.6.9

Oct 7, 2021

v1.6.8

Oct 7, 2021

v1.6.7

Oct 7, 2021

v1.6.6

Oct 7, 2021

v1.6.5

Oct 7, 2021

v1.6.4

Oct 7, 2021

v1.6.3

Oct 7, 2021

v1.6.2

Oct 7, 2021

v1.6.1

Oct 7, 2021

v1.6.0

Oct 6, 2021

v1.5.2

Oct 6, 2021

v1.5.1

Oct 6, 2021

v1.5.0

Oct 6, 2021

v1.4.2

Oct 6, 2021

v1.4.1

Oct 6, 2021

v1.4.0

Oct 5, 2021

v1.3.1

Oct 3, 2021

v1.3.0

Sep 28, 2021

Changes in this version

type RMQWorker

+ SyncMode bool

+ func (w *RMQWorker) SetSyncMode(sync bool) *RMQWorker

v1.2.0

Sep 27, 2021

Changes in this version

type RMQMonitoringWorker

+ func (w *RMQMonitoringWorker) Reset()

type RMQWorker

+ func (w *RMQWorker) Reset()

v1.1.0

Sep 27, 2021

v1.0.20

Sep 26, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) NewRMQHandler() (*RMQHandler, APIError)

v1.0.19

Sep 26, 2021

Changes in this version

type RMQDeliveryHandler

+ func (d *RMQDeliveryHandler) GetResponseRoutingKeyHeader() (string, APIError)

v1.0.18

Sep 26, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) RMQPublishToExchange(message interface{}, exchangeName, routingKey string) APIError

v1.0.17

Sep 26, 2021

v1.0.16

Sep 24, 2021

Changes in this version

type RMQPublishResponseTask

+ CorrelationID string

v1.0.15

Sep 21, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) RMQPublishInterfaceToQueue(task RMQPublishRequestTask, message interface{}) APIError

v1.0.14

Sep 21, 2021

Changes in this version

type RMQDeliveryHandler

+ func NewRMQDeliveryHandler(delivery amqp.Delivery) RMQDeliveryHandler

v1.0.13

Sep 21, 2021

Changes in this version

type RMQDeliveryHandler

+ func (d *RMQDeliveryHandler) CheckResponseError() APIError

v1.0.12

Sep 21, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) RMQPublishToQueue(task RMQPublishRequestTask) APIError

v1.0.11

Sep 21, 2021

Changes in this version

+ type RMQPublishRequestTask struct

+ MessageBody []byte

+ QueueName string

+ ResponseRoutingKey string

v1.0.10

Sep 21, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) DeleteQueues(queueNames map[string][]string) APIError

v1.0.9

Sep 21, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) RMQQueueDeclareAndBind(task RMQQueueDeclareTask) APIError

v1.0.8

Sep 21, 2021

Changes in this version

+ type RMQQueueDeclareTask struct

+ AutoDelete bool

+ Durable bool

+ FromExchangeName string

+ QueueName string

+ RoutingKey string

v1.0.7

Sep 21, 2021

Changes in this version

+ type RMQMonitoringWorkerTask struct

+ Callback RMQDeliveryCallback

+ FromExchangeName string

+ ID string

+ ISAutoDelete bool

+ ISQueueDurable bool

+ QueueName string

+ RMQChannel *amqp.Channel

+ RMQConn *amqp.Connection

+ RoutingKey string

+ Timeout time.Duration

+ TimeoutCallback RMQTimeoutCallback

v1.0.6

Sep 21, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) SendRMQResponse(task *RMQPublishResponseTask, errorMsg ...*constants.APIError) APIError

+ type RMQPublishResponseTask struct

+ ExchangeName string

+ MessageBody []byte

+ ResponseRoutingKey string

v1.0.5

Sep 21, 2021

Changes in this version

type RMQDeliveryHandler

+ func (d *RMQDeliveryHandler) GetHeader(headerName string) (interface{}, bool)

v1.0.4

Sep 21, 2021

Changes in this version

type RMQDeliveryHandler

+ func (d *RMQDeliveryHandler) GetMessageBody() []byte

v1.0.3

Sep 21, 2021

Changes in this version

+ type RMQDeliveryHandler struct

+ func (d *RMQDeliveryHandler) Accept() APIError

+ func (d *RMQDeliveryHandler) GetCorrelationID() string

+ func (d *RMQDeliveryHandler) GetRoutingKey() string

v1.0.2

Sep 21, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) NewRMQMonitoringWorker(task rmqMonitoringWorkerTask) (*RMQMonitoringWorker, APIError)

+ type RMQMonitoringWorker struct

+ Worker *RMQWorker

+ func (w *RMQMonitoringWorker) AwaitFinish()

+ func (w *RMQMonitoringWorker) Pause()

+ func (w *RMQMonitoringWorker) Resume()

+ func (w *RMQMonitoringWorker) Stop()

type RMQWorker

+ func (w *RMQWorker) AwaitFinish()

+ func (w *RMQWorker) HandleReconnect()

+ func (w *RMQWorker) Listen()

+ func (w *RMQWorker) Pause()

+ func (w *RMQWorker) Resume()

+ func (w *RMQWorker) Serve()

+ func (w *RMQWorker) SetAutoAck(autoAck bool) *RMQWorker

+ func (w *RMQWorker) SetCheckResponseErrors(check bool) *RMQWorker

+ func (w *RMQWorker) SetID(id string) *RMQWorker

+ func (w *RMQWorker) SetName(name string) *RMQWorker

+ func (w *RMQWorker) SetTimeout(timeout time.Duration, callback RMQTimeoutCallback) *RMQWorker

+ func (w *RMQWorker) Stop()

+ func (w *RMQWorker) Subscribe() APIError

v1.0.1

Sep 21, 2021

Changes in this version

+ type RMQConnectionData struct

+ Host string

+ Password string

+ Port string

+ UseTLS string

+ User string

v1.0.0

Sep 21, 2021

Changes in this version

+ func NewRMQHandler(connData rmqConnectionData, logger ...*constants.Logger) (*RMQHandler, APIError)

+ type APIError *constants.APIError

+ type RMQDeliveryCallback func(w *RMQWorker, rmqDelivery amqp.Delivery)

+ type RMQHandler struct

+ ConnectionData rmqConnectionData

+ Logger *constants.Logger

+ RMQChannel *amqp.Channel

+ RMQConn *amqp.Connection

+ func (r *RMQHandler) DeclareExchanges(exchangeTypes map[string]string) APIError

+ func (r *RMQHandler) DeclareQueues(queues []string) APIError

+ func (r *RMQHandler) NewRMQWorker(QueueName string, callback RMQDeliveryCallback) (*RMQWorker, APIError)

+ type RMQTimeoutCallback func(w *RMQWorker)

+ type RMQWorker struct

+ Channels rmqWorkerChannels

+ ConnectionData rmqConnectionData

+ Connections rmqWorkerConnections

+ Data rmqWorkerData

+ DeliveryCallback RMQDeliveryCallback

+ Logger *constants.Logger

+ Paused bool

+ TimeoutCallback RMQTimeoutCallback

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