com.caucho.message.nautilus
Class NautilusBrokerSubscriber

java.lang.Object
  extended by com.caucho.message.nautilus.NautilusBrokerSubscriber
All Implemented Interfaces:
BrokerReceiver

public class NautilusBrokerSubscriber
extends java.lang.Object
implements BrokerReceiver

Subscription to a destination


Method Summary
 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