public class Session extends SessionInvoker
Modifier and Type | Class and Description |
---|---|
static class |
Session.State |
Modifier and Type | Field and Description |
---|---|
static int |
UNLIMITED_CREDIT |
Modifier | Constructor and Description |
---|---|
protected |
Session(Connection connection,
Binary name,
long expiry) |
protected |
Session(Connection connection,
Binary name,
long expiry,
boolean noReplay) |
protected |
Session(Connection connection,
SessionDelegate delegate,
Binary name,
long expiry) |
protected |
Session(Connection connection,
SessionDelegate delegate,
Binary name,
long expiry,
boolean noReplay) |
Modifier and Type | Method and Description |
---|---|
protected void |
awaitClose() |
void |
awaitOpen() |
void |
close() |
void |
closed() |
protected boolean |
complete(int lower,
int upper) |
void |
exception(Throwable t) |
void |
flushProcessed(Option... options) |
int |
getChannel() |
int |
getCommandsIn() |
int |
getCommandsOut() |
Connection |
getConnection() |
SessionDetachCode |
getDetachCode() |
Binary |
getName() |
SessionListener |
getSessionListener() |
protected Session.State |
getState() |
Object |
getStateLock() |
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) |
boolean |
isFlowBlocked()
An auxiliary method for test purposes only
|
protected boolean |
isFull(int id) |
boolean |
isTransacted() |
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() |
protected void |
notifyFailoverRequired() |
void |
processed(int command) |
void |
processed(int lower,
int upper) |
void |
processed(Method command) |
void |
processed(Range range) |
void |
setAutoSync(boolean value) |
protected void |
setClose(boolean close) |
void |
setDetachCode(SessionDetachCode dtc) |
void |
setSessionListener(SessionListener listener) |
protected void |
setState(Session.State state) |
void |
setTransacted(boolean b) |
protected boolean |
shouldIssueFlush(int next) |
void |
sync() |
void |
sync(long timeout) |
String |
toString() |
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, txCommit, txRollback, txSelect
public static final int UNLIMITED_CREDIT
protected Session(Connection connection, Binary name, long expiry)
protected Session(Connection connection, Binary name, long expiry, boolean noReplay)
protected Session(Connection connection, SessionDelegate delegate, Binary name, long expiry)
protected Session(Connection connection, SessionDelegate delegate, Binary name, long expiry, boolean noReplay)
public Connection getConnection()
public Binary getName()
protected void setClose(boolean close)
public int getChannel()
public void setSessionListener(SessionListener listener)
public SessionListener getSessionListener()
public void setAutoSync(boolean value)
protected void setState(Session.State state)
protected Session.State getState()
public int getCommandsOut()
public int getCommandsIn()
public int nextCommandId()
public void processed(Method command)
public void processed(int command)
public void processed(Range range)
public void processed(int lower, int upper)
public void flushProcessed(Option... options)
protected boolean complete(int lower, int upper)
protected boolean isFull(int id)
protected boolean isBytesFull()
protected boolean isCommandsFull(int id)
public void invoke(Method m)
invoke
in class SessionInvoker
protected boolean shouldIssueFlush(int next)
public void sync()
public void sync(long timeout)
protected <T> Future<T> invoke(Method m, Class<T> klass)
invoke
in class SessionInvoker
public final void messageTransfer(String destination, MessageAcceptMode acceptMode, MessageAcquireMode acquireMode, Header header, byte[] body, Option... _options)
public final void messageTransfer(String destination, MessageAcceptMode acceptMode, MessageAcquireMode acquireMode, Header header, String body, Option... _options)
public void close()
protected void awaitClose()
public void exception(Throwable t)
public void closed()
public boolean isClosing()
public void setTransacted(boolean b)
public boolean isTransacted()
public void setDetachCode(SessionDetachCode dtc)
public SessionDetachCode getDetachCode()
public void awaitOpen()
public Object getStateLock()
protected void notifyFailoverRequired()
public boolean isFlowBlocked()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.