Documentation
¶
Index ¶
Constants ¶
View Source
const ( ContentTooLarge = 311 NoRoute = 312 NoConsumers = 313 ConnectionForced = 320 InvalidPath = 402 AccessRefused = 403 NotFound = 404 ResourceLocked = 405 PreconditionFailed = 406 FrameError = 501 SyntaxError = 502 CommandInvalid = 503 ChannelError = 504 UnexpectedFrame = 505 ResourceError = 506 NotAllowed = 530 NotImplemented = 540 InternalError = 541 )
Error codes that can be sent from the server during a connection or channel exception or used by the client to indicate a class of error like ErrCredentials. The text of the error is likely more interesting than these constants.
Variables ¶
This section is empty.
Functions ¶
func ConvertOpt ¶
func ConvertOpt(opt wabbit.Option) (amqp.Publishing, error)
Types ¶
type ErrBroadcast ¶
type ErrBroadcast struct {
sync.Mutex // Protects listeners
// contains filtered or unexported fields
}
ErrBroadcast enables broadcast an error channel to various listener channels
func NewErrBroadcast ¶
func NewErrBroadcast() *ErrBroadcast
NewErrBroadcast creates a broadcast object for push errors to subscribed channels
func (*ErrBroadcast) Delete ¶
func (b *ErrBroadcast) Delete(c chan<- wabbit.Error)
Delete the listener
func (*ErrBroadcast) Write ¶
func (b *ErrBroadcast) Write(err wabbit.Error)
Write to subscribed channels
Source Files
Click to show internal directories.
Click to hide internal directories.