subscriber

package

v0.3.1 Latest Latest Go to latest Published: Mar 18, 2026 License: AGPL-3.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewSubscriber(ctx context.Context, logger *zap.Logger, clientName string) (*EventSubscriber, error)

func (s *EventSubscriber) Close() error

func (s *EventSubscriber) Subscribe(ctx context.Context, groupName string, dlqSubject string, invoker eventing.HandlerInvoker) error

Subscribe to a NATS subject and handle incoming messages. process incoming messages using the provided handler in strict order

type Subscriber interface {
	Subscribe(ctx context.Context, groupName, dlqSubject string, invoker eventing.HandlerInvoker) error
	Close() error
}