com.caucho.message.stomp

Class StompProtocol

java.lang.Object

com.caucho.message.stomp.StompProtocol

All Implemented Interfaces:

Protocol

public class StompProtocol
extends java.lang.Object
implements Protocol

Custom serialization for the cache

Constructor Summary

Constructors

Constructor and Description
StompProtocol()

Method Summary

Modifier and Type	Method and Description
ProtocolConnection	createConnection(SocketLink link) Creates a new protocol connection.
BrokerSender	createDestination(java.lang.String name)
MessageBroker	getBroker()
java.lang.String	getProtocolName() Returns the protocol name.
void	init()
void	setBroker(MessageBroker broker)

Methods inherited from class java.lang.Object

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

Constructor Detail

StompProtocol

public StompProtocol()

Method Detail

setBroker

public void setBroker(MessageBroker broker)

init

@PostConstruct
public void init()

getBroker

public MessageBroker getBroker()

createConnection

public ProtocolConnection createConnection(SocketLink link)

Description copied from interface: Protocol

Creates a new protocol connection.

Specified by:

createConnection in interface Protocol

getProtocolName

public java.lang.String getProtocolName()

Description copied from interface: Protocol

Returns the protocol name.

Specified by:

getProtocolName in interface Protocol

createDestination

public BrokerSender createDestination(java.lang.String name)