rabbitmq

package

v1.8.1 Latest Latest Go to latest Published: Mar 18, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubemq-io/kubemq-targets

Links

Open Source Insights

README ¶

Kubemq RabbitMQ Target Connector

Kubemq rabbitmq target connector allows services using kubemq server to access rabbitmq messaging services.

Prerequisites

The following are required to run the rabbitmq target connector:

kubemq cluster
rabbitmq server
kubemq-targets deployment

Configuration

RabbitMQ target connector configuration properties:

Properties Key	Required	Description	Example
url	yes	rabbitmq connection string address	"amqp://rabbitmq:rabbitmq@localhost:5672/"
default_exchange	no	set default exchange routing	"exchange.1"
default_topic	no	set default topic routing	"topic1"
default_persistence	no	set default persistence for messages	"true"
ca_cert	no	SSL CA certificate	pem certificate value
client_certificate	no	SSL Client certificate (mMTL)	pem certificate value
client_key	no	SSL Client Key (mTLS)	pem key value

Example:

bindings:
  - name: kubemq-query-rabbitmq
    source:
      kind: kubemq.query
      name: kubemq-query
      properties:
        address: "kubemq-cluster:50000"
        client_id: "kubemq-query-rabbitmq-connector"
        auth_token: ""
        channel: "query.rabbitmq"
        group:   ""
        concurrency: "1"
        auto_reconnect: "true"
        reconnect_interval_seconds: "1"
        max_reconnects: "0"
    target:
      kind: messaging.rabbitmq
      name: target-rabbitmq
      properties:
        url: "amqp://rabbitmq:rabbitmq@localhost:5672/"
        default_exchange: "exchange"
        default_topic: "topic1"
        default_persistence: "true"

Usage

Request

Request metadata setting:

Metadata Key	Required	Description	Possible values
queue	yes	set queue name	"queue"
exchange	no	set exchange name	"exchange"
mandatory	no	set mandatory	"true","false"
immediate	no	set immediate	"true","false"
delivery_mode	no	set delivery mode	"1","2"
priority	no	set priority	"0"-"9"
correlation_id	no	set correlation id	"some id"
reply_to	no	set set reply to	""
expiry_seconds	no	set message expiry in seconds	"3600"

Query request data setting:

Data Key	Required	Description	Possible values
data	yes	data to publish	base64 bytes array

Example:

{
  "metadata": {
    "queue": "queue",
    "exchange": "",
    "confirm": "true",
    "mandatory": "false",
    "immediate": "false",
    "delivery_mode": "1",
    "priority": "0",
    "correlation_id": "",
    "reply_to": "",
    "expiry_seconds": "3600"
    
  },
  "data": "U0VMRUNUIGlkLHRpdGxlLGNvbnRlbnQgRlJPTSBwb3N0Ow=="
}

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Connector ¶

func Connector() *common.Connector

Types ¶

type Client ¶

type Client struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New ¶

func New() *Client

func (*Client) Connector ¶

func (c *Client) Connector() *common.Connector

func (*Client) Do ¶

func (c *Client) Do(ctx context.Context, req *types.Request) (*types.Response, error)

func (*Client) Init ¶

func (c *Client) Init(ctx context.Context, cfg config.Spec, log *logger.Logger) error

func (*Client) Publish ¶

func (c *Client) Publish(ctx context.Context, meta metadata, data []byte) (*types.Response, error)

func (*Client) Stop ¶

func (c *Client) Stop() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL