wpc

Documentation

Index

• func Close()
• func New(connectionUrl string, logger *zap.SugaredLogger, ...) *wpc
• func NewWpcSubscriber(h MessageHandler) *wpcSubscriber
• func Pd(topic string) pulsar.Producer
• func ReleaseMessage(msg *Message)
• type Message
  • func AcquireMessage() *Message
  • func (m *Message) ReleaseThis()
• type MessageHandler

Functions

func Close

func Close()

func New

func New(connectionUrl string, logger *zap.SugaredLogger, pulsarOptions ...*pulsar.ClientOptions) *wpc

func NewWpcSubscriber

func NewWpcSubscriber(h MessageHandler) *wpcSubscriber

func Pd

func Pd(topic string) pulsar.Producer

func ReleaseMessage

func ReleaseMessage(msg *Message)

Types

type Message

type Message struct {
	MessageId       []byte
	Topic           string
	ProducerName    string
	Properties      map[string]string
	Payload         []byte
	PublishTime     time.Time
	EventTime       time.Time
	RedeliveryCount int
}

func AcquireMessage

func AcquireMessage() *Message

func (*Message) ReleaseThis

func (m *Message) ReleaseThis()

type MessageHandler

type MessageHandler func(msg *Message) error