com.caucho.message.broker
Class AbstractBrokerSender

java.lang.Object
  extended by com.caucho.message.broker.AbstractBrokerSender
All Implemented Interfaces:
BrokerSender

public class AbstractBrokerSender
extends java.lang.Object
implements BrokerSender

Custom serialization for the cache


Constructor Summary
AbstractBrokerSender()
           
 
Method Summary
 void close()
           
 int getPrefetch()
           
 void message(long xid, long mid, boolean isDurable, int priority, long expireTime, byte[] buffer, int offset, int length, TempBuffer tBuf, SenderSettleHandler listener)
           
 long nextMessageId()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractBrokerSender

public AbstractBrokerSender()
Method Detail

getPrefetch

public int getPrefetch()
Specified by:
getPrefetch in interface BrokerSender

nextMessageId

public long nextMessageId()
Specified by:
nextMessageId in interface BrokerSender

message

public void message(long xid,
                    long mid,
                    boolean isDurable,
                    int priority,
                    long expireTime,
                    byte[] buffer,
                    int offset,
                    int length,
                    TempBuffer tBuf,
                    SenderSettleHandler listener)
Specified by:
message in interface BrokerSender

close

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