public class SessionImpl extends EndpointImpl implements ProtonJSession
Modifier and Type | Method and Description |
---|---|
ConnectionImpl |
getConnection() |
protected ConnectionImpl |
getConnectionImpl() |
int |
getIncomingBytes() |
int |
getIncomingCapacity() |
int |
getOutgoingBytes() |
long |
getOutgoingWindow() |
Session |
next(EnumSet<EndpointState> local,
EnumSet<EndpointState> remote) |
ReceiverImpl |
receiver(String name)
Returns a newly created receiver endpoint
|
SenderImpl |
sender(String name)
Returns a newly created sender endpoint
|
void |
setIncomingCapacity(int capacity) |
void |
setOutgoingWindow(long outgoingWindow)
Sets the outgoing window size.
|
attachments, close, free, getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, open, setCondition, setContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, free, getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, open, setCondition, setContext
attachments
public SenderImpl sender(String name)
Session
sender
in interface ProtonJSession
sender
in interface Session
public ReceiverImpl receiver(String name)
Session
public Session next(EnumSet<EndpointState> local, EnumSet<EndpointState> remote)
protected ConnectionImpl getConnectionImpl()
getConnectionImpl
in class EndpointImpl
public ConnectionImpl getConnection()
getConnection
in interface Session
public int getIncomingCapacity()
getIncomingCapacity
in interface Session
public void setIncomingCapacity(int capacity)
setIncomingCapacity
in interface Session
public int getIncomingBytes()
getIncomingBytes
in interface Session
public int getOutgoingBytes()
getOutgoingBytes
in interface Session
public void setOutgoingWindow(long outgoingWindow)
Session
setOutgoingWindow
in interface Session
outgoingWindow
- the outgoing window sizepublic long getOutgoingWindow()
getOutgoingWindow
in interface Session
Copyright © 2016 The Apache Software Foundation. All rights reserved.