ha

type ConfirmMessageHandler ¶

type ConfirmMessageHandler func(messageConfirm []*stream.ConfirmationStatus)

type IReliable ¶ added in v1.3.1

type IReliable interface {
	GetStatus() int

	GetStatusAsString() string
	// contains filtered or unexported methods
}

type ReliableConsumer ¶ added in v1.3.1

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

ReliableConsumer is a consumer that can reconnect in case of connection problems the function messagesHandler is mandatory

func NewReliableConsumer(env *stream.Environment, streamName string,
	consumerOptions *stream.ConsumerOptions, messagesHandler stream.MessagesHandler) (*ReliableConsumer, error)

func (c *ReliableConsumer) Close() error

func (c *ReliableConsumer) GetInfo() string

func (c *ReliableConsumer) GetStatus() int

func (c *ReliableConsumer) GetStatusAsString() string

type ReliableProducer ¶

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

ReliableProducer is a producer that can reconnect in case of connection problems the function handlePublishConfirm is mandatory in case of problems the messages have the message.Confirmed == false The functions `Send` and `SendBatch` are blocked during the reconnection

func NewReliableProducer(env *stream.Environment, streamName string,
	producerOptions *stream.ProducerOptions,
	confirmMessageHandler ConfirmMessageHandler) (*ReliableProducer, error)

func (p *ReliableProducer) BatchSend(batchMessages []message.StreamMessage) error

func (p *ReliableProducer) Close() error

func (p *ReliableProducer) GetBroker() *stream.Broker

func (p *ReliableProducer) GetInfo() string

func (p *ReliableProducer) GetStatus() int

func (p *ReliableProducer) GetStatusAsString() string

func (p *ReliableProducer) IsOpen() bool

func (p *ReliableProducer) Send(message message.StreamMessage) error