com.caucho.mqueue.stomp
Class StompProtocol

java.lang.Object
  extended by 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)