Interface IPublisherCallbackChannel
Namespace: Steeltoe.Messaging.RabbitMQ.Connection
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
csharp
public interface IPublisherCallbackChannel
Properties
| Edit this page View SourceChannel
Gets the underlying RabbitMQ model
Declaration
csharp
RabbitMQ.Client.IModel Channel { get; }
Property Value
Type | Description |
---|---|
Rabbit |
Methods
| Edit this page View SourceAddListener(IPublisherCallbackChannel.IListener)
Add a publisher callback listener
Declaration
csharp
void AddListener(IPublisherCallbackChannel.IListener listener)
Parameters
Type | Name | Description |
---|---|---|
IPublisher |
listener | the listener to add |
AddPendingConfirm(IPublisherCallbackChannel.IListener, UInt64, PendingConfirm)
Add a pending confirmation to this channels map
Declaration
csharp
void AddPendingConfirm(IPublisherCallbackChannel.IListener listener, ulong sequence, PendingConfirm pendingConfirm)
Parameters
Type | Name | Description |
---|---|---|
IPublisher |
listener | the listener the pending confir is for |
System. |
sequence | the key to the map |
Pending |
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
csharp
IList<PendingConfirm> Expire(IPublisherCallbackChannel.IListener listener, long cutoffTime)
Parameters
Type | Name | Description |
---|---|---|
IPublisher |
listener | the listener |
System. |
cutoffTime | the time before which expired messages were created |
Returns
Type | Description |
---|---|
IList<Pending |
the list of expired confirms |
GetPendingConfirmsCount()
Gett the total pending confirm count
Declaration
csharp
int GetPendingConfirmsCount()
Returns
Type | Description |
---|---|
System. |
the total count |
GetPendingConfirmsCount(IPublisherCallbackChannel.IListener)
Get the total pending confirm count for the listener
Declaration
csharp
int GetPendingConfirmsCount(IPublisherCallbackChannel.IListener listener)
Parameters
Type | Name | Description |
---|---|---|
IPublisher |
listener | the listener to get confirm count for |
Returns
Type | Description |
---|---|
System. |
the count of pending confirms |
SetAfterAckCallback(Action<RabbitMQ.Client.IModel>)
Set a callback to be invoked after the ack/nack has been handled
Declaration
csharp
void SetAfterAckCallback(Action<RabbitMQ.Client.IModel> callback)
Parameters
Type | Name | Description |
---|---|---|
Action<Rabbit |
callback | the callback |