transit/tcp/tcp-transporter.go
Method TCPTransporter.Publish
has 6 return statements (exceeds 4 allowed). Open
Open
func (transporter *TCPTransporter) Publish(command, nodeID string, message moleculer.Payload) {
transporter.logger.Debug("TCPTransporter.Publish() command: " + command + " to nodeID: " + nodeID)
if command == "DISCOVER" {
if transporter.udpServer != nil {
transporter.udpServer.BroadcastDiscoveryMessage()