Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func TrySendToPotentiallyClosedChannel ¶
func TrySendToPotentiallyClosedChannel(channel chan<- channelstructs.ListenerOutput, msg channelstructs.ListenerOutput)
Types ¶
type AMQPListener ¶
type AMQPListener struct { PActiveMatches *match.ActiveMatches Channels ChannelBundle }
func (*AMQPListener) Run ¶
func (ls *AMQPListener) Run()
type ChannelBundle ¶
type ChannelBundle struct { ChanLS2MM chan channelstructs.ListenerOutput ChanAMQP <-chan amqp.Delivery }
Click to show internal directories.
Click to hide internal directories.