Package | Description |
---|---|
org.apache.activemq.transport.mqtt |
A Broker side implementation of the MQTT 3.1 protocol - see http://mqtt.org/
|
org.apache.activemq.transport.mqtt.strategy |
Modifier and Type | Method and Description |
---|---|
MQTTProtocolConverter |
MQTTInactivityMonitor.getProtocolConverter() |
Modifier and Type | Method and Description |
---|---|
void |
ResponseHandler.onResponse(MQTTProtocolConverter converter,
org.apache.activemq.command.Response response) |
void |
MQTTInactivityMonitor.setProtocolConverter(MQTTProtocolConverter protocolConverter) |
Constructor and Description |
---|
MQTTSubscription(MQTTProtocolConverter protocolConverter,
String topicName,
org.fusesource.mqtt.client.QoS qos,
org.apache.activemq.command.ConsumerInfo consumerInfo) |
Modifier and Type | Field and Description |
---|---|
protected MQTTProtocolConverter |
AbstractMQTTSubscriptionStrategy.protocol |
Modifier and Type | Method and Description |
---|---|
MQTTProtocolConverter |
MQTTSubscriptionStrategy.getProtocolConverter() |
MQTTProtocolConverter |
AbstractMQTTSubscriptionStrategy.getProtocolConverter() |
Modifier and Type | Method and Description |
---|---|
void |
MQTTSubscriptionStrategy.initialize(MQTTProtocolConverter protocol)
Initialize the strategy before first use.
|
void |
AbstractMQTTSubscriptionStrategy.initialize(MQTTProtocolConverter protocol) |
void |
MQTTSubscriptionStrategy.setProtocolConverter(MQTTProtocolConverter parent)
Sets the
MQTTProtocolConverter that is the parent of this strategy object. |
void |
AbstractMQTTSubscriptionStrategy.setProtocolConverter(MQTTProtocolConverter parent) |
Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.