activemq

README

Kubemq ActiveMQ Target Connector

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

Prerequisites

The following are required to run the activemq target connector:

• kubemq cluster
• activemq server
• kubemq-targets deployment

Configuration

ActiveMQ target connector configuration properties:

Properties Key	Required	Description	Example
host	yes	activemq connection host	"localhost:1883"
username	no	set activemq username	"username"
password	no	set activemq password	"password"
default_destination	no	set activemq default destination	"q1"

Example:

bindings:
  - name: kubemq-query-activemq
    source:
      kind: kubemq.query
      name: kubemq-query
      properties:
        address: "kubemq-cluster:50000"
        client_id: "kubemq-query-activemq-connector"
        auth_token: ""
        channel: "query.activemq"
        group:   ""
        auto_reconnect: "true"
        reconnect_interval_seconds: "1"
        max_reconnects: "0"
    target:
      kind: messaging.activemq
      name: target-activemq
      properties:
        host: "localhost:61613"
        username: "admin"
        password: "admin"
        default_destination: ""

Usage

Request

Request metadata setting:

Metadata Key	Required	Description	Possible values
destination	yes	set destination name	"destination"

Query request data setting:

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

Example:

{
  "metadata": {
    "destination": "destination"
  },
  "data": "U0VMRUNUIGlkLHRpdGxlLGNvbnRlbnQgRlJPTSBwb3N0Ow=="
}

Documentation

Index

• func Connector() *common.Connector
• type Client
  • func New() *Client
  • func (c *Client) Connector() *common.Connector
  • func (c *Client) Do(ctx context.Context, req *types.Request) (*types.Response, error)
  • func (c *Client) Init(ctx context.Context, cfg config.Spec, log *logger.Logger) 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) 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) Stop

func (c *Client) Stop() error