-
Notifications
You must be signed in to change notification settings - Fork 0
/
notifier_rabbitmq.go
55 lines (46 loc) · 3.67 KB
/
notifier_rabbitmq.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
package v2
import (
"github.com/jaehoonkim/synapse/pkg/manager/database/vanilla"
)
type NotifierRabbitMq_essential struct {
//amqp Dial
Url string `column:"url,default(0)" json:"url"`
//amqp.Channel.Publish
ChannelPublish struct {
Exchange vanilla.NullString `column:"exchange" json:"exchange,omitempty" swaggertype:"string"`
RoutingKey vanilla.NullString `column:"routing_key" json:"routing_key,omitempty" swaggertype:"string"`
Mandatory vanilla.NullBool `column:"mandatory" json:"mandatory,omitempty" swaggertype:"boolean"`
Immediate vanilla.NullBool `column:"immediate" json:"immediate,omitempty" swaggertype:"boolean"`
} `json:"channel_publish"`
//amqp.Publishing
Publishing struct {
MessageHeaders vanilla.NullObject `column:"message_headers" json:"message_headers,omitempty" swaggertype:"object"` // Application or header exchange table
MessageContentType vanilla.NullString `column:"message_content_type" json:"message_content_type,omitempty" swaggertype:"string"` // MIME content type
MessageContentEncoding vanilla.NullString `column:"message_content_encoding" json:"message_content_encoding,omitempty" swaggertype:"string"` // MIME content encoding
MessageDeliveryMode vanilla.NullUint8 `column:"message_delivery_mode" json:"message_delivery_mode,omitempty" swaggertype:"integer"` // queue implementation use - Transient (1) or Persistent (2)
MessagePriority vanilla.NullUint8 `column:"message_priority" json:"message_priority,omitempty" swaggertype:"integer"` // queue implementation use - 0 to 9
MessageCorrelationId vanilla.NullString `column:"message_correlation_id" json:"message_correlation_id,omitempty" swaggertype:"string"` // application use - correlation identifier
MessageReplyTo vanilla.NullString `column:"message_reply_to" json:"message_reply_to,omitempty" swaggertype:"string"` // application use - address to to reply to (ex: RPC)
MessageExpiration vanilla.NullString `column:"message_expiration" json:"message_expiration,omitempty" swaggertype:"string"` // implementation use - message expiration spec
MessageMessageId vanilla.NullString `column:"message_message_id" json:"message_message_id,omitempty" swaggertype:"string"` // application use - message identifier
MessageTimestamp vanilla.NullBool `column:"message_timestamp" json:"message_timestamp,omitempty" swaggertype:"boolean"` // application use - message timestamp
MessageType vanilla.NullString `column:"message_type" json:"message_type,omitempty" swaggertype:"string"` // application use - message type name
MessageUserId vanilla.NullString `column:"message_user_id" json:"message_user_id,omitempty" swaggertype:"string"` // application use - creating user id
MessageAppId vanilla.NullString `column:"message_app_id" json:"message_app_id,omitempty" swaggertype:"string"` // application use - creating application
} `json:"publishing"`
}
type NotifierRabbitMq_property struct {
NotifierRabbitMq_essential `json:",inline"`
Created vanilla.NullTime `column:"created" json:"created,omitempty" swaggertype:"string"`
Updated vanilla.NullTime `column:"updated" json:"updated,omitempty" swaggertype:"string"`
}
func (NotifierRabbitMq_property) Type() NotifierType {
return NotifierTypeRabbitmq
}
func (NotifierRabbitMq_property) TableName() string {
return "managed_channel_notifier_rabbitmq"
}
type NotifierRabbitMq struct {
NotifierRabbitMq_property `json:",inline"`
Uuid string `column:"uuid" json:"uuid,omitempty"` // pk
}