org.apache.qpid.proton.engine.impl

Class SessionImpl

java.lang.Object

org.apache.qpid.proton.engine.impl.EndpointImpl

org.apache.qpid.proton.engine.impl.SessionImpl

All Implemented Interfaces:

Endpoint, ProtonJEndpoint, ProtonJSession, Session

public class SessionImpl
extends EndpointImpl
implements ProtonJSession

Method Summary

Methods

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)

Methods inherited from class org.apache.qpid.proton.engine.impl.EndpointImpl

getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, setCondition, setContext, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.qpid.proton.engine.Endpoint

getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, setCondition, setContext

Method Detail

open

public void open()

Description copied from interface: Endpoint

transition local state to ACTIVE

Specified by:

open in interface Endpoint

Overrides:

open in class EndpointImpl

close

public void close()

Description copied from interface: Endpoint

transition local state to CLOSED

Specified by:

close in interface Endpoint

Overrides:

close in class EndpointImpl

sender

public SenderImpl sender(String name)

Description copied from interface: Session

Returns a newly created sender endpoint

Specified by:

sender in interface ProtonJSession

Specified by:

sender in interface Session

receiver

public ReceiverImpl receiver(String name)

Description copied from interface: Session

Returns a newly created receiver endpoint

Specified by:

receiver in interface Session

next

public Session next(EnumSet<EndpointState> local,
           EnumSet<EndpointState> remote)

Specified by:

next in interface Session

getConnectionImpl

protected ConnectionImpl getConnectionImpl()

Specified by:

getConnectionImpl in class EndpointImpl

getConnection

public ConnectionImpl getConnection()

Specified by:

getConnection in interface Session

free

public void free()

Description copied from interface: Endpoint

free the endpoint and any associated resources

Specified by:

free in interface Endpoint

Overrides:

free in class EndpointImpl

getIncomingCapacity

public int getIncomingCapacity()

Specified by:

getIncomingCapacity in interface Session

setIncomingCapacity

public void setIncomingCapacity(int capacity)

Specified by:

setIncomingCapacity in interface Session

getIncomingBytes

public int getIncomingBytes()

Specified by:

getIncomingBytes in interface Session

getOutgoingBytes

public int getOutgoingBytes()

Specified by:

getOutgoingBytes in interface Session