com.caucho.message.nautilus

Class NautilusBrokerSubscriber

java.lang.Object

com.caucho.message.nautilus.NautilusBrokerSubscriber

All Implemented Interfaces:

BrokerReceiver

public class NautilusBrokerSubscriber
extends java.lang.Object
implements BrokerReceiver

Subscription to a destination

Method Summary

Modifier and Type	Method and Description
void	accepted(long xid, long mid)
void	close()
void	flow(long deliveryCount, int linkCredit)
void	modified(long xid, long mid, boolean isFailed, boolean isUndeliverableHere)
void	onTransfer(NautilusQueue.QueueEntry entry)
void	rejected(long xid, long mid, java.lang.String message)
void	released(long xid, long mid)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

accepted

public void accepted(long xid,
                     long mid)

Specified by:

accepted in interface BrokerReceiver

rejected

public void rejected(long xid,
                     long mid,
                     java.lang.String message)

Specified by:

rejected in interface BrokerReceiver

modified

public void modified(long xid,
                     long mid,
                     boolean isFailed,
                     boolean isUndeliverableHere)

Specified by:

modified in interface BrokerReceiver

released

public void released(long xid,
                     long mid)

Specified by:

released in interface BrokerReceiver

flow

public void flow(long deliveryCount,
                 int linkCredit)

Specified by:

flow in interface BrokerReceiver

close

public void close()

Specified by:

close in interface BrokerReceiver

onTransfer

public void onTransfer(NautilusQueue.QueueEntry entry)

Parameters:

entry -

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object