Interface IPublisherCallbackChannel

Namespace: Steeltoe.Messaging.RabbitMQ.Connection

Assembly: Steeltoe.Messaging.RabbitMQ.dll

Syntax

public interface IPublisherCallbackChannel

Properties

Channel

Gets the underlying RabbitMQ model

Declaration

RabbitMQ.Client.IModel Channel { get; }

Property Value

Type	Description
RabbitMQ.Client.IModel

Methods

AddListener(IPublisherCallbackChannel.IListener)

Add a publisher callback listener

Declaration

void AddListener(IPublisherCallbackChannel.IListener listener)

Parameters

Type	Name	Description
IPublisherCallbackChannel.IListener	listener	the listener to add

AddPendingConfirm(IPublisherCallbackChannel.IListener, UInt64, PendingConfirm)

Add a pending confirmation to this channels map

Declaration

void AddPendingConfirm(IPublisherCallbackChannel.IListener listener, ulong sequence, PendingConfirm pendingConfirm)

Parameters

Type	Name	Description
IPublisherCallbackChannel.IListener	listener	the listener the pending confir is for
System.UInt64	sequence	the key to the map
PendingConfirm	pendingConfirm	the pending confirm

Expire(IPublisherCallbackChannel.IListener, Int64)

Expire (remove) any pending confirmations created before the specified cutoff time for the supplied listener and return them to the caller

Declaration

IList<PendingConfirm> Expire(IPublisherCallbackChannel.IListener listener, long cutoffTime)

Parameters

Type	Name	Description
IPublisherCallbackChannel.IListener	listener	the listener
System.Int64	cutoffTime	the time before which expired messages were created

Returns

Type	Description
IList<PendingConfirm>	the list of expired confirms

GetPendingConfirmsCount()

Gett the total pending confirm count

Declaration

int GetPendingConfirmsCount()

Returns

Type	Description
System.Int32	the total count

GetPendingConfirmsCount(IPublisherCallbackChannel.IListener)

Get the total pending confirm count for the listener

Declaration

int GetPendingConfirmsCount(IPublisherCallbackChannel.IListener listener)

Parameters

Type	Name	Description
IPublisherCallbackChannel.IListener	listener	the listener to get confirm count for

Returns

Type	Description
System.Int32	the count of pending confirms

SetAfterAckCallback(Action<RabbitMQ.Client.IModel>)

Set a callback to be invoked after the ack/nack has been handled

Declaration

void SetAfterAckCallback(Action<RabbitMQ.Client.IModel> callback)

Parameters

Type	Name	Description
Action<RabbitMQ.Client.IModel>	callback	the callback