activemq

package module

v1.2.6 Latest Latest Go to latest Published: Mar 9, 2024 License: MIT Imports: 13 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/tx7do/kratos-transport

Links

Open Source Insights

README ¶

ActiveMQ

什么是ActiveMQ？

ActiveMQ 是 Apache 出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现，尽管 JMS 规范出台已经是很久的事情了，但是 JMS 在当今的 J2EE 应用中间仍然扮演着特殊的地位。

ActiveMQ的主要特点如下：

支持Java消息服务(JMS) 1.1 版本
支持的编程语言包括：C、C++、C#、Delphi、Erlang、Adobe Flash、Haskell、Java、JavaScript、Perl、PHP、Pike、Python和Ruby；
协议支持包括：OpenWire、REST、STOMP、WS-Notification、MQTT、XMPP以及AMQP
集群 (Clustering)

Docker部署开发环境

docker pull rmohr/activemq:latest

docker run -d \
      --name activemq-test \
      -p 61616:61616 \
      -p 8161:8161 \
      -p 5672:5672 \
      -p 61613:61613 \
      -p 1883:1883 \
      -p 61614:61614 \
      rmohr/activemq:latest

端口号	协议
61616	JMS
8161	UI
5672	AMQP
61613	STOMP
1883	MQTT
61614	WS

管理后台：http://localhost:8161/admin/
默认账号名密码：admin/admin

Documentation ¶

Index ¶

Constants
func LogDebug(args ...interface{})
func LogDebugf(format string, args ...interface{})
func LogError(args ...interface{})
func LogErrorf(format string, args ...interface{})
func LogFatal(args ...interface{})
func LogFatalf(format string, args ...interface{})
func LogInfo(args ...interface{})
func LogInfof(format string, args ...interface{})
func LogWarn(args ...interface{})
func LogWarnf(format string, args ...interface{})
func RegisterSubscriber[T any](srv *Server, ctx context.Context, topic string, ...) error
type Server
- func NewServer(opts ...ServerOption) *Server
- func (s *Server) Endpoint() (*url.URL, error)
- func (s *Server) Name() string
- func (s *Server) RegisterSubscriber(ctx context.Context, topic string, handler broker.Handler, ...) error
- func (s *Server) Start(ctx context.Context) error
- func (s *Server) Stop(_ context.Context) error
type ServerOption
- func WithAddress(addrs []string) ServerOption
- func WithBrokerOptions(opts ...broker.Option) ServerOption
- func WithCodec(c string) ServerOption
- func WithEnableKeepAlive(enable bool) ServerOption
- func WithGlobalPropagator() ServerOption
- func WithGlobalTracerProvider() ServerOption
- func WithPropagator(propagators propagation.TextMapPropagator) ServerOption
- func WithTLSConfig(c *tls.Config) ServerOption
- func WithTracerProvider(provider trace.TracerProvider, tracerName string) ServerOption
type SubscribeOption
type SubscribeOptionMap
type SubscriberMap
type Transport
- func (tr *Transport) Endpoint() string
- func (tr *Transport) Kind() transport.Kind
- func (tr *Transport) NodeFilters() []selector.NodeFilter
- func (tr *Transport) Operation() string
- func (tr *Transport) ReplyHeader() transport.Header
- func (tr *Transport) RequestHeader() transport.Header

Constants ¶

View Source

const (
	KindActiveMQ transport.Kind = "activemq"
)

Variables ¶

This section is empty.

Functions ¶

func LogDebug ¶

func LogDebug(args ...interface{})

func LogDebugf ¶

func LogDebugf(format string, args ...interface{})

func LogError ¶

func LogError(args ...interface{})

func LogErrorf ¶

func LogErrorf(format string, args ...interface{})

func LogFatal ¶

func LogFatal(args ...interface{})

func LogFatalf ¶

func LogFatalf(format string, args ...interface{})

func LogInfo ¶

func LogInfo(args ...interface{})

func LogInfof ¶

func LogInfof(format string, args ...interface{})

func LogWarn ¶

func LogWarn(args ...interface{})

func LogWarnf ¶

func LogWarnf(format string, args ...interface{})

func RegisterSubscriber ¶

func RegisterSubscriber[T any](srv *Server, ctx context.Context, topic string, handler func(context.Context, string, broker.Headers, *T) error, opts ...broker.SubscribeOption) error

Types ¶

type Server ¶

type Server struct {
	broker.Broker

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewServer ¶

func NewServer(opts ...ServerOption) *Server

func (*Server) Endpoint ¶

func (s *Server) Endpoint() (*url.URL, error)

func (*Server) Name ¶

func (s *Server) Name() string

func (*Server) RegisterSubscriber ¶

func (s *Server) RegisterSubscriber(ctx context.Context, topic string, handler broker.Handler, binder broker.Binder, opts ...broker.SubscribeOption) error

func (*Server) Start ¶

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop ¶

func (s *Server) Stop(_ context.Context) error

type ServerOption ¶

type ServerOption func(o *Server)

func WithAddress ¶

func WithAddress(addrs []string) ServerOption

func WithBrokerOptions ¶

func WithBrokerOptions(opts ...broker.Option) ServerOption

WithBrokerOptions MQ代理配置

func WithCodec ¶

func WithCodec(c string) ServerOption

func WithEnableKeepAlive ¶

func WithEnableKeepAlive(enable bool) ServerOption

WithEnableKeepAlive enable keep alive

func WithGlobalPropagator ¶

func WithGlobalPropagator() ServerOption

func WithGlobalTracerProvider ¶

func WithGlobalTracerProvider() ServerOption

func WithPropagator ¶

func WithPropagator(propagators propagation.TextMapPropagator) ServerOption

func WithTLSConfig ¶

func WithTLSConfig(c *tls.Config) ServerOption

func WithTracerProvider ¶

func WithTracerProvider(provider trace.TracerProvider, tracerName string) ServerOption

type SubscribeOption ¶

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

type SubscribeOptionMap ¶

type SubscribeOptionMap map[string]*SubscribeOption

type SubscriberMap ¶

type SubscriberMap map[string]broker.Subscriber

type Transport ¶

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

Transport is a ActiveMQ transport.

func (*Transport) Endpoint ¶

func (tr *Transport) Endpoint() string

Endpoint returns the transport endpoint.

func (*Transport) Kind ¶

func (tr *Transport) Kind() transport.Kind

Kind returns the transport kind.

func (*Transport) NodeFilters ¶

func (tr *Transport) NodeFilters() []selector.NodeFilter

NodeFilters returns the client select filters.

func (*Transport) Operation ¶

func (tr *Transport) Operation() string

Operation returns the transport operation.

func (*Transport) ReplyHeader ¶

func (tr *Transport) ReplyHeader() transport.Header

ReplyHeader returns the reply header.

func (*Transport) RequestHeader ¶

func (tr *Transport) RequestHeader() transport.Header

RequestHeader returns the request header.

Source Files ¶

View all Source files

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