Documentation ¶
Index ¶
- type Connector
- func (c *Connector) CancelMonitor()
- func (c *Connector) Close() error
- func (c *Connector) Dial() error
- func (c *Connector) Get(opts *connectors.SubscribeOptions) []byte
- func (m *Connector) GetPublishOptions() *connectors.PublishOptions
- func (m *Connector) GetSubscribeOptions() *connectors.SubscribeOptions
- func (c *Connector) ID() string
- func (c *Connector) Listen(opts *connectors.SubscribeOptions, outch chan []byte) error
- func (c *Connector) Monitor()
- func (c *Connector) Name() string
- func (c *Connector) On(opts *connectors.SubscribeOptions, f func(s []byte)) error
- func (c *Connector) Put(opts *connectors.PublishOptions, msg []byte) error
- func (c *Connector) Stream(opts *connectors.PublishOptions, ch chan []byte) error
- func (c *Connector) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connector ¶
type Connector struct { C *AMQP.Connection Channel *AMQP.Channel // contains filtered or unexported fields }
func (*Connector) CancelMonitor ¶
func (c *Connector) CancelMonitor()
func (*Connector) Get ¶
func (c *Connector) Get(opts *connectors.SubscribeOptions) []byte
func (*Connector) GetPublishOptions ¶
func (m *Connector) GetPublishOptions() *connectors.PublishOptions
func (*Connector) GetSubscribeOptions ¶
func (m *Connector) GetSubscribeOptions() *connectors.SubscribeOptions
func (*Connector) Listen ¶
func (c *Connector) Listen(opts *connectors.SubscribeOptions, outch chan []byte) error
func (*Connector) Monitor ¶
func (c *Connector) Monitor()
Monitor reset the status of the topology after disconnection from server Influenced by https://github.com/streadway/amqp/issues/133 per using a channel to be notified instead of using NotifyClose directly
func (*Connector) On ¶
func (c *Connector) On(opts *connectors.SubscribeOptions, f func(s []byte)) error
func (*Connector) Put ¶
func (c *Connector) Put(opts *connectors.PublishOptions, msg []byte) error
func (*Connector) Stream ¶
func (c *Connector) Stream(opts *connectors.PublishOptions, ch chan []byte) error
Click to show internal directories.
Click to hide internal directories.