public class SessionImpl extends EndpointImpl implements ProtonJSession
Modifier and Type | Method and Description |
---|---|
void |
close()
transition local state to CLOSED
|
void |
free()
free the endpoint and any associated resources
|
ConnectionImpl |
getConnection() |
protected ConnectionImpl |
getConnectionImpl() |
int |
getIncomingBytes() |
int |
getIncomingCapacity() |
int |
getOutgoingBytes() |
Session |
next(EnumSet<EndpointState> local,
EnumSet<EndpointState> remote) |
void |
open()
transition local state to ACTIVE
|
ReceiverImpl |
receiver(String name)
Returns a newly created receiver endpoint
|
SenderImpl |
sender(String name)
Returns a newly created sender endpoint
|
void |
setIncomingCapacity(int capacity) |
getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, setCondition, setContext, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, setCondition, setContext
public void open()
Endpoint
open
in interface Endpoint
open
in class EndpointImpl
public void close()
Endpoint
close
in interface Endpoint
close
in class EndpointImpl
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
Copyright © 2013 The Apache Software Foundation. All rights reserved.