com.caucho.mqueue.stomp
Class AbstractStompDestination

java.lang.Object
  extended by com.caucho.mqueue.stomp.AbstractStompDestination
All Implemented Interfaces:
StompDestination

public class AbstractStompDestination
extends java.lang.Object
implements StompDestination

Custom serialization for the cache


Constructor Summary
AbstractStompDestination()
           
 
Method Summary
 void close()
           
 void messageComplete(TempBuffer buffer, int length, StompReceiptListener listener)
           
 void messagePart(TempBuffer buffer, int length)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractStompDestination

public AbstractStompDestination()
Method Detail

messagePart

public void messagePart(TempBuffer buffer,
                        int length)
Specified by:
messagePart in interface StompDestination

messageComplete

public void messageComplete(TempBuffer buffer,
                            int length,
                            StompReceiptListener listener)
Specified by:
messageComplete in interface StompDestination

close

public void close()
Specified by:
close in interface StompDestination