public class SessionImpl extends EndpointImpl implements ProtonJSession
Modifier and Type | Method and Description |
---|---|
void |
free()
free the endpoint and any associated resources
|
ConnectionImpl |
getConnection() |
protected ConnectionImpl |
getConnectionImpl() |
int |
getIncomingBytes() |
int |
getIncomingCapacity() |
int |
getOutgoingBytes() |
protected void |
localStateChanged() |
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, getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, open, setCondition, setContext, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close, 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 void free()
Endpoint
free
in interface Endpoint
free
in class EndpointImpl
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
protected void localStateChanged()
localStateChanged
in class EndpointImpl
Copyright © 2014 The Apache Software Foundation. All rights reserved.