A B C D E F G I L M O P Q R S T U V

A

AbstractMQTTSubscriptionStrategy - Class in org.apache.activemq.transport.mqtt.strategy

Abstract implementation of the MQTTSubscriptionStrategy interface providing the base functionality that is common to most implementations.

AbstractMQTTSubscriptionStrategy() - Constructor for class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

ackPacketId(String, short) - Method in class org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator

B

brokerService - Variable in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

C

commandType(byte) - Static method in class org.apache.activemq.transport.mqtt.MQTTProtocolSupport

Given an MQTT header byte, determine the command type that the header represents.

compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOTransportFactory

compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.mqtt.MQTTSslTransportFactory

compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFactory

consumerIdGenerator - Variable in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

containsMqttWildcard(String) - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

convertActiveMQToMQTT(String) - Static method in class org.apache.activemq.transport.mqtt.MQTTProtocolSupport

Converts an ActiveMQ destination name into a correctly formatted MQTT destination name.

convertMessage(ActiveMQMessage) - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

convertMQTTToActiveMQ(String) - Static method in class org.apache.activemq.transport.mqtt.MQTTProtocolSupport

Converts an MQTT formatted Topic name into a suitable ActiveMQ Destination name string.

createInactivityMonitor(Transport, WireFormat) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOTransportFactory

createInactivityMonitor(Transport, WireFormat) - Method in class org.apache.activemq.transport.mqtt.MQTTSslTransportFactory

createInactivityMonitor(Transport, WireFormat) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFactory

createMessageAck(MessageDispatch) - Method in class org.apache.activemq.transport.mqtt.MQTTSubscription

Create a MessageAck that will acknowledge the given MessageDispatch.

createPublish(ActiveMQMessage) - Method in class org.apache.activemq.transport.mqtt.MQTTSubscription

Creates a PUBLISH command that can be sent to a remote client from an incoming ActiveMQMessage instance.

createSslTransportServer(URI, SSLServerSocketFactory) - Method in class org.apache.activemq.transport.mqtt.MQTTSslTransportFactory

createTcpTransport(WireFormat, SocketFactory, URI, URI) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOSSLTransportFactory

createTcpTransport(WireFormat, SocketFactory, URI, URI) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOTransportFactory

createTcpTransportServer(URI, ServerSocketFactory) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOSSLTransportFactory

createTcpTransportServer(URI, ServerSocketFactory) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOTransportFactory

createTcpTransportServer(URI, ServerSocketFactory) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFactory

createWireFormat() - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormatFactory

D

deleteDurableSubs(List<SubscriptionInfo>) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

doBind(URI) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOSSLTransportFactory

doStart() - Method in class org.apache.activemq.transport.mqtt.MQTTNIOTransport

doStart() - Method in class org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator

doStop(ServiceStopper) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOTransport

doStop(ServiceStopper) - Method in class org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator

doSubscribe(ConsumerInfo, String, QoS) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

doUnSubscribe(MQTTSubscription) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

E

expectAck(PUBLISH) - Method in class org.apache.activemq.transport.mqtt.MQTTSubscription

Given a PUBLISH command determine if it will expect an ACK based on the QoS of the Publish command and the QoS of this subscription.

F

findSubscriptionStrategy() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

G

getActiveMQSubscriptionPrefetch() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

getActiveMQSubscriptionPrefetch() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

getClientId() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

getConnectAttemptTimeout() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

getConnectAttemptTimeout() - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormat

getConnectionId() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

getConsumerInfo() - Method in class org.apache.activemq.transport.mqtt.MQTTSubscription

Gets the ConsumerInfo that describes the subscription sent to ActiveMQ.

getDefaultKeepAlive() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

getDefaultKeepAlive() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

getDefaultWireFormatType() - Method in class org.apache.activemq.transport.mqtt.MQTTNIOTransportFactory

getDefaultWireFormatType() - Method in class org.apache.activemq.transport.mqtt.MQTTSslTransportFactory

getDefaultWireFormatType() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFactory

getDestination() - Method in class org.apache.activemq.transport.mqtt.MQTTSubscription

The real ActiveMQDestination that this subscription is assigned.

getInactivityMonitor() - Method in interface org.apache.activemq.transport.mqtt.MQTTTransport

getInactivityMonitor() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

getMaxFrameSize() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

getMaxFrameSize() - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormat

getMQTTPacketIdGenerator(BrokerService) - Static method in class org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator

getMQTTTransport() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

getNextConsumerId() - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

getNextSequenceId(String) - Method in class org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator

getPacketIdGenerator() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

getPeerCertificates() - Method in interface org.apache.activemq.transport.mqtt.MQTTTransport

getPeerCertificates() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

getProtocolConverter() - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

getProtocolConverter() - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

getProtocolConverter() - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

getPublishDollarTopics() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

getPublishDollarTopics() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

getQoS() - Method in class org.apache.activemq.transport.mqtt.MQTTSubscription

getReadGraceTime() - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

getReadKeepAliveTime() - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

getSessionId() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

getSubscription(ConsumerId) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

getSubscription(ConsumerId) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Lookup an MQTTSubscription instance based on known ConsumerId value.

getSubscriptionStrategy() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

getSubscriptionStrategy() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

getTopicName() - Method in class org.apache.activemq.transport.mqtt.MQTTSubscription

getVersion() - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormat

getWireFormat() - Method in interface org.apache.activemq.transport.mqtt.MQTTTransport

getWireFormat() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

I

initialize(MQTTProtocolConverter) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

initialize(MQTTProtocolConverter) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Initialize the strategy before first use.

initializeStreams() - Method in class org.apache.activemq.transport.mqtt.MQTTNIOSSLTransport

initializeStreams() - Method in class org.apache.activemq.transport.mqtt.MQTTNIOTransport

isCleanSession() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

isControlTopic(ActiveMQDestination) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

isControlTopic(ActiveMQDestination) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Allows the protocol handler to interrogate an destination name to determine if it is equivalent to the MQTT control topic (starts with $).

isControlTopic(ActiveMQDestination) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTVirtualTopicSubscriptionStrategy

isFatal() - Method in exception org.apache.activemq.transport.mqtt.MQTTProtocolException

isTrace() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

L

lookupSubscription(String) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

M

marshal(Object) - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormat

marshal(Object, DataOutput) - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormat

MQTTCodec - Class in org.apache.activemq.transport.mqtt

MQTTCodec(MQTTCodec.MQTTFrameSink) - Constructor for class org.apache.activemq.transport.mqtt.MQTTCodec

MQTTCodec(MQTTCodec.MQTTFrameSink, MQTTWireFormat) - Constructor for class org.apache.activemq.transport.mqtt.MQTTCodec

MQTTCodec(TcpTransport) - Constructor for class org.apache.activemq.transport.mqtt.MQTTCodec

MQTTCodec(TcpTransport, MQTTWireFormat) - Constructor for class org.apache.activemq.transport.mqtt.MQTTCodec

MQTTCodec.MQTTFrameSink - Interface in org.apache.activemq.transport.mqtt

Sink for newly decoded MQTT Frames.

MQTTDefaultSubscriptionStrategy - Class in org.apache.activemq.transport.mqtt.strategy

Default implementation that uses unmapped topic subscriptions.

MQTTDefaultSubscriptionStrategy() - Constructor for class org.apache.activemq.transport.mqtt.strategy.MQTTDefaultSubscriptionStrategy

MQTTInactivityMonitor - Class in org.apache.activemq.transport.mqtt

MQTTInactivityMonitor(Transport, WireFormat) - Constructor for class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

MQTTNIOSSLTransport - Class in org.apache.activemq.transport.mqtt

MQTTNIOSSLTransport(WireFormat, SocketFactory, URI, URI) - Constructor for class org.apache.activemq.transport.mqtt.MQTTNIOSSLTransport

MQTTNIOSSLTransport(WireFormat, Socket) - Constructor for class org.apache.activemq.transport.mqtt.MQTTNIOSSLTransport

MQTTNIOSSLTransportFactory - Class in org.apache.activemq.transport.mqtt

MQTTNIOSSLTransportFactory() - Constructor for class org.apache.activemq.transport.mqtt.MQTTNIOSSLTransportFactory

MQTTNIOTransport - Class in org.apache.activemq.transport.mqtt

An implementation of the Transport interface for using MQTT over NIO

MQTTNIOTransport(WireFormat, SocketFactory, URI, URI) - Constructor for class org.apache.activemq.transport.mqtt.MQTTNIOTransport

MQTTNIOTransport(WireFormat, Socket) - Constructor for class org.apache.activemq.transport.mqtt.MQTTNIOTransport

MQTTNIOTransportFactory - Class in org.apache.activemq.transport.mqtt

A MQTT over NIO transport factory

MQTTNIOTransportFactory() - Constructor for class org.apache.activemq.transport.mqtt.MQTTNIOTransportFactory

MQTTPacketIdGenerator - Class in org.apache.activemq.transport.mqtt

Manages PUBLISH packet ids for clients.

MQTTProtocolConverter - Class in org.apache.activemq.transport.mqtt

MQTTProtocolConverter(MQTTTransport, BrokerService) - Constructor for class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

MQTTProtocolException - Exception in org.apache.activemq.transport.mqtt

MQTTProtocolException() - Constructor for exception org.apache.activemq.transport.mqtt.MQTTProtocolException

MQTTProtocolException(String) - Constructor for exception org.apache.activemq.transport.mqtt.MQTTProtocolException

MQTTProtocolException(String, boolean) - Constructor for exception org.apache.activemq.transport.mqtt.MQTTProtocolException

MQTTProtocolException(String, boolean, Throwable) - Constructor for exception org.apache.activemq.transport.mqtt.MQTTProtocolException

MQTTProtocolSupport - Class in org.apache.activemq.transport.mqtt

A set of static methods useful for handling MQTT based client connections.

MQTTProtocolSupport() - Constructor for class org.apache.activemq.transport.mqtt.MQTTProtocolSupport

MQTTSslTransportFactory - Class in org.apache.activemq.transport.mqtt

A MQTT over SSL transport factory

MQTTSslTransportFactory() - Constructor for class org.apache.activemq.transport.mqtt.MQTTSslTransportFactory

MQTTSubscription - Class in org.apache.activemq.transport.mqtt

Keeps track of the MQTT client subscription so that acking is correctly done.

MQTTSubscription(MQTTProtocolConverter, String, QoS, ConsumerInfo) - Constructor for class org.apache.activemq.transport.mqtt.MQTTSubscription

mqttSubscriptionByTopic - Variable in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

MQTTSubscriptionStrategy - Interface in org.apache.activemq.transport.mqtt.strategy

Subscription management strategy used to control how MQTT clients subscribe to destination and how messages are addressed in order to arrive on the appropriate destinations.

MQTTTransport - Interface in org.apache.activemq.transport.mqtt

Basic interface that mediates between protocol converter and transport

MQTTTransportFactory - Class in org.apache.activemq.transport.mqtt

A MQTT transport factory

MQTTTransportFactory() - Constructor for class org.apache.activemq.transport.mqtt.MQTTTransportFactory

MQTTTransportFilter - Class in org.apache.activemq.transport.mqtt

The MQTTTransportFilter normally sits on top of a TcpTransport that has been configured with the StompWireFormat and is used to convert MQTT commands to ActiveMQ commands.

MQTTTransportFilter(Transport, WireFormat, BrokerService) - Constructor for class org.apache.activemq.transport.mqtt.MQTTTransportFilter

MQTTVirtualTopicSubscriptionStrategy - Class in org.apache.activemq.transport.mqtt.strategy

Subscription strategy that converts all MQTT subscribes that would be durable to Virtual Topic Queue subscriptions.

MQTTVirtualTopicSubscriptionStrategy() - Constructor for class org.apache.activemq.transport.mqtt.strategy.MQTTVirtualTopicSubscriptionStrategy

MQTTWireFormat - Class in org.apache.activemq.transport.mqtt

Implements marshalling and unmarsalling the MQTT protocol.

MQTTWireFormat() - Constructor for class org.apache.activemq.transport.mqtt.MQTTWireFormat

MQTTWireFormatFactory - Class in org.apache.activemq.transport.mqtt

Creates WireFormat objects that marshalls the Stomp protocol.

MQTTWireFormatFactory() - Constructor for class org.apache.activemq.transport.mqtt.MQTTWireFormatFactory

MULTI_LEVEL_WILDCARD - Static variable in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

O

onActiveMQCommand(Command) - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

Dispatch an ActiveMQ command

onCommand(Object) - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

onCommand(Object) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

onConnect(CONNECT) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTDefaultSubscriptionStrategy

onConnect(CONNECT) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Allows the strategy to perform any needed actions on client connect prior to the CONNACK frame being sent back such as recovering old subscriptions and performing any clean session actions.

onConnect(CONNECT) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTVirtualTopicSubscriptionStrategy

oneway(Object) - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

oneway(Object) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

onException(IOException) - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

onException(IOException) - Method in interface org.apache.activemq.transport.mqtt.MQTTTransport

onException(IOException) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

onFrame(MQTTFrame) - Method in interface org.apache.activemq.transport.mqtt.MQTTCodec.MQTTFrameSink

onMQTTCommand(MQTTFrame) - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

Convert a MQTT command

onResponse(MQTTProtocolConverter, Response) - Method in interface org.apache.activemq.transport.mqtt.ResponseHandler

onReSubscribe(MQTTSubscription) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

onReSubscribe(MQTTSubscription) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTDefaultSubscriptionStrategy

onReSubscribe(MQTTSubscription) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Called when a client sends a duplicate subscribe request which should force any retained messages on that topic to be replayed again as though the client had just subscribed for the first time.

onReSubscribe(MQTTSubscription) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTVirtualTopicSubscriptionStrategy

onSend(String) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

onSend(ActiveMQDestination) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

onSend(String) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Intercepts PUBLISH operations from the client and allows the strategy to map the target destination so that the send operation will land in the destinations that this strategy has mapped the incoming subscribe requests to.

onSend(ActiveMQDestination) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Intercepts send operations from the broker and allows the strategy to map the target topic name so that the client sees a valid Topic name.

onSend(String) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTVirtualTopicSubscriptionStrategy

onSend(ActiveMQDestination) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTVirtualTopicSubscriptionStrategy

onSubscribe(Topic) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

onSubscribe(String, QoS) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTDefaultSubscriptionStrategy

onSubscribe(Topic) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Called for each Topic that a client requests to subscribe to.

onSubscribe(String, QoS) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Called when a new Subscription is being requested.

onSubscribe(String, QoS) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTVirtualTopicSubscriptionStrategy

onTransportError() - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

onUnSubscribe(UNSUBSCRIBE) - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

onUnSubscribe(String) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTDefaultSubscriptionStrategy

onUnSubscribe(String) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Called when a client requests an un-subscribe a previous subscription.

onUnSubscribe(String) - Method in class org.apache.activemq.transport.mqtt.strategy.MQTTVirtualTopicSubscriptionStrategy

org.apache.activemq.transport.mqtt - package 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 - package org.apache.activemq.transport.mqtt.strategy

P

parse(DataByteArrayInputStream, int) - Method in class org.apache.activemq.transport.mqtt.MQTTCodec

processCommand(ByteBuffer) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOSSLTransport

protocol - Variable in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

Q

QOS_PROPERTY_NAME - Static variable in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

R

ResponseHandler - Interface in org.apache.activemq.transport.mqtt

Interface used by the MQTTProtocolConverter for callbacks.

restoredDurableSubs - Variable in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

restoreDurableSubs(List<SubscriptionInfo>) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

S

sendToActiveMQ(Command, ResponseHandler) - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

sendToActiveMQ(Command) - Method in interface org.apache.activemq.transport.mqtt.MQTTTransport

sendToActiveMQ(Command) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

sendToMQTT(MQTTFrame) - Method in interface org.apache.activemq.transport.mqtt.MQTTTransport

sendToMQTT(MQTTFrame) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

serverConfigure(Transport, WireFormat, HashMap) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOTransportFactory

serverConfigure(Transport, WireFormat, HashMap) - Method in class org.apache.activemq.transport.mqtt.MQTTSslTransportFactory

serverConfigure(Transport, WireFormat, HashMap) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFactory

setActiveMQSubscriptionPrefetch(int) - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

set the default prefetch size when mapping the MQTT subscription to an ActiveMQ one The default = 1

setActiveMQSubscriptionPrefetch(int) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

set the default prefetch size when mapping the MQTT subscription to an ActiveMQ one The default = 1

setBrokerService(BrokerService) - Method in class org.apache.activemq.transport.mqtt.MQTTNIOTransportFactory

setBrokerService(BrokerService) - Method in class org.apache.activemq.transport.mqtt.MQTTSslTransportFactory

setBrokerService(BrokerService) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFactory

setBrokerService(BrokerService) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

setConnectAttemptTimeout(long) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

Sets the timeout value used to fail a connection if no CONNECT frame is read in the given interval.

setConnectAttemptTimeout(long) - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormat

Sets the timeout value used to fail a connection if no CONNECT frame is read in the given interval.

setDefaultKeepAlive(long) - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

Set the default keep alive time (in milliseconds) that would be used if configured on server side and the client sends a keep-alive value of 0 (zero) on a CONNECT frame

setDefaultKeepAlive(long) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

setInactivityMonitor(MQTTInactivityMonitor) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

setMaxFrameSize(int) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

Sets the maximum frame size for an incoming MQTT frame.

setMaxFrameSize(int) - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormat

Sets the maximum frame size for an incoming MQTT frame.

setPacketId(String, MQTTSubscription, ActiveMQMessage, PUBLISH) - Method in class org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator

setPeerCertificates(X509Certificate[]) - Method in interface org.apache.activemq.transport.mqtt.MQTTTransport

setPeerCertificates(X509Certificate[]) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

setProtocolConverter(MQTTProtocolConverter) - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

setProtocolConverter(MQTTProtocolConverter) - Method in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

setProtocolConverter(MQTTProtocolConverter) - Method in interface org.apache.activemq.transport.mqtt.strategy.MQTTSubscriptionStrategy

Sets the MQTTProtocolConverter that is the parent of this strategy object.

setPublishDollarTopics(boolean) - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

setPublishDollarTopics(boolean) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

setReadGraceTime(long) - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

setReadKeepAliveTime(long) - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

setSubscriptionStrategy(String) - Method in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

setSubscriptionStrategy(String) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

setTrace(boolean) - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

setVersion(int) - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormat

SINGLE_LEVEL_WILDCARD - Static variable in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

start() - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

start() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

startClientSession(String) - Method in class org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator

startConnectChecker(long) - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

stop() - Method in class org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

stop() - Method in interface org.apache.activemq.transport.mqtt.MQTTTransport

stop() - Method in class org.apache.activemq.transport.mqtt.MQTTTransportFilter

stopClientSession(String) - Method in class org.apache.activemq.transport.mqtt.MQTTPacketIdGenerator

subscriptionsByConsumerId - Variable in class org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy

T

toString() - Method in class org.apache.activemq.transport.mqtt.MQTTSubscription

U

unmarshal(ByteSequence) - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormat

unmarshal(DataInput) - Method in class org.apache.activemq.transport.mqtt.MQTTWireFormat

V

V3_1 - Static variable in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

V3_1_1 - Static variable in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

version - Variable in class org.apache.activemq.transport.mqtt.MQTTProtocolConverter

A B C D E F G I L M O P Q R S T U V