package stomp

import (
	"gitee.com/sasukebo/go-micro/v4/broker"
	"github.com/go-stomp/stomp/v3"
)

type publication struct {
	// msg is the actual STOMP message
	msg *stomp.Message
	// m is the broker message
	m *broker.Message
	// Link to the broken (for ack)
	broker *rbroker
	// Topic
	topic string
	err   error
}

func (p *publication) Ack() error {
	return p.broker.stompConn.Ack(p.msg)
}

func (p *publication) Error() error {
	return p.err
}

func (p *publication) Topic() string {
	return p.topic
}

func (p *publication) Message() *broker.Message {
	return p.m
}