ConnectionInterface
in
Table of Contents
Methods
- channel() : Channel|null
- 获取一个可用通道
- channels() : array<string|int, Channel>
- 获取所有通道
- consume() : void
- 消费消息
- disconnect() : void
- 关闭连接
- getClient() : AbstractClient
- 获取原始rabbitmq-client
- heartbeat() : void
- 发送心跳
- isConnected() : bool
- 是否已连接
- publish() : mixed
- 发布消息
- reconnect() : void
- 连接/重连
Methods
channel()
获取一个可用通道
public
channel() : Channel|null
Tags
Return values
Channel|nullchannels()
获取所有通道
public
channels() : array<string|int, Channel>
Return values
array<string|int, Channel>consume()
消费消息
public
consume(BuilderConfig $config) : void
Parameters
- $config : BuilderConfig
disconnect()
关闭连接
public
disconnect([array{replyCode: int, replyText: string} $options = [] ]) : void
Parameters
- $options : array{replyCode: int, replyText: string} = []
Tags
getClient()
获取原始rabbitmq-client
public
getClient() : AbstractClient
Return values
AbstractClientheartbeat()
发送心跳
public
heartbeat() : void
Tags
isConnected()
是否已连接
public
isConnected() : bool
Return values
boolpublish()
发布消息
public
publish(BuilderConfig $config[, bool $close = false ]) : mixed
Parameters
- $config : BuilderConfig
- $close : bool = false
Tags
reconnect()
连接/重连
public
reconnect([array{replyCode: int, replyText: string} $options = [] ][, bool $force = true ]) : void
Parameters
- $options : array{replyCode: int, replyText: string} = []
- $force : bool = true
-
强制重连