com.caucho.mqueue.stomp
Class StompProtocol

java.lang.Object
  com.caucho.mqueue.stomp.StompProtocol

All Implemented Interfaces:

Protocol

public class StompProtocol
extends java.lang.Object
implements Protocol

Custom serialization for the cache

Constructor Summary

StompProtocol()

Method Summary

ProtocolConnection	createConnection(SocketLink link) Creates a new protocol connection.
StompDestination	createDestination(java.lang.String name)
StompBroker	getBroker()
java.lang.String	getProtocolName() Returns the protocol name.
void	init()
void	setBroker(StompBroker 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(StompBroker broker)

init

@PostConstruct
public void init()

getBroker

public StompBroker 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 StompDestination createDestination(java.lang.String name)