public class SessionImpl extends EndpointImpl implements ProtonJSession
Modifier and Type | Method and Description |
---|---|
ConnectionImpl |
getConnection() |
protected ConnectionImpl |
getConnectionImpl() |
int |
getIncomingBytes() |
int |
getIncomingCapacity() |
int |
getOutgoingBytes() |
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) |
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
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
Copyright © 2015 The Apache Software Foundation. All rights reserved.