bridge

Documentation

Index

• Constants
• type Bridge
  • func NewBridge(p Publisher, s Subscriber, ctx context.Context, stomp config.Stomp) *Bridge
  • func (b *Bridge) StartBridge()
• type Publisher
• type Subscriber

Constants

const (
	OFFLINE = iota
	ONLINE
)

const (
	NATS_STOMP_SUBJECT_PREFIX         = "stomp.usp.v1."
	NATS_STOMP_ADAPTER_SUBJECT_PREFIX = "stomp-adapter.usp.v1."
	DEVICE_SUBJECT_PREFIX             = "device.usp.v1."
	STOMP_QUEUE_PREFIX                = "oktopus/usp/v1/"
	STOMP_STATUS_QUEUE                = STOMP_QUEUE_PREFIX + "status"
	DEVICE_TIMEOUT_RESPONSE           = 5 * time.Second
	USP_CONTENT_TYPE                  = "application/vnd.bbf.usp.msg"
)

const STOMP_CONNECTION_RETRY = 5 * time.Second

Types

type Bridge

type Bridge struct {
	Pub   Publisher
	Sub   Subscriber
	Stomp config.Stomp
	Ctx   context.Context
}

func NewBridge

func NewBridge(p Publisher, s Subscriber, ctx context.Context, stomp config.Stomp) *Bridge

func (*Bridge) StartBridge

func (b *Bridge) StartBridge()

type Publisher

type Publisher func(string, []byte) error

type Subscriber

type Subscriber func(string, func(*nats.Msg)) error