Documentation ¶
Index ¶
- Constants
- type AMQPConnection
- type Channel
- func (channel *Channel) AcquireResources(qm *amqp.QueueMessage) bool
- func (channel *Channel) AddUnackedMessage(consumerTag string, msg *amqp.QueueMessage, queueName string) uint64
- func (channel *Channel) FlowActive() bool
- func (channel *Channel) ReleaseResources(qm *amqp.QueueMessage)
- func (channel *Channel) SendContent(method amqp.MethodFrame, message *amqp.Message)
- func (channel *Channel) SendMethod(method amqp.MethodFrame)
- type ConnectStatus
- type Server
- type User
Constants ¶
View Source
const ( CH_STATE_INIT = iota CH_STATE_OPEN = iota CH_STATE_CLOSING = iota CH_STATE_CLOSED = iota )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPConnection ¶
type AMQPConnection struct {
// contains filtered or unexported fields
}
func NewAMQPConnection ¶
func NewAMQPConnection(server *Server, network net.Conn) *AMQPConnection
func (*AMQPConnection) MarshalJSON ¶
func (conn *AMQPConnection) MarshalJSON() ([]byte, error)
type Channel ¶
type Channel struct {
// contains filtered or unexported fields
}
func NewChannel ¶
func NewChannel(id uint16, conn *AMQPConnection) *Channel
func (*Channel) AcquireResources ¶
func (channel *Channel) AcquireResources(qm *amqp.QueueMessage) bool
func (*Channel) AddUnackedMessage ¶
func (*Channel) FlowActive ¶
func (*Channel) ReleaseResources ¶
func (channel *Channel) ReleaseResources(qm *amqp.QueueMessage)
func (*Channel) SendContent ¶
func (channel *Channel) SendContent(method amqp.MethodFrame, message *amqp.Message)
Send a method frame out to the client
func (*Channel) SendMethod ¶
func (channel *Channel) SendMethod(method amqp.MethodFrame)
Send a method frame out to the client TODO: why isn't this taking a pointer?
type ConnectStatus ¶
type ConnectStatus struct {
// contains filtered or unexported fields
}
TODO: we can only be "in" one of these at once, so this should probably be one field
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) MarshalJSON ¶
func (*Server) OpenConnection ¶
Click to show internal directories.
Click to hide internal directories.