Versions in this module Expand all Collapse all v2 v2.1.1 Dec 9, 2025 v2.0.0 Jun 18, 2023 Changes in this version + const PluginEmbedded + func NewClient(ctx context.Context, config cmap.CustomMap) (busPluginTY.Plugin, error) + type Client struct + func (c *Client) Close() error + func (c *Client) Name() string + func (c *Client) PausePublish() + func (c *Client) Publish(topic string, data interface{}) error + func (c *Client) QueueSubscribe(topic, _queueName string, handler busPluginTY.CallBackFunc) (int64, error) + func (c *Client) QueueUnsubscribe(topic, _queueName string, subscriptionID int64) error + func (c *Client) ResumePublish() + func (c *Client) Subscribe(topic string, handler busPluginTY.CallBackFunc) (int64, error) + func (c *Client) TopicPrefix() string + func (c *Client) Unsubscribe(topic string, subscriptionID int64) error + func (c *Client) UnsubscribeAll(topic string) error + type Config struct + TopicPrefix string + Type string
Go to main page