rmqworker

package module

Go to main page

Versions in this module

v1

v1.38.2

Apr 6, 2025

v1.38.1

Dec 9, 2024

v1.38.0

Dec 6, 2024

v1.37.7

Dec 5, 2024

Changes in this version

type DeclareQueueTask

+ DeadLetterExchange string

type WorkerTask

+ DeadLetterExchange string

v1.37.6

Dec 4, 2024

v1.37.5

Dec 4, 2024

v1.37.4

Dec 4, 2024

v1.37.3

Dec 4, 2024

v1.37.2

Dec 2, 2024

v1.37.1

Jun 6, 2024

v1.37.0

Jun 2, 2024

v1.36.1

Apr 9, 2024

v1.36.0

Mar 22, 2024

Changes in this version

+ const ExchangeTypeFanout

v1.35.7

Feb 7, 2024

v1.35.6

Dec 18, 2023

v1.35.5

Nov 16, 2023

v1.35.4

Oct 3, 2023

v1.35.3

Sep 30, 2023

v1.35.2

Sep 30, 2023

v1.35.1

Sep 30, 2023

v1.35.0

Jun 23, 2023

v1.34.1

May 31, 2023

v1.34.0

Mar 4, 2023

Changes in this version

type WorkerTask

+ ManualAck bool

v1.33.1

Feb 20, 2023

v1.33.0

Feb 16, 2023

v1.32.0

Nov 28, 2022

v1.31.1

Nov 26, 2022

v1.31.0

Nov 23, 2022

v1.30.1

Nov 18, 2022

v1.30.0

Nov 4, 2022

v1.29.2

Oct 5, 2022

v1.29.1

Sep 15, 2022

Changes in this version

type RMQHandler

+ func (r *RMQHandler) IsConnectionAlive() bool

v1.29.0

Aug 30, 2022

Changes in this version

type RMQHandler

+ func (handler *RMQHandler) NewCSTX(ackNum, timeout int32) cstx.CrossServiceTransaction

+ func (r *RMQHandler) PublishCSXTToExchange(task structs.PublishToExchangeTask, tx cstx.CrossServiceTransaction) errs.APIError

+ func (r *RMQHandler) PublishCSXTToQueue(task structs.RMQPublishRequestTask, tx cstx.CrossServiceTransaction) errs.APIError

type RMQWorker

+ Logger *zap.Logger

v1.28.1

Aug 26, 2022

Changes in this version

type RMQDeliveryHandler

+ func (deliveryHandler RMQDeliveryHandler) GetCSTXID() (string, bool)

v1.28.0

Aug 19, 2022

Changes in this version

type RMQHandler

+ func (handler *RMQHandler) StartCSTXAcksConsumer() APIError

v1.27.8

Aug 14, 2022

v1.27.7

Aug 14, 2022

v1.27.6

Aug 14, 2022

v1.27.5

Aug 13, 2022

v1.27.4

Aug 12, 2022

v1.27.3

Aug 4, 2022

v1.27.2

Jul 30, 2022

v1.27.1

Jul 30, 2022

Changes in this version

type CreateRMQHandlerTask

+ Logs LogCallbacks

+ type LogCallbacks struct

+ LogError func(err error)

+ LogVerbose func(info string)

+ UseLogs bool

type RequestHandlerTask

+ Logs LogCallbacks

type WorkerTask

+ Logs LogCallbacks

v1.27.0

Jul 17, 2022

v1.26.30

Jul 11, 2022

v1.26.29

Jul 9, 2022

v1.26.28

Jul 7, 2022

Changes in this version

+ const ExchangeTypeDirect

+ const ExchangeTypeTopic

+ type CSTXAck struct

+ TXID string

+ Time int64

+ Timeout int

+ Type string

+ type CrossServiceTransaction struct

+ AckNum int

+ ID string

+ StartedAt int64

+ Timeout int

+ func (CSTX CrossServiceTransaction) Commit() (bool, APIError)

+ func (CSTX CrossServiceTransaction) PublishToExchange(task PublishToExchangeTask) APIError

+ func (CSTX CrossServiceTransaction) PublishToQueue(task RMQPublishRequestTask) APIError

+ func (CSTX CrossServiceTransaction) Rollback() APIError

type RMQDeliveryHandler

+ func (deliveryHandler RMQDeliveryHandler) GetCSTX(handler *RMQHandler) CrossServiceTransaction

type RMQHandler

+ func (handler *RMQHandler) BeginCSTX(ackNum int, timeout int) (*CrossServiceTransaction, APIError)

type RMQPublishRequestTask

+ CSTX CrossServiceTransaction

v1.26.27

Jul 4, 2022

v1.26.26

Jun 28, 2022

v1.26.25

Jun 25, 2022

v1.26.24

Jun 25, 2022

v1.26.23

Jun 25, 2022

Changes in this version

+ type PublishToExchangeTask struct

+ CorrelationID string

+ ExchangeName string

+ Message interface{}

+ ResponseRoutingKey string

+ RoutingKey string

type RMQHandler

+ func (r *RMQHandler) PublishToExchange(task PublishToExchangeTask) APIError

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

type RMQPublishRequestTask

+ CorrelationID string

v1.26.22

Jun 25, 2022

Changes in this version

type WorkerTask

+ DisableCheckResponseErrors bool

v1.26.21

Jun 23, 2022

v1.26.20

Jun 23, 2022

v1.26.19

Jun 14, 2022

v1.26.18

Jun 13, 2022

v1.26.17

Jun 4, 2022

v1.26.16

Jun 4, 2022

v1.26.15

May 28, 2022

Changes in this version

type RequestHandlerTask

+ MethodFriendlyName string

v1.26.14

May 28, 2022

Changes in this version

type RMQWorker

+ func (w *RMQWorker) Finish()

type RequestHandlerTask

+ Timeout time.Duration

type WorkerTask

+ DoNotStopOnTimeout bool

v1.26.13

May 28, 2022

v1.26.12

May 28, 2022

v1.26.11

May 28, 2022

v1.26.10

May 27, 2022

Changes in this version

type RequestHandler

+ Finished chan struct{}

+ IsPaused bool

+ func (r *RequestHandler) Stop()

v1.26.9

May 27, 2022

v1.26.8

May 27, 2022

v1.26.7

May 27, 2022

v1.26.6

May 27, 2022

Changes in this version

type RequestHandler

+ Worker *RMQWorker

+ func (r *RequestHandler) DeleteQueues() APIError

v1.26.5

May 22, 2022

v1.26.4

May 20, 2022

v1.26.3

May 20, 2022

v1.26.2

May 20, 2022

Changes in this version

type WorkerTask

+ ExchangeType string

v1.26.1

May 20, 2022

v1.26.0

May 17, 2022

v1.25.13

May 17, 2022

v1.25.12

May 17, 2022

v1.25.11

May 17, 2022

v1.25.10

May 16, 2022

v1.25.9

May 16, 2022

v1.25.8

May 16, 2022

v1.25.7

May 16, 2022

v1.25.6

May 16, 2022

v1.25.5

May 14, 2022

v1.25.4

May 13, 2022

v1.25.3

May 13, 2022

v1.25.2

May 13, 2022

v1.25.1

May 13, 2022

v1.25.0

May 12, 2022

Changes in this version

+ type CreateRMQHandlerTask struct

+ ConnectionErrorCallback func(err APIError)

+ Data RMQConnectionData

+ Logger *constants.Logger

+ UseErrorCallback bool

+ type DeclareQueueTask struct

+ AutoDelete bool

+ DisableOverflow bool

+ Durable bool

+ MaxLength int64

+ MessagesLifetime int64

+ Name string

type WorkerTask

+ ConsumersCount int

+ DisableOverflow bool

+ FromExchange string

+ ID string

+ ISAutoDelete bool

+ ISQueueDurable bool

+ MessagesLifetime int64

+ QueueLength int64

+ RoutingKey string

+ Timeout time.Duration

+ TimeoutCallback RMQTimeoutCallback

+ UseErrorCallback bool

v1.24.6

May 5, 2022

v1.24.5

May 4, 2022

v1.24.4

Apr 29, 2022

v1.24.3

Apr 25, 2022

v1.24.2

Apr 25, 2022

v1.24.1

Apr 25, 2022

v1.24.0

Apr 25, 2022

v1.23.17

Apr 23, 2022

Changes in this version

type RMQHandler

+ func (r *RMQHandler) IsQueueExists(name string) (bool, APIError)

v1.23.16

Apr 20, 2022

v1.23.15

Apr 20, 2022

v1.23.14

Apr 19, 2022

Changes in this version

type RMQDeliveryHandler

+ func (d *RMQDeliveryHandler) Reject(requeue bool) APIError

type RMQMonitoringWorkerTask

+ RejectDeliveryOnPause bool

type WorkerTask

+ RejectDeliveryOnPause bool

v1.23.13

Apr 16, 2022

v1.23.12

Apr 6, 2022

v1.23.11

Mar 29, 2022

v1.23.10

Mar 28, 2022

v1.23.9

Mar 28, 2022

Changes in this version

type RMQMonitoringWorkerTask

+ EnableRateLimiter bool

+ MaxEventsPerSecond int

type WorkerTask

+ EnableRateLimiter bool

+ MaxEventsPerSecond int

v1.23.8

Mar 26, 2022

Changes in this version

type RMQMonitoringWorkerTask

+ DisableOverflow bool

v1.23.7

Mar 25, 2022

Changes in this version

type RMQQueueDeclareSimpleTask

+ DisableOverflow bool

type RMQQueueDeclareTask

+ DisableOverflow bool

v1.23.6

Mar 25, 2022

Changes in this version

type RMQMonitoringWorker

+ func (w *RMQMonitoringWorker) IsConnAlive() bool

type RMQWorker

+ func (w *RMQWorker) IsConnAlive() bool

v1.23.5

Mar 20, 2022

Changes in this version

type RMQMonitoringWorker

+ func (w *RMQMonitoringWorker) IsActive() bool

type RMQWorker

+ func (w *RMQWorker) IsActive() bool

v1.23.4

Mar 20, 2022

Changes in this version

type RMQMonitoringWorker

+ func (w *RMQMonitoringWorker) IsPaused() bool

type RMQWorker

+ func (w *RMQWorker) IsPaused() bool

v1.23.3

Mar 13, 2022

v1.23.2

Feb 25, 2022

Changes in this version

type RequestHandlerTask

+ ForceQueueToDurable bool

v1.23.1

Feb 20, 2022

v1.23.0

Feb 14, 2022

v1.22.19

Feb 13, 2022

v1.22.18

Feb 12, 2022

v1.22.17

Feb 4, 2022

v1.22.16

Feb 2, 2022

v1.22.15

Feb 2, 2022

v1.22.14

Feb 2, 2022

Changes in this version

+ type RMQErrorCallback func(w *RMQWorker, err *constants.APIError)

type RMQMonitoringWorkerTask

+ ErrorCallback RMQErrorCallback

type WorkerTask

+ ErrorCallback RMQErrorCallback

v1.22.12

Jan 28, 2022

v1.22.11

Jan 28, 2022

v1.22.10

Jan 24, 2022

v1.22.9

Jan 21, 2022

Changes in this version

type WorkerTask

+ VerboseMode bool

v1.22.8

Jan 21, 2022

v1.22.7

Jan 19, 2022

v1.22.6

Jan 19, 2022

v1.22.5

Jan 19, 2022

v1.22.4

Jan 17, 2022

v1.22.3

Jan 19, 2022

v1.22.2

Jan 16, 2022

v1.22.1

Jan 14, 2022

Changes in this version

type RequestHandlerTask

+ ExchangeInsteadOfQueue bool

v1.22.0

Jan 13, 2022

v1.21.11

Jan 3, 2022

v1.21.10

Jan 3, 2022

v1.21.9

Jan 2, 2022

v1.21.8

Jan 2, 2022

v1.21.7

Jan 1, 2022

v1.21.6

Jan 1, 2022

v1.21.5

Jan 1, 2022

v1.21.4

Jan 1, 2022

v1.21.3

Dec 29, 2021

Changes in this version

type RMQMonitoringWorkerTask

+ ReuseChannels bool

+ type WorkerTask struct

+ Callback RMQDeliveryCallback

+ QueueName string

+ ReuseChannels bool

+ WorkerName string

v1.21.2

Dec 29, 2021

v1.21.1

Dec 29, 2021

v1.21.0

Dec 24, 2021

Changes in this version

type RequestHandlerTask

+ AttemptsNumber int

v1.20.4

Dec 22, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) DeclareQueuesExtended(queues []RMQQueueDeclareSimpleTask) APIError

v1.20.3

Dec 21, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) Close()

type RequestHandler

+ func (r *RequestHandler) Close()

v1.20.2

Dec 13, 2021

v1.20.1

Dec 8, 2021

Changes in this version

type RMQMonitoringWorkerTask

+ QueueLength int64

type RMQQueueDeclareSimpleTask

+ QueueLength int64

type RMQQueueDeclareTask

+ QueueLength int64

v1.20.0

Dec 6, 2021

v1.19.6

Dec 3, 2021

v1.19.5

Dec 3, 2021

Changes in this version

type RMQPublishRequestTask

+ ExchangeName string

v1.19.4

Nov 22, 2021

Changes in this version

type RMQMonitoringWorkerTask

+ MessagesLifetime int64

v1.19.3

Nov 22, 2021

Changes in this version

+ type RMQExchangeDeclareTask struct

+ ExchangeName string

+ ExchangeType string

+ MessagesLifetime int64

type RMQHandler

+ func (r *RMQHandler) QueueDeclare(task RMQQueueDeclareSimpleTask) APIError

+ type RMQQueueDeclareSimpleTask struct

+ AutoDelete bool

+ Durable bool

+ MessagesLifetime int64

+ QueueName string

type RMQQueueDeclareTask

+ MessagesLifetime int64

v1.19.2

Nov 22, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) SetMessagesLifetimeLimit(limit int64) *RMQHandler

v1.19.1

Nov 22, 2021

v1.19.0

Nov 22, 2021

Changes in this version

type RMQWorker

+ func (w *RMQWorker) CloseChannels()

v1.18.7

Nov 19, 2021

v1.18.6

Nov 18, 2021

v1.18.5

Nov 18, 2021

v1.18.4

Nov 18, 2021

v1.18.3

Nov 18, 2021

Changes in this version

type RMQHandler

+ func (r *RMQHandler) NewRequestHandler(task RequestHandlerTask) *RequestHandler

type RMQMonitoringWorker

+ func (w *RMQMonitoringWorker) StopConnections()

type RMQWorker

+ func (w *RMQWorker) StopConnections()

+ type RequestHandler struct

+ LastError *constants.APIError

+ RMQH *RMQHandler

+ Response *RequestHandlerResponse

+ Task RequestHandlerTask

+ WorkerID string

+ func (r *RequestHandler) Send() (*RequestHandlerResponse, APIError)

+ func (r *RequestHandler) SetID(id string) *RequestHandler

+ type RequestHandlerResponse struct

+ ResponseBody []byte

+ func (s *RequestHandlerResponse) Decode(destination interface{}) APIError

+ type RequestHandlerTask struct

+ MessageBody interface{}

+ RequestToQueueName string

+ ResponseFromExchangeName string

+ ResponseTimeout time.Duration

+ TempQueueName string

+ WorkerName string

v1.18.1

Nov 17, 2021

v1.18.0

Nov 13, 2021

v1.17.5

Nov 13, 2021

v1.17.4

Nov 11, 2021

Changes in this version

type RMQMonitoringWorkerTask

+ WorkerName string

v1.17.3

Nov 11, 2021

v1.17.2

Nov 11, 2021

v1.17.1

Nov 11, 2021

v1.17.0

Nov 10, 2021

v1.16.9

Nov 7, 2021

v1.16.8

Nov 4, 2021

v1.16.7

Nov 3, 2021

v1.16.6

Nov 3, 2021

Changes in this version

type RMQHandler

+ Connections handlerConnections

v1.16.5

Nov 2, 2021

v1.16.4

Nov 2, 2021

v1.16.3

Nov 2, 2021

v1.16.2

Nov 2, 2021

v1.16.1

Nov 2, 2021

v1.16.0

Nov 2, 2021

v1.15.9

Nov 2, 2021

v1.15.8

Nov 1, 2021

v1.15.7

Nov 1, 2021

v1.15.6

Nov 1, 2021

v1.15.5

Nov 1, 2021

v1.15.4

Nov 1, 2021

v1.15.3

Nov 1, 2021

v1.15.2

Nov 1, 2021

Changes in this version

type RMQWorker

+ func (w *RMQWorker) SetConsumerTag(uniqueTag string) *RMQWorker

+ func (w *RMQWorker) SetConsumerTagFromName() *RMQWorker

v1.15.1

Nov 1, 2021

v1.14.6

Nov 1, 2021

v1.14.5

Nov 1, 2021

v1.14.4

Oct 30, 2021

v1.14.3

Oct 30, 2021

v1.14.2

Oct 30, 2021

v1.14.1

Oct 24, 2021

v1.14.0

Oct 24, 2021

Changes in this version

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

+ type APIError *constants.APIError

+ type RMQConnectionData struct

+ Host string

+ Password string

+ Port string

+ UseTLS string

+ User string

+ type RMQDeliveryCallback func(w *RMQWorker, deliveryHandler RMQDeliveryHandler)

+ type RMQDeliveryHandler struct

+ func NewRMQDeliveryHandler(delivery amqp.Delivery) RMQDeliveryHandler

+ func (d *RMQDeliveryHandler) Accept() APIError

+ func (d *RMQDeliveryHandler) CheckResponseError() APIError

+ func (d *RMQDeliveryHandler) GetCorrelationID() string

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

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

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

+ func (d *RMQDeliveryHandler) GetRoutingKey() string

+ type RMQHandler struct

+ ConnectionData RMQConnectionData

+ Cron *simplecron.CronObject

+ 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) DeleteQueues(queueNames map[string][]string) APIError

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

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

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

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

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

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

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

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

+ type RMQMonitoringWorker struct

+ Worker *RMQWorker

+ func (w *RMQMonitoringWorker) AwaitFinish()

+ func (w *RMQMonitoringWorker) GetID() string

+ func (w *RMQMonitoringWorker) GetName() string

+ func (w *RMQMonitoringWorker) Pause()

+ func (w *RMQMonitoringWorker) Reset()

+ func (w *RMQMonitoringWorker) Resume()

+ func (w *RMQMonitoringWorker) Stop()

+ type RMQMonitoringWorkerTask struct

+ Callback RMQDeliveryCallback

+ FromExchangeName string

+ ID string

+ ISAutoDelete bool

+ ISQueueDurable bool

+ QueueName string

+ RoutingKey string

+ Timeout time.Duration

+ TimeoutCallback RMQTimeoutCallback

+ type RMQPublishRequestTask struct

+ MessageBody interface{}

+ QueueName string

+ ResponseRoutingKey string

+ type RMQPublishResponseTask struct

+ CorrelationID string

+ ExchangeName string

+ MessageBody interface{}

+ ResponseRoutingKey string

+ type RMQQueueDeclareTask struct

+ AutoDelete bool

+ Durable bool

+ FromExchangeName string

+ QueueName string

+ RoutingKey string

+ type RMQTimeoutCallback func(w *RMQWorker)

+ type RMQWorker struct

+ func (w *RMQWorker) AwaitFinish()

+ func (w *RMQWorker) GetID() string

+ func (w *RMQWorker) GetName() string

+ func (w *RMQWorker) HandleReconnect()

+ func (w *RMQWorker) Listen()

+ func (w *RMQWorker) Pause()

+ func (w *RMQWorker) Reset()

+ func (w *RMQWorker) Resume()

+ func (w *RMQWorker) Serve()

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

+ func (w *RMQWorker) SetAutoAckByLib(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) SetSyncMode(sync bool) *RMQWorker

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

+ func (w *RMQWorker) Stop()

+ func (w *RMQWorker) Subscribe() APIError

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