rabbitmq

README

Kubemq RabbitMQ Source

Kubemq RabbitMQ source provides a RabbitMQ subscriber for processing RabbitMQ's messages.

Prerequisites

The following are required to run events source connector:

• kubemq cluster
• kubemq-sources deployment
• RabbitMQ Server

Configuration

RabbitMQ source connector configuration properties:

Properties Key	Required	Description	Example
url	yes	rabbitmq connection string address	"amqp://guest:guest@localhost:5672/"
queue	yes	set subscription queue	"queue"
dynamic_mapping	yes	set if to map rabbit topic to kubemq channel	"true"
consumer	yes	set subscription consumer tag	"consumer"
requeue_on_error	bool	set requeue on error property	"false"
auto_ack	bool	set auto_ack property	"false"
exclusive	bool	set exclusive property	"false"

Example:

bindings:
- name: rabbitmq
  source:
    kind: messaging.rabbitmq
    properties:
      auto_ack: "false"
      consumer: "1"
      exclusive: "false"
      dynamic_mapping: "true"
      queue: some-queue
      requeue_on_error: "false"
      url: amqp://guest:guest@localhost:5672/
  target:
    kind: kubemq.events
    properties:
      address: localhost:50000
      auth_token: ""
      channel: events.messaging.rabbitmq
      client_id: rabbitmq
  properties: {}

Documentation

Index

• func Connector() *common.Connector
• type Client
  • func New() *Client
  • func (c *Client) Connector() *common.Connector
  • func (c *Client) Init(ctx context.Context, cfg config.Spec, log *logger.Logger) error
  • func (c *Client) Start(ctx context.Context, target middleware.Middleware) error
  • func (c *Client) Stop() error

Functions

func Connector

func Connector() *common.Connector

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func New

func New() *Client

func (*Client) Connector

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

func (*Client) Init

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

func (*Client) Start

func (c *Client) Start(ctx context.Context, target middleware.Middleware) error

func (*Client) Stop

func (c *Client) Stop() error