Every line of 'rabbitmq routing key' code snippets is scanned for vulnerabilities by our powerful machine learning engine that combs millions of open source libraries, ensuring your Go code is secure.
139 func (c *Call) RoutingKey() string { 140 if c == nil { 141 return "" 142 } 143 return c.ic.req.RoutingKey 144 }
122 func (cb *ContextBuilder) SetRoutingKey(rk string) *ContextBuilder { 123 if cb.CallOptions == nil { 124 cb.CallOptions = new(CallOptions) 125 } 126 cb.CallOptions.RoutingKey = rk 127 return cb 128 }
176 func (binding TaskRunning) RoutingKey() string { 177 return generateRoutingKey(&binding) 178 }
211 func (q *AMQP) routingKey(metric telegraf.Metric) string { 212 if q.RoutingTag != "" { 213 key, ok := metric.GetTag(q.RoutingTag) 214 if ok { 215 return key 216 } 217 } 218 return q.RoutingKey 219 }
526 func (channel *Channel) ackMsg(unackedMessage *UnackedMessage, deliveryTag uint64) { 527 delete(channel.ackStore, deliveryTag) 528 q := channel.conn.GetVirtualHost().GetQueue(unackedMessage.queue) 529 if q != nil { 530 q.AckMsg(unackedMessage.msg) 531 532 channel.metrics.Acknowledge.Counter.Inc(1) 533 channel.metrics.Unacked.Counter.Dec(1) 534 } 535 536 channel.decQosAndConsumerNext(unackedMessage) 537 }
92 func rabbitmqReceive(r *Rabbitmq) { 93 loop: 94 for { 95 deliveries, _ := r.sub.channel.Consume( 96 r.queue, 97 r.sub.tag, 98 false, 99 false, 100 false, 101 false, 102 nil, 103 ) 104 105 for d := range deliveries { 106 if r.handler.ReceiveMessage(d.Body) { 107 break loop 108 } 109 } 110 } 111 }
182 func (ch *Channel) QueueUnbind(name, route, exchange string, _ wabbit.Option) error { 183 return ch.Channel.QueueUnbind(name, route, exchange, nil) 184 }
10 func checkBind(queue string, routingKey string) error { 11 if len(queue) == 0 { 12 return fmt.Errorf("queue empty forbidden") 13 } else if len(queue) > proto.MaxQueueName { 14 return fmt.Errorf("queue too long") 15 } else if len(routingKey) > proto.MaxRoutingKeyName { 16 return fmt.Errorf("routingkey too long") 17 } 18 return nil 19 }
146 func RabbitQueueConsumer(ch *amqp.Channel, config QueueConfig) <-chan amqp.Delivery { 147 msgs, err := ch.Consume( 148 config.Name, 149 config.Exchange, 150 config.AutoAck, 151 config.Exclusive, 152 config.Local, 153 config.Wait, 154 nil, 155 ) 156 157 if err != nil { 158 panic(err.Error()) 159 } 160 161 return msgs 162 }
107 func (c *AMQPMessageQueueProvider) BindKey() string { 108 bindKey := c.macro.Consume["key"] 109 if bindKey != "" { 110 return bindKey 111 } 112 return c.QueueName() 113 }