stomp

package

v4.9.0 Latest Latest Go to latest Published: Dec 10, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Package stomp implements a Deliverer over the STOMP protocol.

Deprecated: This package will be removed in a future version. Users should write a webhook to STOMP transducer.

This section is empty.

This section is empty.

This section is empty.

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

Deliverer is a STOMP deliverer which publishes a notifier.Callback to the broker.

func New(conf *config.STOMP) (*Deliverer, error)

func (d *Deliverer) Deliver(ctx context.Context, nID uuid.UUID) error

func (d *Deliverer) Name() string

type DirectDeliverer struct {
	Deliverer
	// contains filtered or unexported fields
}

Deliverer is a STOMP deliverer which publishes a notifier.Callback to the the broker.

func NewDirectDeliverer(conf *config.STOMP) (*DirectDeliverer, error)

func (d *DirectDeliverer) Deliver(ctx context.Context, nID uuid.UUID) error

func (d *DirectDeliverer) Name() string

func (d *DirectDeliverer) Notifications(ctx context.Context, n []notifier.Notification) error

Notifications will copy the provided notifications into a buffer for STOMP delivery.