From ed39d5d5ed392a94182ba62a29ec4db8cfcdd8a0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Martin=20M=C3=A1gr?= Date: Mon, 29 Apr 2024 17:30:53 +0200 Subject: [PATCH] s/paralel/parallel --- connector/amqp10/amqp10.go | 64 +++++++++++++++++++------------------- 1 file changed, 32 insertions(+), 32 deletions(-) diff --git a/connector/amqp10/amqp10.go b/connector/amqp10/amqp10.go index 6a1ca81..764114b 100644 --- a/connector/amqp10/amqp10.go +++ b/connector/amqp10/amqp10.go @@ -20,24 +20,24 @@ const ( defaultListenPrefetch = 1 defaultClientName = "localhost" defaultLinkFailureLimit = 20 - defaultMaxParalelSend = 128 + defaultMaxParallelSend = 128 ) // AMQP10Connector is the object to be used for communication with AMQP-1.0 entity type AMQP10Connector struct { - Address string - ClientName string - SendTimeout int64 - ListenPrefetch int64 - LinkFailureLimit int64 - MaxParalelSendLimit int64 - appName string - inConnection *amqp.Session - outConnection *amqp.Session - receivers map[string]*amqp.Receiver - senders map[string]*amqp.Sender - logger *logging.Logger - interrupt chan bool + Address string + ClientName string + SendTimeout int64 + ListenPrefetch int64 + LinkFailureLimit int64 + MaxParallelSendLimit int64 + appName string + inConnection *amqp.Session + outConnection *amqp.Session + receivers map[string]*amqp.Receiver + senders map[string]*amqp.Sender + logger *logging.Logger + interrupt chan bool } // AMQP10Message holds received (or to be sent) messages from (to) AMQP-1.0 entity @@ -80,22 +80,22 @@ func CreateAMQP10Connector( appName string, sendTimeout int64, linkFailureLimit int64, - maxParalelLimit int64, + maxParallelLimit int64, listenPrefetch int64, listenChannels []string, ) (*AMQP10Connector, error) { connector := AMQP10Connector{ - Address: address, - ClientName: clientName, - SendTimeout: sendTimeout, - ListenPrefetch: listenPrefetch, - LinkFailureLimit: linkFailureLimit, - MaxParalelSendLimit: maxParalelLimit, - appName: appName, - logger: logger, - receivers: make(map[string]*amqp.Receiver), - senders: make(map[string]*amqp.Sender), - interrupt: make(chan bool), + Address: address, + ClientName: clientName, + SendTimeout: sendTimeout, + ListenPrefetch: listenPrefetch, + LinkFailureLimit: linkFailureLimit, + MaxParallelSendLimit: maxParallelLimit, + appName: appName, + logger: logger, + receivers: make(map[string]*amqp.Receiver), + senders: make(map[string]*amqp.Sender), + interrupt: make(chan bool), } // connect @@ -154,13 +154,13 @@ func ConnectAMQP10(appName string, cfg config.Config, logger *logging.Logger) (* switch conf := cfg.(type) { case *config.INIConfig: - opt, err = conf.GetOption("amqp1/send_max_in_paralel") + opt, err = conf.GetOption("amqp1/send_max_in_parallel") case *config.JSONConfig: - opt, err = conf.GetOption("Amqp1.Connection.SendMaxInParalel") + opt, err = conf.GetOption("Amqp1.Connection.SendMaxInParallel") } - maxParalelLimit := int64(defaultMaxParalelSend) + maxParallelLimit := int64(defaultMaxParallelSend) if opt != nil && err == nil { - maxParalelLimit = opt.GetInt() + maxParallelLimit = opt.GetInt() } switch conf := cfg.(type) { @@ -196,7 +196,7 @@ func ConnectAMQP10(appName string, cfg config.Config, logger *logging.Logger) (* prf = opt.GetInt() } - return CreateAMQP10Connector(logger, addr, clientName, appName, sendTimeout, linkLimit, maxParalelLimit, prf, listen) + return CreateAMQP10Connector(logger, addr, clientName, appName, sendTimeout, linkLimit, maxParallelLimit, prf, listen) } //---------------------------- connect helpers and method ---------------------------- @@ -379,7 +379,7 @@ func (conn *AMQP10Connector) startSenders(inchan chan interface{}, wg *sync.Wait // block if we have too much sending goroutines sndLock.RLock() - for activeSend > conn.MaxParalelSendLimit { + for activeSend > conn.MaxParallelSendLimit { time.Sleep(time.Second) } sndLock.RUnlock()