Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CancelableAmqpJob ¶
type CancelableAmqpJob struct {
// contains filtered or unexported fields
}
func NewCancelableAmqpJob ¶
func NewCancelableAmqpJob(ctx context.Context, deliveries <-chan amqp.Delivery, handler amqpRecipient.JobHandler, onFail amqpRecipient.OnHandlerFails) *CancelableAmqpJob
func (*CancelableAmqpJob) OnCancel ¶
func (job *CancelableAmqpJob) OnCancel(fn func())
func (*CancelableAmqpJob) Run ¶
func (job *CancelableAmqpJob) Run()
Click to show internal directories.
Click to hide internal directories.