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)