You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
41 lines
836 B
41 lines
836 B
package rabbitmq
|
|
|
|
import amqp "github.com/rabbitmq/amqp091-go"
|
|
|
|
// Table stores user supplied fields of the following types:
|
|
//
|
|
// bool
|
|
// byte
|
|
// float32
|
|
// float64
|
|
// int
|
|
// int16
|
|
// int32
|
|
// int64
|
|
// nil
|
|
// string
|
|
// time.Time
|
|
// amqp.Decimal
|
|
// amqp.Table
|
|
// []byte
|
|
// []interface{} - containing above types
|
|
//
|
|
// Functions taking a table will immediately fail when the table contains a
|
|
// value of an unsupported type.
|
|
//
|
|
// The caller must be specific in which precision of integer it wishes to
|
|
// encode.
|
|
//
|
|
// Use a type assertion when reading values from a table for type conversion.
|
|
//
|
|
// RabbitMQ expects int32 for integer values.
|
|
//
|
|
type Table map[string]interface{}
|
|
|
|
func tableToAMQPTable(table Table) amqp.Table {
|
|
new := amqp.Table{}
|
|
for k, v := range table {
|
|
new[k] = v
|
|
}
|
|
return new
|
|
}
|