com.caucho.mqueue.stomp
Class StompEnvironmentBroker

java.lang.Object
  extended by com.caucho.mqueue.stomp.StompEnvironmentBroker
All Implemented Interfaces:
StompBroker

public class StompEnvironmentBroker
extends java.lang.Object
implements StompBroker

Custom serialization for the cache


Method Summary
 void addBroker(StompBroker broker)
           
static StompEnvironmentBroker create()
           
 StompDestination createDestination(java.lang.String name)
           
 StompSubscription createSubscription(java.lang.String name, StompMessageListener listener)
           
static StompEnvironmentBroker getCurrent()
           
 void removeBroker(StompBroker broker)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Method Detail

getCurrent

public static StompEnvironmentBroker getCurrent()

create

public static StompEnvironmentBroker create()

addBroker

public void addBroker(StompBroker broker)

removeBroker

public void removeBroker(StompBroker broker)

createDestination

public StompDestination createDestination(java.lang.String name)
Specified by:
createDestination in interface StompBroker

createSubscription

public StompSubscription createSubscription(java.lang.String name,
                                            StompMessageListener listener)
Specified by:
createSubscription in interface StompBroker

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object