117 lines
3.6 KiB
C#
117 lines
3.6 KiB
C#
using System;
|
|
using System.Threading.Tasks;
|
|
|
|
// ReSharper disable UnusedMember.Global
|
|
// ReSharper disable UnusedMemberInSuper.Global
|
|
|
|
namespace Tapeti
|
|
{
|
|
/// <summary>
|
|
/// Contains information about the established connection.
|
|
/// </summary>
|
|
public class ConnectedEventArgs
|
|
{
|
|
/// <summary>
|
|
/// The connection parameters used to establish the connection.
|
|
/// </summary>
|
|
public TapetiConnectionParams ConnectionParams { get; }
|
|
|
|
/// <summary>
|
|
/// The local port for the connection. Useful for identifying the connection in the management interface.
|
|
/// </summary>
|
|
public int LocalPort { get; }
|
|
|
|
|
|
/// <summary></summary>
|
|
public ConnectedEventArgs(TapetiConnectionParams connectionParams, int localPort)
|
|
{
|
|
ConnectionParams = connectionParams;
|
|
LocalPort = 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 { get; }
|
|
|
|
/// <summary>
|
|
/// The ReplyText as indicated by the client library
|
|
/// </summary>
|
|
public string ReplyText { get; }
|
|
|
|
|
|
/// <summary></summary>
|
|
public DisconnectedEventArgs(ushort replyCode, string replyText)
|
|
{
|
|
ReplyCode = replyCode;
|
|
ReplyText = replyText;
|
|
}
|
|
}
|
|
|
|
|
|
/// <inheritdoc />
|
|
public delegate void ConnectedEventHandler(object sender, ConnectedEventArgs e);
|
|
|
|
/// <inheritdoc />
|
|
public delegate void DisconnectedEventHandler(object sender, DisconnectedEventArgs e);
|
|
|
|
|
|
/// <summary>
|
|
/// Represents a connection to a RabbitMQ server
|
|
/// </summary>
|
|
public interface IConnection : IAsyncDisposable, 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;
|
|
|
|
}
|
|
}
|