Interface IPublisherCallbackChannel

Namespace

Steeltoe.Messaging.RabbitMQ.Connection

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public interface IPublisherCallbackChannel : IModel, IDisposable

Inherited Members

IModel.Abort()

IModel.Abort(ushort, string)

IModel.BasicAck(ulong, bool)

IModel.BasicCancel(string)

IModel.BasicConsume(string, bool, string, bool, bool, IDictionary<string, object>, IBasicConsumer)

IModel.BasicGet(string, bool)

IModel.BasicNack(ulong, bool, bool)

IModel.BasicPublish(string, string, bool, IBasicProperties, byte[])

IModel.BasicQos(uint, ushort, bool)

IModel.BasicRecover(bool)

IModel.BasicRecoverAsync(bool)

IModel.BasicReject(ulong, bool)

IModel.Close()

IModel.Close(ushort, string)

IModel.ConfirmSelect()

IModel.CreateBasicPublishBatch()

IModel.CreateBasicProperties()

IModel.ExchangeBind(string, string, string, IDictionary<string, object>)

IModel.ExchangeBindNoWait(string, string, string, IDictionary<string, object>)

IModel.ExchangeDeclare(string, string, bool, bool, IDictionary<string, object>)

IModel.ExchangeDeclareNoWait(string, string, bool, bool, IDictionary<string, object>)

IModel.ExchangeDeclarePassive(string)

IModel.ExchangeDelete(string, bool)

IModel.ExchangeDeleteNoWait(string, bool)

IModel.ExchangeUnbind(string, string, string, IDictionary<string, object>)

IModel.ExchangeUnbindNoWait(string, string, string, IDictionary<string, object>)

IModel.QueueBind(string, string, string, IDictionary<string, object>)

IModel.QueueBindNoWait(string, string, string, IDictionary<string, object>)

IModel.QueueDeclare(string, bool, bool, bool, IDictionary<string, object>)

IModel.QueueDeclareNoWait(string, bool, bool, bool, IDictionary<string, object>)

IModel.QueueDeclarePassive(string)

IModel.MessageCount(string)

IModel.ConsumerCount(string)

IModel.QueueDelete(string, bool, bool)

IModel.QueueDeleteNoWait(string, bool, bool)

IModel.QueuePurge(string)

IModel.QueueUnbind(string, string, string, IDictionary<string, object>)

IModel.TxCommit()

IModel.TxRollback()

IModel.TxSelect()

IModel.WaitForConfirms()

IModel.WaitForConfirms(TimeSpan)

IModel.WaitForConfirms(TimeSpan, out bool)

IModel.WaitForConfirmsOrDie()

IModel.WaitForConfirmsOrDie(TimeSpan)

IModel.ChannelNumber

IModel.CloseReason

IModel.DefaultConsumer

IModel.IsClosed

IModel.IsOpen

IModel.NextPublishSeqNo

IModel.ContinuationTimeout

IModel.BasicAcks

IModel.BasicNacks

IModel.BasicRecoverOk

IModel.BasicReturn

IModel.CallbackException

IModel.FlowControl

IModel.ModelShutdown

IDisposable.Dispose()

Properties

Channel

Gets the underlying RabbitMQ model

IModel Channel { get; }

Property Value

IModel

Methods

AddListener(IListener)

Add a publisher callback listener

void AddListener(IPublisherCallbackChannel.IListener listener)

Parameters

listener IPublisherCallbackChannel.IListener

the listener to add

AddPendingConfirm(IListener, ulong, PendingConfirm)

Add a pending confirmation to this channels map

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

Parameters

listener IPublisherCallbackChannel.IListener

the listener the pending confir is for

sequence ulong

the key to the map

pendingConfirm PendingConfirm

the pending confirm

Expire(IListener, long)

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

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

Parameters

listener IPublisherCallbackChannel.IListener

the listener

cutoffTime long

the time before which expired messages were created

Returns

IList<PendingConfirm>

the list of expired confirms

GetPendingConfirmsCount()

Gett the total pending confirm count

int GetPendingConfirmsCount()

Returns

int

the total count

GetPendingConfirmsCount(IListener)

Get the total pending confirm count for the listener

int GetPendingConfirmsCount(IPublisherCallbackChannel.IListener listener)

Parameters

listener IPublisherCallbackChannel.IListener

the listener to get confirm count for

Returns

int

the count of pending confirms

SetAfterAckCallback(Action<IModel>)

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

void SetAfterAckCallback(Action<IModel> callback)

Parameters

callback Action<IModel>

the callback