activemq

Documentation

Index

• func CheckConnection(activemq ActiveMQ) bool
• type ActiveMQ
  • func NewActiveMQConnection(config ActiveMQconfig) *ActiveMQ
  • func NewActiveMQConnectionExternal(config ActiveMQconfig, docDBconn *documents.DocDB, db *sql.DB, ...) *ActiveMQ
  • func (a *ActiveMQ) CallWebService(msg *stomp.Message, topic string, handler string)
  • func (a *ActiveMQ) Subscribes()
• type ActiveMQconfig
• type ActiveMQconfigs
• type ActiveMQtopic

Functions

func CheckConnection

func CheckConnection(activemq ActiveMQ) bool

Types

type ActiveMQ

type ActiveMQ struct {
	Config       ActiveMQconfig
	Conn         *stomp.Conn
	Subs         []*stomp.Subscription
	ConnectionID string
	QueueID      string

	Queue         *queue.MessageQueue
	DocDBconn     *documents.DocDB
	DB            *sql.DB
	SignalRClient signalr.Client
	AppServer     string
	ApiKey        string
	// contains filtered or unexported fields
}

ActiveMQ struct

func NewActiveMQConnection

func NewActiveMQConnection(config ActiveMQconfig) *ActiveMQ

type msghandler struct {
	Topic   string
	Handler string
	Message stomp.Message
}

func NewActiveMQConnectionExternal

func NewActiveMQConnectionExternal(config ActiveMQconfig, docDBconn *documents.DocDB, db *sql.DB, signalRClient signalr.Client) *ActiveMQ

func (*ActiveMQ) CallWebService

func (a *ActiveMQ) CallWebService(msg *stomp.Message, topic string, handler string)

func (*ActiveMQ) Subscribes

func (a *ActiveMQ) Subscribes()

type ActiveMQconfig

type ActiveMQconfig struct {
	Host      string          `json:"host"`
	Port      string          `json:"port"`
	Username  string          `json:"username"`
	Password  string          `json:"passwrod"`
	TLS       string          `json:"tls"`
	TLSVerify bool            `json:"tlsverify"`
	CAPath    string          `json:"CAPath"`
	CertPath  string          `json:"CertPath"`
	KeyPath   string          `json:"keypath"`
	Topics    []ActiveMQtopic `json:"topics"`
}

ActiveMQ struct

type ActiveMQconfigs

type ActiveMQconfigs struct {
	ActiveMQs []ActiveMQconfig `json:"activemqs"`
	ApiKey    string           `json:"apikey"`
}

type ActiveMQtopic

type ActiveMQtopic struct {
	Topic    string `json:"topic"`
	Handler  string `json:"handler"`
	SQLQuery string `json:"sqlquery"`
	Mode     string `json:"mode"`
	Type     string `json:"type"`
}