AbstractMqttMessageDispatcher (anteros-mqtt-core 1.0.7 API)

java.lang.Object
- br.com.anteros.mqtt.core.server.dispatcher.AbstractMqttMessageDispatcher

All Implemented Interfaces:

IMqttMessageDispatcher

Direct Known Subclasses:

DefaultMqttBrokerDispatcher
```
public abstract class AbstractMqttMessageDispatcher
extends Object
implements IMqttMessageDispatcher
```
内部消息转发抽象

Author:

L.cm

Field Summary

Fields
Modifier and Type Field Description

protected MqttServer mqttServer

protected IMqttSessionManager sessionManager

Constructor Summary

Constructors
Constructor Description

AbstractMqttMessageDispatcher()

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`config(MqttServer mqttServer)`
`boolean`	`send(br.com.anteros.mqtt.core.server.model.Message message)`	发送消息
`abstract void`	`sendAll(br.com.anteros.mqtt.core.server.model.Message message)`	转发所有消息

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface br.com.anteros.mqtt.core.server.dispatcher.IMqttMessageDispatcher
send

Field Detail

mqttServer
```
protected MqttServer mqttServer
```

sessionManager

protected IMqttSessionManager sessionManager

Constructor Detail
- AbstractMqttMessageDispatcher
```
public AbstractMqttMessageDispatcher()
```

Method Detail
- config
```
public void config(MqttServer mqttServer)
```
- sendAll
```
public abstract void sendAll(br.com.anteros.mqtt.core.server.model.Message message)
```
  转发所有消息
  
  Parameters:
  
  message - Message
- send
```
public boolean send(br.com.anteros.mqtt.core.server.model.Message message)
```
  Description copied from interface: IMqttMessageDispatcher
  
  发送消息
  
  Specified by:
  
  send in interface IMqttMessageDispatcher
  
  Parameters:
  
  message - 消息
  
  Returns:
  
  是否成功