org.apache.activemq.apollo.mqtt

Class MqttProtocolCodecFactory

java.lang.Object

org.apache.activemq.apollo.mqtt.MqttProtocolCodecFactory

All Implemented Interfaces:

org.apache.activemq.apollo.broker.protocol.ProtocolCodecFactory.Provider

Direct Known Subclasses:

MqttProtocol

public class MqttProtocolCodecFactory
extends Object
implements org.apache.activemq.apollo.broker.protocol.ProtocolCodecFactory.Provider

Creates MqttCodec objects that encode/decode the Mqtt protocol.

Author:

Hiram Chirino

Constructor Summary

Constructors

Constructor and Description
MqttProtocolCodecFactory()

Method Summary

Methods

Modifier and Type	Method and Description
org.fusesource.hawtdispatch.transport.ProtocolCodec	createProtocolCodec(Connector connector)
String	id()
boolean	isIdentifiable()
boolean	matchesIdentification(org.fusesource.hawtbuf.Buffer header)
int	maxIdentificaionLength()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MqttProtocolCodecFactory

public MqttProtocolCodecFactory()

Method Detail

id

public String id()

Specified by:

id in interface org.apache.activemq.apollo.broker.protocol.ProtocolCodecFactory.Provider

createProtocolCodec

public org.fusesource.hawtdispatch.transport.ProtocolCodec createProtocolCodec(Connector connector)

Specified by:

createProtocolCodec in interface org.apache.activemq.apollo.broker.protocol.ProtocolCodecFactory.Provider

isIdentifiable

public boolean isIdentifiable()

Specified by:

isIdentifiable in interface org.apache.activemq.apollo.broker.protocol.ProtocolCodecFactory.Provider

maxIdentificaionLength

public int maxIdentificaionLength()

Specified by:

maxIdentificaionLength in interface org.apache.activemq.apollo.broker.protocol.ProtocolCodecFactory.Provider

matchesIdentification

public boolean matchesIdentification(org.fusesource.hawtbuf.Buffer header)

Specified by:

matchesIdentification in interface org.apache.activemq.apollo.broker.protocol.ProtocolCodecFactory.Provider