Mark van Renswoude
2e2a77a7ae
- Consume calls still in the TapetiClient task queue while it is reconnecting would not be cancelled, but new calls were added as well after the reconnect - Unrelated but useful: added LocalPort and Disconnect event to logging
101 lines
3.1 KiB
C#
101 lines
3.1 KiB
C#
using System;
|
|
using System.Threading.Tasks;
|
|
|
|
// ReSharper disable UnusedMember.Global
|
|
|
|
namespace Tapeti
|
|
{
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
public class ConnectedEventArgs
|
|
{
|
|
/// <summary>
|
|
/// The connection parameters used to establish the connection.
|
|
/// </summary>
|
|
public TapetiConnectionParams ConnectionParams;
|
|
|
|
/// <summary>
|
|
/// The local port for the connection. Useful for identifying the connection in the management interface.
|
|
/// </summary>
|
|
public int LocalPort;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// Contains information about the reason for a lost connection.
|
|
/// </summary>
|
|
public class DisconnectedEventArgs
|
|
{
|
|
/// <summary>
|
|
/// The ReplyCode as indicated by the client library
|
|
/// </summary>
|
|
public ushort ReplyCode;
|
|
|
|
/// <summary>
|
|
/// The ReplyText as indicated by the client library
|
|
/// </summary>
|
|
public string ReplyText;
|
|
}
|
|
|
|
|
|
/// <inheritdoc />
|
|
public delegate void ConnectedEventHandler(object sender, ConnectedEventArgs e);
|
|
|
|
/// <inheritdoc />
|
|
public delegate void DisconnectedEventHandler(object sender, DisconnectedEventArgs e);
|
|
|
|
|
|
/// <inheritdoc />
|
|
/// <summary>
|
|
/// Represents a connection to a RabbitMQ server
|
|
/// </summary>
|
|
public interface IConnection : IDisposable
|
|
{
|
|
/// <summary>
|
|
/// Creates a subscriber to consume messages from the bound queues.
|
|
/// </summary>
|
|
/// <param name="startConsuming">If true, the subscriber will start consuming messages immediately. If false, the queues will be
|
|
/// declared but no messages will be consumed yet. Call Resume on the returned ISubscriber to start consuming messages.</param>
|
|
Task<ISubscriber> Subscribe(bool startConsuming = true);
|
|
|
|
|
|
/// <summary>
|
|
/// Synchronous version of Subscribe.
|
|
/// </summary>
|
|
/// <param name="startConsuming">If true, the subscriber will start consuming messages immediately. If false, the queues will be
|
|
/// declared but no messages will be consumed yet. Call Resume on the returned ISubscriber to start consuming messages.</param>
|
|
ISubscriber SubscribeSync(bool startConsuming = true);
|
|
|
|
|
|
/// <summary>
|
|
/// Returns an IPublisher implementation for the current connection.
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
IPublisher GetPublisher();
|
|
|
|
|
|
/// <summary>
|
|
/// Closes the connection to RabbitMQ.
|
|
/// </summary>
|
|
Task Close();
|
|
|
|
|
|
/// <summary>
|
|
/// Fired when a connection to RabbitMQ has been established.
|
|
/// </summary>
|
|
event ConnectedEventHandler Connected;
|
|
|
|
/// <summary>
|
|
/// Fired when the connection to RabbitMQ has been lost.
|
|
/// </summary>
|
|
event DisconnectedEventHandler Disconnected;
|
|
|
|
/// <summary>
|
|
/// Fired when the connection to RabbitMQ has been recovered after an unexpected disconnect.
|
|
/// </summary>
|
|
event ConnectedEventHandler Reconnected;
|
|
|
|
}
|
|
}
|