Interface IConnection
Namespace: Steeltoe.Messaging.RabbitMQ.Connection
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
public interface IConnection
Properties
| Edit this page View SourceConnection
Gets the underlying RabbitMQ connection
Declaration
RabbitMQ.Client.IConnection Connection { get; }
Property Value
Type | Description |
---|---|
RabbitMQ.Client.IConnection |
IsOpen
Gets a value indicating whether the connection is open
Declaration
bool IsOpen { get; }
Property Value
Type | Description |
---|---|
System.Boolean |
LocalPort
Gets the local port of the connection
Declaration
int LocalPort { get; }
Property Value
Type | Description |
---|---|
System.Int32 |
Methods
| Edit this page View SourceAddBlockedListener(IBlockedListener)
Add a Blocked listener to the connection
Declaration
void AddBlockedListener(IBlockedListener listener)
Parameters
Type | Name | Description |
---|---|---|
IBlockedListener | listener | the listener to add |
Close()
Close the connection
Declaration
void Close()
CreateChannel(Boolean)
Create a new channel, using an inernally allocated channel number
Declaration
RabbitMQ.Client.IModel CreateChannel(bool transactional = false)
Parameters
Type | Name | Description |
---|---|---|
System.Boolean | transactional | true if transaction support on channel |
Returns
Type | Description |
---|---|
RabbitMQ.Client.IModel | the new channel |
RemoveBlockedListener(IBlockedListener)
Remove a Blocked listener from the connection
Declaration
bool RemoveBlockedListener(IBlockedListener listener)
Parameters
Type | Name | Description |
---|---|---|
IBlockedListener | listener | the listener to remove |
Returns
Type | Description |
---|---|
System.Boolean | true if successful |