com.caucho.jms.cluster
Interface ServerDestination<E extends java.io.Serializable>

All Known Implementing Classes:
ClusterTopic, ClusterTopicImpl

public interface ServerDestination<E extends java.io.Serializable>

Implements a cluster receive queue.


Method Summary
 void acknowledge(java.lang.String msgId)
           
 boolean hasMessage(java.lang.String subscription)
           
 E receiveLocal(java.lang.String subscription, boolean isAutoAck)
           
 void rollback(java.lang.String msgId)
           
 void sendLocal(java.lang.String msgId, E payload, int priority, long expireTime, java.lang.String publisherId)
           
 void sendLocalAsBackup(java.lang.String msgId, E payload, long expireTime)
           
 

Method Detail

sendLocal

void sendLocal(java.lang.String msgId,
               E payload,
               int priority,
               long expireTime,
               java.lang.String publisherId)

sendLocalAsBackup

void sendLocalAsBackup(java.lang.String msgId,
                       E payload,
                       long expireTime)

receiveLocal

E receiveLocal(java.lang.String subscription,
               boolean isAutoAck)

hasMessage

boolean hasMessage(java.lang.String subscription)

acknowledge

void acknowledge(java.lang.String msgId)

rollback

void rollback(java.lang.String msgId)