queuelib

type Config struct {
	ConString      string
	Scheme         string
	Host           string
	Port           int
	Username       string
	Password       string
	Vhost          string
	KafkaTopic     string
	KafkaPartition int
}

type Delivery struct {
	// Properties
	ContentType     string    // MIME content type
	ContentEncoding string    // MIME content encoding
	DeliveryMode    uint8     // queue implementation use - non-persistent (1) or persistent (2)
	Priority        uint8     // queue implementation use - 0 to 9
	CorrelationID   string    // application use - correlation identifier
	ReplyTo         string    // application use - address to reply to (ex: RPC)
	Expiration      string    // implementation use - message expiration spec
	MessageID       string    // application use - message identifier
	Timestamp       time.Time // application use - message timestamp
	Type            string    // application use - message type name
	UserID          string    // application use - creating user - should be authenticated user
	AppID           string    // application use - creating application id

	// Valid only with Channel.Consume
	ConsumerTag string

	// Valid only with Channel.Get
	MessageCount uint32

	DeliveryTag uint64
	Redelivered bool
	Exchange    string // basic.publish exhange
	RoutingKey  string // basic.publish routing key

	Body []byte

	KafkaTopic     string
	KafkaPartition int
	KafkaKey       []byte
}

type GetStruct struct {
	Queue   string
	AutoAck bool
}

type Kafka struct {
	Connection *kafka.Conn
}

type PublishStruct struct {
	Exchange              string
	Key                   string
	Mandatory             bool
	Immediate             bool
	Message               []byte
	ContentType           string
	DeliveryTag           uint64
	Delay                 uint64 //Delay in milliseconds
	KafkaTimeoutInSeconds time.Duration
}

type Queue interface {
	Connect(*Config) (bool, error)
	Publish(PublishStruct) (bool, error)
	Subscribe(SubscribeStruct) (<-chan Delivery, error)
	Get(GetStruct) (Delivery, bool, error)
	Acknowledge(Delivery) (bool, error)
}

type RabbitMQ struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
}

type SubscribeStruct struct {
	Queue                 string
	Consumer              string
	AutoAck               bool
	Exclusive             bool
	NoLocal               bool
	NoWait                bool
	PrefetchCount         int //Allows batching of messages
	PrefetchSize          int
	ApplyPrefetchGlobally bool //apply prefetch settings to all channels - across all consumers
	KafkaTopic            string
	KafkaConsumerGroupID  string
	KafkaBrokers          []string
}