public interface  org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy extends java.lang.Object
{
public abstract void initialize(org.apache.activemq.transport.mqtt.MQTTProtocolConverter) throws org.apache.activemq.transport.mqtt.MQTTProtocolException;
public abstract void onConnect(org.fusesource.mqtt.codec.CONNECT) throws org.apache.activemq.transport.mqtt.MQTTProtocolException;
public abstract byte onSubscribe(org.fusesource.mqtt.client.Topic) throws org.apache.activemq.transport.mqtt.MQTTProtocolException;
public abstract byte onSubscribe(java.lang.String, org.fusesource.mqtt.client.QoS) throws org.apache.activemq.transport.mqtt.MQTTProtocolException;
public abstract void onReSubscribe(org.apache.activemq.transport.mqtt.MQTTSubscription) throws org.apache.activemq.transport.mqtt.MQTTProtocolException;
public abstract void onUnSubscribe(java.lang.String) throws org.apache.activemq.transport.mqtt.MQTTProtocolException;
public abstract org.apache.activemq.command.ActiveMQDestination onSend(java.lang.String);
public abstract java.lang.String onSend(org.apache.activemq.command.ActiveMQDestination);
public abstract boolean isControlTopic(org.apache.activemq.command.ActiveMQDestination);
public abstract void setProtocolConverter(org.apache.activemq.transport.mqtt.MQTTProtocolConverter);
public abstract org.apache.activemq.transport.mqtt.MQTTProtocolConverter getProtocolConverter();
public abstract org.apache.activemq.transport.mqtt.MQTTSubscription getSubscription(org.apache.activemq.command.ConsumerId);
}