org.apache.qpid.transport
Class Session
java.lang.Object
org.apache.qpid.transport.SessionInvoker
org.apache.qpid.transport.Session
public class Session
- extends SessionInvoker
Session
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
|
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 |
UNLIMITED_CREDIT
public static final int UNLIMITED_CREDIT
- See Also:
- Constant Field Values
Session
protected Session(Connection connection,
Binary name,
long expiry)
Session
protected Session(Connection connection,
SessionDelegate delegate,
Binary name,
long expiry)
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