gorabbit

May 26, 2022

Changes in this version

+ const MaxMessagesPerConnection

Aug 4, 2020

Changes in this version

+ const DefaultMaxConnectionOnRPS

+ const DefaultMaxConnections

+ const DefaultMaxIdleConnectionLifeTime

+ type ConnectionPool struct

+ func NewConnectionPool() *ConnectionPool

+ func (cp *ConnectionPool) GetConnection(s RabbitServer) (c *connection, e porterr.IError)

+ func (cp *ConnectionPool) Publish(p amqp.Publishing, s RabbitServer, q RabbitQueue, route ...string) (e porterr.IError)

type RabbitServer

+ MaxConnections int

+ MaxIdleConnectionLifeTime time.Duration

+ type ServerPool struct

+ func NewServerPool(l gocli.Logger) *ServerPool

+ func (sp *ServerPool) GetConnectionPoolOrCreate(server string) *ConnectionPool

Mar 3, 2020

Changes in this version

type Application

+ func (a *Application) SetRegistry(r Registry) *Application

Mar 2, 2020

Changes in this version

+ const CommandConsumer

+ const CommandKeyWordAll

+ const CommandKeyWordCount

+ const CommandRestart

+ const CommandSet

+ const CommandStart

+ const CommandStatus

+ const CommandStop

+ func ParseCommand(command gocli.Command) (action string, arguments []gocli.Argument, e porterr.IError)

type Application

+ func (a *Application) AttentionMessage(message string, command gocli.Command)

+ func (a *Application) ConsumerCommander(command gocli.Command)

+ func (a *Application) FailMessage(message string, command gocli.Command)

+ func (a *Application) GetConfig() *Config

+ func (a *Application) GetRegistry() *Registry

+ func (a *Application) SuccessMessage(message string, command gocli.Command)

type Consumer

+ Callback func(d amqp.Delivery)

+ Count uint8

+ Queue string

+ Server string

+ func (c *Consumer) HasSubscribers() bool

+ func (c *Consumer) NewSubscriber(name string) *subscriber

+ func (c *Consumer) Stop()

+ func (c *Consumer) Subscribe(logger gocli.Logger) porterr.IError

+ func (c *Consumer) SubscribersCount() uint8

Oct 15, 2019

Changes in this version

+ type Application struct

+ func NewApplication(config Config, app gocli.Application) *Application

+ func (a *Application) Consume(registry Registry, arguments gocli.Arguments)

+ func (a *Application) NewConsumer(serverName string, queueName string, callback func(d amqp.Delivery)) *Consumer

+ func (a *Application) Publish(publishing amqp.Publishing, queue string, server string) porterr.IError

+ func (a *Application) Subscribe(consumer *Consumer)

+ type Config struct

+ Queues Queues

+ Servers Servers

+ func (c *Config) GetQueue(name string) (*RabbitQueue, porterr.IError)

+ func (c *Config) GetServer(name string) (*RabbitServer, porterr.IError)

+ type Consumer struct

+ type Queues map[string]RabbitQueue

+ type RabbitQueue struct

+ Arguments map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ Exchange string

+ Exclusive bool

+ Internal bool

+ Name string

+ Nowait bool

+ Passive bool

+ RoutingKey []string

+ Server string

+ Type string

+ type RabbitServer struct

+ Host string

+ Password string

+ Port int

+ User string

+ Vhost string

+ func (srv *RabbitServer) String() string

+ type Registry map[string]RegistryItem

+ type RegistryItem struct

+ Callback func(d amqp.Delivery)

+ Count byte

+ Queue string

+ Server string

+ type Servers map[string]RabbitServer