Documentation ¶
Index ¶
Constants ¶
View Source
const RetryConsumeTimeoutMs = 10000
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AwsSqsEventHandler ¶ added in v0.3.1
type AwsSqsEventHandler struct { worker.BaseHandler SqsMessage *sqs.Message }
func (*AwsSqsEventHandler) SetSqsMessage ¶ added in v0.3.1
func (h *AwsSqsEventHandler) SetSqsMessage(m *sqs.Message)
type AwsSqsEventHandlerInterface ¶ added in v0.3.1
type AwsSqsEventHandlerInterface interface { worker.BaseHandlerInterface SetSqsMessage(*sqs.Message) }
type AwsSqsEventsWorker ¶ added in v0.3.1
type AwsSqsEventsWorker struct { *worker.BaseWorker // contains filtered or unexported fields }
func NewAwsSqsEventsWorker ¶ added in v0.3.1
func NewAwsSqsEventsWorker(name string, config *sqs_adapter.AwsSqsConfig) *AwsSqsEventsWorker
func (*AwsSqsEventsWorker) Run ¶ added in v0.3.1
func (w *AwsSqsEventsWorker) Run()
func (*AwsSqsEventsWorker) SetEvent ¶ added in v0.3.1
func (w *AwsSqsEventsWorker) SetEvent(queue string, handler AwsSqsEventHandlerInterface)
func (*AwsSqsEventsWorker) Setup ¶ added in v0.3.1
func (w *AwsSqsEventsWorker) Setup()
func (*AwsSqsEventsWorker) Stop ¶ added in v0.3.1
func (w *AwsSqsEventsWorker) Stop()
Click to show internal directories.
Click to hide internal directories.