Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPQueue ¶
type AMQPQueue struct {
// contains filtered or unexported fields
}
func NewAMQPQueue ¶
type JMSAMQPQueue ¶
type JMSAMQPQueue struct {
// contains filtered or unexported fields
}
func NewJMSAMQPQueue ¶
func NewJMSAMQPQueue(amqpURI, queueName, exchangeName, topic string) *JMSAMQPQueue
func (*JMSAMQPQueue) Init ¶
func (jaq *JMSAMQPQueue) Init() error
func (*JMSAMQPQueue) Publish ¶
func (jaq *JMSAMQPQueue) Publish(data interface{}) error
func (*JMSAMQPQueue) Shutdown ¶
func (jaq *JMSAMQPQueue) Shutdown() error
Click to show internal directories.
Click to hide internal directories.