Implements the mechanics of managing a single AMQP connection associated with the provided engine instance. More...

Inheritance diagram for Apache.Qpid.Proton.Engine.Implementation.ProtonConnection:

Public Member Functions
	ProtonConnection (ProtonEngine engine)

override IConnection	Open ()

override IConnection	Close ()

IConnection	Negotiate ()

IConnection	Negotiate (in Action< AmqpHeader > remoteAMQPHeaderHandler)

long	Tick (long current)
	Performs a tick operation on the connection which checks that Connection Idle timeout processing is run. It is an error to call this method if the scheduled tick method has been invoked.

IConnection	TickAuto (in TaskFactory taskFactory)
	Convenience method which is the same as calling Engine auto tick idle checking API.

ISession	Session ()
	Creates a new Session linked to this Connection.

IConnection	SessionOpenedHandler (Action< ISession > handler)
	Sets an Action for when an AMQP Begin frame is received from the remote peer. Used to process remotely initiated Sessions. Locally initiated sessions have their own Action delegate invoked instead. This method is Typically used by servers to listen for remote Session creation.

IConnection	ReceiverOpenedHandler (Action< IReceiver > handler)
	Sets an Action for when an AMQP Attach frame is received from the remote peer that represents the receiving end of a link. Used to process remotely initiated receivers. Locally initiated receivers have their own Action delegate invoked instead. This method is Typically used by servers to listen for remote receiver creation. If an event handler for remote receiver open is registered on the Session that the link is owned by then that handler will be invoked instead of this one.

IConnection	SenderOpenedHandler (Action< ISender > handler)
	Sets an Action for when an AMQP Attach frame is received from the remote peer that represents the sending end of a link. Used to process remotely initiated sender. Locally initiated senders have their own Action delegate invoked instead. This method is Typically used by servers to listen for remote sender creation. If an event handler for remote sender open is registered on the session that the link is owned by then that handler will be invoked instead of this one.

IConnection	TransactionManagerOpenedHandler (Action< ITransactionManager > handler)
	Sets an Action for when an AMQP Attach frame is received from the remote peer that represents the manager side of a coordinator link. Used to process remotely initiated manager. Locally initiated managers have their own Action delegate invoked instead. This method is Typically used by servers to listen for remote transaction manager creation. If an event handler for remote transaction manager open is registered on the Session that the link is owned by then that handler will be invoked instead of this one.

void	HandleAMQPHeader (AmqpHeader header, ProtonEngine context)

void	HandleSASLHeader (AmqpHeader header, ProtonEngine context)

void	HandleOpen (Open open, IProtonBuffer payload, ushort channel, ProtonEngine context)

void	HandleClose (Close close, IProtonBuffer payload, ushort channel, ProtonEngine context)

void	HandleBegin (Begin begin, IProtonBuffer payload, ushort channel, ProtonEngine context)

void	HandleEnd (End end, IProtonBuffer payload, ushort channel, ProtonEngine context)

void	HandleAttach (Attach attach, IProtonBuffer payload, ushort channel, ProtonEngine context)

void	HandleDetach (Detach detach, IProtonBuffer payload, ushort channel, ProtonEngine context)

void	HandleFlow (Flow flow, IProtonBuffer payload, ushort channel, ProtonEngine context)

void	HandleTransfer (Transfer transfer, IProtonBuffer payload, ushort channel, ProtonEngine context)

void	HandleDisposition (Disposition disposition, IProtonBuffer payload, ushort channel, ProtonEngine context)

Public Member Functions inherited from Apache.Qpid.Proton.Engine.Implementation.ProtonEndpoint< IConnection >
	ProtonEndpoint (ProtonEngine engine)
	Creates a new instance of this endpoint implementation which is owned by the provided engine instance.

T	OpenHandler (Action< T > openHandler)
	Sets a Action for when an AMQP Open frame is received from the remote peer. Used to process remotely initiated Connections. Locally initiated sessions have their own Action invoked instead. This method is typically used by servers to listen for the remote peer to open its endpoint, while a client would listen for the server to open its end of the endpoint once a local open has been performed. Typically used by clients as servers will typically listen to some parent resource event handler to determine if the remote is initiating a resource open.

T	CloseHandler (Action< T > closeHandler)
	Sets a EventHandler for when an AMQP closing frame is received from the remote peer.

T	LocalOpenHandler (Action< T > localOpenHandler)
	Sets a Action for when an this endpoint is opened locally via a call to Open. Typically used by clients for logging or other state update event processing. Clients should not perform any blocking calls within this context. It is an error for the handler to throw an exception and the outcome of doing so is undefined. Typically used by clients as servers will typically listen to some parent resource event handler to determine if the remote is initiating a resource open.

T	LocalCloseHandler (Action< T > localCloseHandler)
	Sets a Action for when an this endpoint is closed locally via a call to Close. Typically used by clients for logging or other state update event processing. Clients should not perform any blocking calls within this context. It is an error for the handler to throw an exception and the outcome of doing so is undefined.

T	EngineShutdownHandler (Action< IEngine > shutdownHandler)
	Sets an Action that is invoked when the engine that supports this endpoint is shutdown which indicates a desire to terminate all engine operations. Any endpoint that has been both locally and remotely closed will not receive this event as it will no longer be tracked by the parent its parent endpoint. A typical use of this event would be from a locally closed endpoint that is awaiting response from the remote. If this event fires then there will never be a remote response to any pending operations and the client or server instance should react accordingly to clean up any related resources etc.

T	Close ()
	Close the end point locally and send the closing performative immediately if possible or holds it until the Connection / Engine state allows it. If the engine encounters an error writing the performative or the engine is in a failed state from a previous error then this method will throw an exception. If the engine has been shutdown then this method will close out the local end of the endpoint and clean up any local resources before returning normally.

T	Open ()
	Open the end point locally, sending the Open performative immediately if possible or holding it until SASL negotiations or the AMQP header exchange and other required performative exchanges has completed. The endpoint will signal any registered handler of the remote opening the endpoint once the remote performative that signals open completion arrives.

Public Member Functions inherited from Apache.Qpid.Proton.Engine.IEndpoint< IConnection >
T	Open ()
	Open the end point locally, sending the Open performative immediately if possible or holding it until SASL negotiations or the AMQP header exchange and other required performative exchanges has completed. The endpoint will signal any registered handler of the remote opening the endpoint once the remote performative that signals open completion arrives.

T	Close ()
	Close the end point locally and send the closing performative immediately if possible or holds it until the Connection / Engine state allows it. If the engine encounters an error writing the performative or the engine is in a failed state from a previous error then this method will throw an exception. If the engine has been shutdown then this method will close out the local end of the endpoint and clean up any local resources before returning normally.

T	LocalOpenHandler (Action< T > localOpenHandler)
	Sets a Action for when an this endpoint is opened locally via a call to Open. Typically used by clients for logging or other state update event processing. Clients should not perform any blocking calls within this context. It is an error for the handler to throw an exception and the outcome of doing so is undefined. Typically used by clients as servers will typically listen to some parent resource event handler to determine if the remote is initiating a resource open.

T	LocalCloseHandler (Action< T > localCloseHandler)
	Sets a Action for when an this endpoint is closed locally via a call to Close. Typically used by clients for logging or other state update event processing. Clients should not perform any blocking calls within this context. It is an error for the handler to throw an exception and the outcome of doing so is undefined.

T	OpenHandler (Action< T > localOpenHandler)
	Sets a Action for when an AMQP Open frame is received from the remote peer. Used to process remotely initiated Connections. Locally initiated sessions have their own Action invoked instead. This method is typically used by servers to listen for the remote peer to open its endpoint, while a client would listen for the server to open its end of the endpoint once a local open has been performed. Typically used by clients as servers will typically listen to some parent resource event handler to determine if the remote is initiating a resource open.

T	CloseHandler (Action< T > localCloseHandler)
	Sets a EventHandler for when an AMQP closing frame is received from the remote peer.

T	EngineShutdownHandler (Action< IEngine > shutdownHandler)
	Sets an Action that is invoked when the engine that supports this endpoint is shutdown which indicates a desire to terminate all engine operations. Any endpoint that has been both locally and remotely closed will not receive this event as it will no longer be tracked by the parent its parent endpoint. A typical use of this event would be from a locally closed endpoint that is awaiting response from the remote. If this event fires then there will never be a remote response to any pending operations and the client or server instance should react accordingly to clean up any related resources etc.

Public Member Functions inherited from Apache.Qpid.Proton.Types.Transport.IHeaderHandler< ProtonEngine >
void	HandleAMQPHeader (AmqpHeader header, E context)
	Handles AMQP Header events.

void	HandleSASLHeader (AmqpHeader header, E context)
	Handles SASL Header events.

Public Member Functions inherited from Apache.Qpid.Proton.Types.Transport.IPerformativeHandler< ProtonEngine >
void	HandleOpen (Open open, IProtonBuffer payload, ushort channel, T context)

void	HandleBegin (Begin begin, IProtonBuffer payload, ushort channel, T context)

void	HandleAttach (Attach attach, IProtonBuffer payload, ushort channel, T context)

void	HandleFlow (Flow flow, IProtonBuffer payload, ushort channel, T context)

void	HandleTransfer (Transfer transfer, IProtonBuffer payload, ushort channel, T context)

void	HandleDisposition (Disposition disposition, IProtonBuffer payload, ushort channel, T context)

void	HandleDetach (Detach detach, IProtonBuffer payload, ushort channel, T context)

void	HandleEnd (End end, IProtonBuffer payload, ushort channel, T context)

void	HandleClose (Close close, IProtonBuffer payload, ushort channel, T context)

Properties
ConnectionState	ConnectionState `[get]`
	Provides access to the current connection operating state.

ConnectionState	RemoteConnectionState `[get]`
	Provides access to the current connection operating state on the remote end of the connection.

override bool	IsLocallyOpen `[get]`

override bool	IsLocallyClosed `[get]`

override bool	IsRemotelyOpen `[get]`

override bool	IsRemotelyClosed `[get]`

string	ContainerId `[get, set]`
	Provides access to the container Id value of this connection. The value can be modified until the connection is opened after which any modification results in an exception being thrown.

string	RemoteContainerId `[get]`
	Access the remote container Id that was returned in the remote open performative.

string	Hostname `[get, set]`
	Access the name of the host (either fully qualified or relative) to which this connection is connecting to. This information may be used by the remote peer to determine the correct back-end service to connect the client to. This value will be sent in the Open performative. Note that it is illegal to set the host name to a numeric IP address or include a port number. The host name value can only be modified prior to a call to open the connection once the connection has been opened locally an error will be thrown if this method is called.

string	RemoteHostname `[get]`
	Access the remote host name that was returned in the remote open performative.

ushort	ChannelMax `[get, set]`
	Access the channel max value for this Connection. The channel max value can only be modified prior to a call to open the connection once the connection has been opened locally an error will be thrown if this method is called.

ushort	RemoteChannelMax `[get]`
	Access the remote channel max that was returned in the remote open performative.

uint	MaxFrameSize `[get, set]`
	Access the maximum frame size allowed for this connection, which is the largest single frame that the remote can send to this connection before it will close the connection with an error condition indicating the violation. The legal range for this value is defined as (512 - 2^32-1) bytes. The max frame size value can only be modified prior to a call to open the connection once the connection has been opened locally an error will be thrown if this method is called.

uint	RemoteMaxFrameSize `[get]`
	Access the remote frame size that was returned in the remote open performative.

uint	IdleTimeout `[get, set]`
	Access the idle timeout value for this Connection. The idle timeout value can only be modified prior to a call to open the connection once the connection has been opened locally an error will be thrown if this method is called.

uint	RemoteIdleTimeout `[get]`
	Access the remote idle timeout that was returned in the remote open performative.

override Symbol[]	OfferedCapabilities `[get, set]`

override Symbol[]	RemoteOfferedCapabilities `[get]`

override Symbol[]	DesiredCapabilities `[get, set]`

override Symbol[]	RemoteDesiredCapabilities `[get]`

override IReadOnlyDictionary< Symbol, object >	Properties `[get, set]`

override IReadOnlyDictionary< Symbol, object >	RemoteProperties `[get]`

ICollection< ISession >	Sessions `[get]`
	Access an enumerator that provides a view of all the currently tracked by this connection meaning each is either locally or remotely opened or both.

Properties inherited from Apache.Qpid.Proton.Engine.Implementation.ProtonEndpoint< IConnection >
virtual IEngine	Engine `[get]`
	Provides access to the engine instance that owns the resources of this endpoint and its parent.

IAttachments	Attachments `[get]`
	Access the attachments instance that is associated with this resource where the application can store data relevant to the endpoint for later use.

object	LinkedResource `[get, set]`
	Allows the endpoint to have some user defined resource linked to it which can be used to store application state data or other associated object instances with this endpoint.

virtual ErrorCondition	ErrorCondition `[get, set]`
	Provides access to the error condition that should be applied to the AMQP frame that closes or ends this endpoint when the close method is called be the user. Setting this value after closing the endpoint has no effect.

virtual ErrorCondition	RemoteErrorCondition `[get, set]`
	If the remote has closed this endpoint and provided an ErrorCondition as part of the closing AMQP performative then this method will return it.

bool	IsLocallyOpen `[get]`
	Returns true if the endpoint open was previously called and the close method has not yet been invoked. This only reflects the state on the local end and the user should also check the remote state.

bool	IsLocallyClosed `[get]`
	Returns true if the endpoint having been previously locally opened is now closed due to a call the the close method. This does not reflect the state of the remote endpoint and that should be checked separately.

bool	IsRemotelyOpen `[get]`
	Returns true if this endpoint is currently remotely open meaning that the AMQP performative that completes the open phase of this endpoint's lifetime has arrived but the performative that closes it has not.

bool	IsRemotelyClosed `[get]`
	Returns true if this endpoint is currently remotely closed meaning that the AMQP performative that completes the close phase of this endpoint's lifetime has arrived.

Symbol[]	OfferedCapabilities `[get, set]`
	Access the capabilities to be offered on to the remote when this endpoint is opened. The offered capabilities value can only be modified prior to a call to open, once the endpoint has been opened locally an error will be thrown if this method is called.

Symbol[]	DesiredCapabilities `[get, set]`
	Access the capabilities that are desired on to the remote when this endpoint is opened. The desired capabilities value can only be modified prior to a call to open, once the endpoint has been opened locally an error will be thrown if this method is called.

Symbol[]	RemoteOfferedCapabilities `[get]`
	The capabilities offered by the remote when it opened its end of the endpoint.

Symbol[]	RemoteDesiredCapabilities `[get]`
	The capabilities desired by the remote when it opened its end of the endpoint.

IReadOnlyDictionary< Symbol, object >	Properties `[get, set]`
	Access the properties that are conveyed to the remote when this endpoint is opened. The properties value can only be modified prior to a call to open, once the endpoint has been opened locally an error will be thrown if this method is called.

IReadOnlyDictionary< Symbol, object >	RemoteProperties `[get]`
	The properties sent by the remote when it opened its end of this endpoint.

Properties inherited from Apache.Qpid.Proton.Engine.IConnection
Properties inherited from Apache.Qpid.Proton.Engine.IEndpoint< IConnection >
IEngine	Engine `[get]`
	Provides access to the engine instance that owns the resources of this endpoint and its parent.

IAttachments	Attachments `[get]`
	Access the attachments instance that is associated with this resource where the application can store data relevant to the endpoint for later use.

object	LinkedResource `[get, set]`
	Allows the endpoint to have some user defined resource linked to it which can be used to store application state data or other associated object instances with this endpoint.

ErrorCondition	ErrorCondition `[get, set]`
	Provides access to the error condition that should be applied to the AMQP frame that closes or ends this endpoint when the close method is called be the user. Setting this value after closing the endpoint has no effect.

ErrorCondition	RemoteErrorCondition `[get]`
	If the remote has closed this endpoint and provided an ErrorCondition as part of the closing AMQP performative then this method will return it.

bool	IsLocallyOpen `[get]`
	Returns true if the endpoint open was previously called and the close method has not yet been invoked. This only reflects the state on the local end and the user should also check the remote state.

bool	IsLocallyClosed `[get]`
	Returns true if the endpoint having been previously locally opened is now closed due to a call the the close method. This does not reflect the state of the remote endpoint and that should be checked separately.

bool	IsRemotelyOpen `[get]`
	Returns true if this endpoint is currently remotely open meaning that the AMQP performative that completes the open phase of this endpoint's lifetime has arrived but the performative that closes it has not.

bool	IsRemotelyClosed `[get]`
	Returns true if this endpoint is currently remotely closed meaning that the AMQP performative that completes the close phase of this endpoint's lifetime has arrived.

Symbol[]	OfferedCapabilities `[get, set]`
	Access the capabilities to be offered on to the remote when this endpoint is opened. The offered capabilities value can only be modified prior to a call to open, once the endpoint has been opened locally an error will be thrown if this method is called.

Symbol[]	DesiredCapabilities `[get, set]`
	Access the capabilities that are desired on to the remote when this endpoint is opened. The desired capabilities value can only be modified prior to a call to open, once the endpoint has been opened locally an error will be thrown if this method is called.

IReadOnlyDictionary< Symbol, object >	Properties `[get, set]`
	Access the properties that are conveyed to the remote when this endpoint is opened. The properties value can only be modified prior to a call to open, once the endpoint has been opened locally an error will be thrown if this method is called.

Symbol[]	RemoteOfferedCapabilities `[get]`
	The capabilities offered by the remote when it opened its end of the endpoint.

Symbol[]	RemoteDesiredCapabilities `[get]`
	The capabilities desired by the remote when it opened its end of the endpoint.

IReadOnlyDictionary< Symbol, object >	RemoteProperties `[get]`
	The properties sent by the remote when it opened its end of this endpoint.

Additional Inherited Members
Protected Attributes inherited from Apache.Qpid.Proton.Engine.Implementation.ProtonEndpoint< IConnection >
readonly ProtonEngine	engine

Detailed Description

Implements the mechanics of managing a single AMQP connection associated with the provided engine instance.

Member Function Documentation

◆ Negotiate() [1/2]

IConnection Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.Negotiate ( )

inline

If not already negotiated this method initiates the AMQP protocol negotiation phase of the connection process sending the AMQP header to the remote peer. For a client application this could mean requesting the server to indicate if it supports the version of the protocol this client speaks. In rare cases a server could use this to preemptively send its AMQP header.

Once a header is sent the remote should respond with the AMQP Header that indicates what protocol level it supports and if there is a mismatch the the engine will be failed with an error indicating the protocol support was not successfully negotiated.

If the engine has a configured SASL layer then by starting the AMQP Header exchange this will implicitly first attempt the SASL authentication step of the connection process.

Returns: This connection instance

Exceptions

EngineStateException If the engine has failed or was shutdown

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ Negotiate() [2/2]

IConnection Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.Negotiate ( in Action< AmqpHeader > remoteAMQPHeaderHandler )

inline

If not already negotiated this method initiates the AMQP protocol negotiation phase of the connection process sending the AMQP header to the remote peer. For a client application this could mean requesting the server to indicate if it supports the version of the protocol this client speaks. In rare cases a server could use this to preemptively send its AMQP header.

Once a header is sent the remote should respond with the AMQP Header that indicates what protocol level it supports and if there is a mismatch the the engine will be failed with an error indicating the protocol support was not successfully negotiated.

The provided remote AMQP Header handler will be called once the remote sends its AMQP Header to the either preemptively or as a response to offered AMQP Header from this peer, even if that has already happened prior to this call.

If the engine has a configured SASL layer then by starting the AMQP Header exchange this will implicitly first attempt the SASL authentication step of the connection process.

Returns: This connection instance

Exceptions

EngineStateException If the engine has failed or was shutdown

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ ReceiverOpenedHandler()

IConnection Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.ReceiverOpenedHandler ( Action< IReceiver > handler )

inline

Sets an Action for when an AMQP Attach frame is received from the remote peer that represents the receiving end of a link. Used to process remotely initiated receivers. Locally initiated receivers have their own Action delegate invoked instead. This method is Typically used by servers to listen for remote receiver creation. If an event handler for remote receiver open is registered on the Session that the link is owned by then that handler will be invoked instead of this one.

Parameters

handler The handler that will process the event

Returns: This connection instance

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ SenderOpenedHandler()

IConnection Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.SenderOpenedHandler ( Action< ISender > handler )

inline

Sets an Action for when an AMQP Attach frame is received from the remote peer that represents the sending end of a link. Used to process remotely initiated sender. Locally initiated senders have their own Action delegate invoked instead. This method is Typically used by servers to listen for remote sender creation. If an event handler for remote sender open is registered on the session that the link is owned by then that handler will be invoked instead of this one.

Parameters

handler The handler that will process the event

Returns: This connection instance

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ Session()

ISession Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.Session ( )

inline

Creates a new Session linked to this Connection.

Returns: A new session instance

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ SessionOpenedHandler()

IConnection Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.SessionOpenedHandler ( Action< ISession > handler )

inline

Sets an Action for when an AMQP Begin frame is received from the remote peer. Used to process remotely initiated Sessions. Locally initiated sessions have their own Action delegate invoked instead. This method is Typically used by servers to listen for remote Session creation.

Parameters

handler The handler that will process the event

Returns: This connection instance

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ Tick()

long Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.Tick ( long current )

inline

Performs a tick operation on the connection which checks that Connection Idle timeout processing is run. It is an error to call this method if the scheduled tick method has been invoked.

Parameters

current The current system tick count

Returns: the absolute deadline in milliseconds to next call tick by/at, or 0 if there is none

Exceptions

InvalidOperationException	If the engine has already been set to auto tick
EngineStateException	If the engine has failed or was shutdown

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ TickAuto()

IConnection Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.TickAuto ( in TaskFactory taskFactory )

inline

Convenience method which is the same as calling Engine auto tick idle checking API.

Parameters

taskFactory The single threaded task factory where are engine work is queued

Returns: This connection instance

Exceptions

EngineStateException If the engine has failed or was shutdown

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ TransactionManagerOpenedHandler()

IConnection Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.TransactionManagerOpenedHandler ( Action< ITransactionManager > handler )

inline

Sets an Action for when an AMQP Attach frame is received from the remote peer that represents the manager side of a coordinator link. Used to process remotely initiated manager. Locally initiated managers have their own Action delegate invoked instead. This method is Typically used by servers to listen for remote transaction manager creation. If an event handler for remote transaction manager open is registered on the Session that the link is owned by then that handler will be invoked instead of this one.

Parameters

handler The handler that will process the event

Returns: This connection instance

Implements Apache.Qpid.Proton.Engine.IConnection.

Property Documentation

◆ ChannelMax

ushort Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.ChannelMax

getset

Access the channel max value for this Connection. The channel max value can only be modified prior to a call to open the connection once the connection has been opened locally an error will be thrown if this method is called.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ ConnectionState

ConnectionState Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.ConnectionState

get

Provides access to the current connection operating state.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ ContainerId

string Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.ContainerId

getset

Provides access to the container Id value of this connection. The value can be modified until the connection is opened after which any modification results in an exception being thrown.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ Hostname

string Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.Hostname

getset

Access the name of the host (either fully qualified or relative) to which this connection is connecting to. This information may be used by the remote peer to determine the correct back-end service to connect the client to. This value will be sent in the Open performative. Note that it is illegal to set the host name to a numeric IP address or include a port number. The host name value can only be modified prior to a call to open the connection once the connection has been opened locally an error will be thrown if this method is called.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ IdleTimeout

uint Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.IdleTimeout

getset

Access the idle timeout value for this Connection. The idle timeout value can only be modified prior to a call to open the connection once the connection has been opened locally an error will be thrown if this method is called.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ MaxFrameSize

uint Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.MaxFrameSize

getset

Access the maximum frame size allowed for this connection, which is the largest single frame that the remote can send to this connection before it will close the connection with an error condition indicating the violation. The legal range for this value is defined as (512 - 2^32-1) bytes. The max frame size value can only be modified prior to a call to open the connection once the connection has been opened locally an error will be thrown if this method is called.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ RemoteChannelMax

ushort Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.RemoteChannelMax

get

Access the remote channel max that was returned in the remote open performative.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ RemoteConnectionState

ConnectionState Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.RemoteConnectionState

get

Provides access to the current connection operating state on the remote end of the connection.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ RemoteContainerId

string Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.RemoteContainerId

get

Access the remote container Id that was returned in the remote open performative.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ RemoteHostname

string Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.RemoteHostname

get

Access the remote host name that was returned in the remote open performative.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ RemoteIdleTimeout

uint Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.RemoteIdleTimeout

get

Access the remote idle timeout that was returned in the remote open performative.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ RemoteMaxFrameSize

uint Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.RemoteMaxFrameSize

get

Access the remote frame size that was returned in the remote open performative.

Implements Apache.Qpid.Proton.Engine.IConnection.

◆ Sessions

ICollection<ISession> Apache.Qpid.Proton.Engine.Implementation.ProtonConnection.Sessions

get

Access an enumerator that provides a view of all the currently tracked by this connection meaning each is either locally or remotely opened or both.

Implements Apache.Qpid.Proton.Engine.IConnection.

The documentation for this class was generated from the following file:

src/Proton/Engine/Implementation/ProtonConnection.cs

Public Member Functions

Properties

Additional Inherited Members

Detailed Description

Member Function Documentation

◆ Negotiate() [1/2]

◆ Negotiate() [2/2]

◆ ReceiverOpenedHandler()

◆ SenderOpenedHandler()

◆ Session()

◆ SessionOpenedHandler()

◆ Tick()

◆ TickAuto()

◆ TransactionManagerOpenedHandler()

Property Documentation

◆ ChannelMax

◆ ConnectionState

◆ ContainerId

◆ Hostname

◆ IdleTimeout

◆ MaxFrameSize

◆ RemoteChannelMax

◆ RemoteConnectionState

◆ RemoteContainerId

◆ RemoteHostname

◆ RemoteIdleTimeout

◆ RemoteMaxFrameSize

◆ Sessions