amazonmq

package
v1.6.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 5, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

README

Kubemq amazonMQ Source Connector

Kubemq AmazonMQ Source connector allows services using kubemq server to access AmazonMQ messaging services.

Prerequisites

The following are required to run the AmazonMQ Source connector:

  • kubemq cluster

  • AmazonMQ server - with access

  • kubemq-Sources deployment

  • Please note the connector uses connection with stomp+ssl, when finishing handling messages need to call Stop().

Configuration

AmazonMQ Source connector configuration properties:

Properties Key Required Description Example
host yes AmazonMQ connection host (stomp+ssl endpoint) "localhost:1883"
dynamic_mapping yes set if to map amazonmq Destination to kubemq channel "true"
username no set AmazonMQ username "username"
password no set AmazonMQ password "password"
destination yes set destination name "destination"

Example:

    bindings:
    - name: amazonmq
      source:
        kind: aws.amazonmq
        properties:
          destination: some-queue
          host: localhost:61613
          password: admin
          username: admin
      target:
        kind: kubemq.events
        properties:
          address: localhost:50000
          auth_token: ""
          channel: event.aws.amazonmq
          client_id: test
      properties: {}

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

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