mirror of
https://github.com/go-micro/go-micro.git
synced 2025-02-10 18:31:40 +02:00
35 lines
558 B
Go
35 lines
558 B
Go
package stomp
|
|
|
|
import (
|
|
"go-micro.dev/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
|
|
}
|