org.apache.qpid.transport
Class Session

java.lang.Object
  extended by org.apache.qpid.transport.SessionInvoker
      extended by org.apache.qpid.transport.Session

public class Session
extends SessionInvoker

Session


Nested Class Summary
(package private) static class Session.DefaultSessionListener
           
static class Session.State
           
 
Field Summary
static int UNLIMITED_CREDIT
           
 
Constructor Summary
protected Session(Connection connection, Binary name, long expiry)
           
protected Session(Connection connection, SessionDelegate delegate, Binary name, long expiry)
           
 
Method Summary
(package private)  void acquireCredit()
           
(package private)  void addCredit(int value)
           
(package private)  void attach()
           
protected  void awaitClose()
           
 void close()
           
(package private)  void closeCode(ConnectionClose close)
           
 void closed()
           
(package private)  void commandPoint(int id)
           
protected  boolean complete(int lower, int upper)
           
(package private)  void drainCredit()
           
(package private)  void dump()
           
 void exception(Throwable t)
           
(package private)  void flushExpected()
           
 void flushProcessed(Option... options)
           
 int getChannel()
           
 int getCommandsIn()
           
 int getCommandsOut()
           
 Connection getConnection()
           
(package private)  ExecutionException getException()
           
 Binary getName()
           
 SessionListener getSessionListener()
           
(package private)  void identify(Method cmd)
           
 void invoke(Method m)
           
protected
<T> Future<T>
invoke(Method m, Class<T> klass)
           
 void invoke(Method m, Runnable postIdSettingAction)
           
protected  boolean isBytesFull()
           
 boolean isClosing()
           
protected  boolean isCommandsFull(int id)
           
protected  boolean isFull(int id)
           
(package private)  void knownComplete(RangeSet kc)
           
 void messageTransfer(String destination, MessageAcceptMode acceptMode, MessageAcquireMode acquireMode, Header header, byte[] body, Option... _options)
           
 void messageTransfer(String destination, MessageAcceptMode acceptMode, MessageAcquireMode acquireMode, Header header, String body, Option... _options)
           
 int nextCommandId()
           
 void processed(int command)
           
 void processed(int lower, int upper)
           
 void processed(Method command)
           
 void processed(Range range)
           
(package private)  void received(Method m)
           
(package private)  void result(int command, Struct result)
           
(package private)  void resume()
           
 void setAutoSync(boolean value)
           
(package private)  void setChannel(int channel)
           
(package private)  void setClose(boolean close)
           
(package private)  void setException(ExecutionException exc)
           
(package private)  void setExpiry(long expiry)
           
(package private)  void setFlowControl(boolean value)
           
 void setSessionListener(SessionListener listener)
           
protected  void setState(Session.State state)
           
protected  boolean shouldIssueFlush(int next)
           
 void sync()
           
 void sync(long timeout)
           
(package private)  void syncPoint()
           
 String toString()
           
 
Methods inherited from class org.apache.qpid.transport.SessionInvoker
dtxCommit, dtxEnd, dtxForget, dtxGetTimeout, dtxPrepare, dtxRecover, dtxRollback, dtxSelect, dtxSetTimeout, dtxStart, exchangeBind, exchangeBound, exchangeDeclare, exchangeDelete, exchangeQuery, exchangeUnbind, executionException, executionResult, executionSync, messageAccept, messageAcquire, messageCancel, messageFlow, messageFlush, messageReject, messageRelease, messageResume, messageSetFlowMode, messageStop, messageSubscribe, messageTransfer, queueDeclare, queueDelete, queuePurge, queueQuery, sessionAttach, sessionAttached, sessionCommandPoint, sessionCompleted, sessionConfirmed, sessionDetach, sessionDetached, sessionExpected, sessionFlush, sessionGap, sessionKnownCompleted, sessionRequestTimeout, sessionTimeout, txCommit, txRollback, txSelect
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

UNLIMITED_CREDIT

public static final int UNLIMITED_CREDIT
See Also:
Constant Field Values
Constructor Detail

Session

protected Session(Connection connection,
                  Binary name,
                  long expiry)

Session

protected Session(Connection connection,
                  SessionDelegate delegate,
                  Binary name,
                  long expiry)
Method Detail

getConnection

public Connection getConnection()

getName

public Binary getName()

setExpiry

void setExpiry(long expiry)

setClose

void setClose(boolean close)

getChannel

public int getChannel()

setChannel

void setChannel(int channel)

setSessionListener

public void setSessionListener(SessionListener listener)

getSessionListener

public SessionListener getSessionListener()

setAutoSync

public void setAutoSync(boolean value)

setState

protected void setState(Session.State state)

setFlowControl

void setFlowControl(boolean value)

addCredit

void addCredit(int value)

drainCredit

void drainCredit()

acquireCredit

void acquireCredit()

attach

void attach()

resume

void resume()

dump

void dump()

commandPoint

final void commandPoint(int id)

getCommandsOut

public int getCommandsOut()

getCommandsIn

public int getCommandsIn()

nextCommandId

public int nextCommandId()

identify

final void identify(Method cmd)

processed

public void processed(Method command)

processed

public void processed(int command)

processed

public void processed(int lower,
                      int upper)

processed

public void processed(Range range)

flushExpected

void flushExpected()

flushProcessed

public void flushProcessed(Option... options)

knownComplete

void knownComplete(RangeSet kc)

syncPoint

void syncPoint()

complete

protected boolean complete(int lower,
                           int upper)

received

void received(Method m)

isFull

protected boolean isFull(int id)

isBytesFull

protected boolean isBytesFull()

isCommandsFull

protected boolean isCommandsFull(int id)

invoke

public void invoke(Method m)
Specified by:
invoke in class SessionInvoker

invoke

public void invoke(Method m,
                   Runnable postIdSettingAction)

shouldIssueFlush

protected boolean shouldIssueFlush(int next)

sync

public void sync()

sync

public void sync(long timeout)

result

void result(int command,
            Struct result)

setException

void setException(ExecutionException exc)

closeCode

void closeCode(ConnectionClose close)

getException

ExecutionException getException()

invoke

protected <T> Future<T> invoke(Method m,
                               Class<T> klass)
Specified by:
invoke in class SessionInvoker

messageTransfer

public final void messageTransfer(String destination,
                                  MessageAcceptMode acceptMode,
                                  MessageAcquireMode acquireMode,
                                  Header header,
                                  byte[] body,
                                  Option... _options)

messageTransfer

public final void messageTransfer(String destination,
                                  MessageAcceptMode acceptMode,
                                  MessageAcquireMode acquireMode,
                                  Header header,
                                  String body,
                                  Option... _options)

close

public void close()

awaitClose

protected void awaitClose()

exception

public void exception(Throwable t)

closed

public void closed()

isClosing

public boolean isClosing()

toString

public String toString()
Overrides:
toString in class Object


Licensed to the Apache Software Foundation