Class PublisherCallbackChannel
Inheritance
System.Object
PublisherCallbackChannel
Implements
RabbitMQ.Client.IModel
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
public class PublisherCallbackChannel : object, IPublisherCallbackChannel
Constructors
|
Edit this page
View Source
PublisherCallbackChannel(RabbitMQ.Client.IModel, ILogger)
Declaration
public PublisherCallbackChannel(RabbitMQ.Client.IModel channel, ILogger logger = null)
Parameters
| Type |
Name |
Description |
| RabbitMQ.Client.IModel |
channel |
|
| ILogger |
logger |
|
Fields
|
Edit this page
View Source
RETURN_LISTENER_CORRELATION_KEY
Declaration
public const string RETURN_LISTENER_CORRELATION_KEY = null
Field Value
| Type |
Description |
| System.String |
|
|
Edit this page
View Source
RETURN_LISTENER_ERROR
Declaration
public const string RETURN_LISTENER_ERROR = null
Field Value
| Type |
Description |
| System.String |
|
|
Edit this page
View Source
RETURNED_MESSAGE_CORRELATION_KEY
Declaration
public const string RETURNED_MESSAGE_CORRELATION_KEY = null
Field Value
| Type |
Description |
| System.String |
|
Properties
|
Edit this page
View Source
Channel
Declaration
public virtual RabbitMQ.Client.IModel Channel { get; }
Property Value
| Type |
Description |
| RabbitMQ.Client.IModel |
|
|
Edit this page
View Source
ChannelNumber
Declaration
public virtual int ChannelNumber { get; }
Property Value
| Type |
Description |
| System.Int32 |
|
|
Edit this page
View Source
CloseReason
Declaration
public virtual RabbitMQ.Client.ShutdownEventArgs CloseReason { get; }
Property Value
| Type |
Description |
| RabbitMQ.Client.ShutdownEventArgs |
|
|
Edit this page
View Source
ContinuationTimeout
Declaration
public virtual TimeSpan ContinuationTimeout { get; set; }
Property Value
| Type |
Description |
| TimeSpan |
|
|
Edit this page
View Source
DefaultConsumer
Declaration
public virtual RabbitMQ.Client.IBasicConsumer DefaultConsumer { get; set; }
Property Value
| Type |
Description |
| RabbitMQ.Client.IBasicConsumer |
|
|
Edit this page
View Source
IsClosed
Declaration
public virtual bool IsClosed { get; }
Property Value
| Type |
Description |
| System.Boolean |
|
|
Edit this page
View Source
IsOpen
Declaration
public virtual bool IsOpen { get; }
Property Value
| Type |
Description |
| System.Boolean |
|
|
Edit this page
View Source
NextPublishSeqNo
Declaration
public virtual ulong NextPublishSeqNo { get; }
Property Value
| Type |
Description |
| System.UInt64 |
|
Methods
|
Edit this page
View Source
Abort()
Declaration
public virtual void Abort()
|
Edit this page
View Source
Abort(UInt16, String)
Declaration
public virtual void Abort(ushort replyCode, string replyText)
Parameters
| Type |
Name |
Description |
| System.UInt16 |
replyCode |
|
| System.String |
replyText |
|
|
Edit this page
View Source
AddListener(IPublisherCallbackChannel.IListener)
Declaration
public virtual void AddListener(IPublisherCallbackChannel.IListener listener)
Parameters
|
Edit this page
View Source
AddPendingConfirm(IPublisherCallbackChannel.IListener, UInt64, PendingConfirm)
Declaration
public virtual void AddPendingConfirm(IPublisherCallbackChannel.IListener listener, ulong sequence, PendingConfirm pendingConfirm)
Parameters
|
Edit this page
View Source
BasicAck(UInt64, Boolean)
Declaration
public virtual void BasicAck(ulong deliveryTag, bool multiple)
Parameters
| Type |
Name |
Description |
| System.UInt64 |
deliveryTag |
|
| System.Boolean |
multiple |
|
|
Edit this page
View Source
BasicCancel(String)
Declaration
public virtual void BasicCancel(string consumerTag)
Parameters
| Type |
Name |
Description |
| System.String |
consumerTag |
|
|
Edit this page
View Source
BasicConsume(String, Boolean, String, Boolean, Boolean, IDictionary<String, Object>, RabbitMQ.Client.IBasicConsumer)
Declaration
public virtual string BasicConsume(string queue, bool autoAck, string consumerTag, bool noLocal, bool exclusive, IDictionary<string, object> arguments, RabbitMQ.Client.IBasicConsumer consumer)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
| System.Boolean |
autoAck |
|
| System.String |
consumerTag |
|
| System.Boolean |
noLocal |
|
| System.Boolean |
exclusive |
|
| IDictionary<System.String, System.Object> |
arguments |
|
| RabbitMQ.Client.IBasicConsumer |
consumer |
|
Returns
| Type |
Description |
| System.String |
|
|
Edit this page
View Source
BasicGet(String, Boolean)
Declaration
public virtual RabbitMQ.Client.BasicGetResult BasicGet(string queue, bool autoAck)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
| System.Boolean |
autoAck |
|
Returns
| Type |
Description |
| RabbitMQ.Client.BasicGetResult |
|
|
Edit this page
View Source
BasicNack(UInt64, Boolean, Boolean)
Declaration
public virtual void BasicNack(ulong deliveryTag, bool multiple, bool requeue)
Parameters
| Type |
Name |
Description |
| System.UInt64 |
deliveryTag |
|
| System.Boolean |
multiple |
|
| System.Boolean |
requeue |
|
|
Edit this page
View Source
BasicPublish(String, String, Boolean, RabbitMQ.Client.IBasicProperties, Byte[])
Declaration
public virtual void BasicPublish(string exchange, string routingKey, bool mandatory, RabbitMQ.Client.IBasicProperties basicProperties, byte[] body)
Parameters
| Type |
Name |
Description |
| System.String |
exchange |
|
| System.String |
routingKey |
|
| System.Boolean |
mandatory |
|
| RabbitMQ.Client.IBasicProperties |
basicProperties |
|
| System.Byte[] |
body |
|
|
Edit this page
View Source
BasicQos(UInt32, UInt16, Boolean)
Declaration
public virtual void BasicQos(uint prefetchSize, ushort prefetchCount, bool global)
Parameters
| Type |
Name |
Description |
| System.UInt32 |
prefetchSize |
|
| System.UInt16 |
prefetchCount |
|
| System.Boolean |
global |
|
|
Edit this page
View Source
BasicRecover(Boolean)
Declaration
public virtual void BasicRecover(bool requeue)
Parameters
| Type |
Name |
Description |
| System.Boolean |
requeue |
|
|
Edit this page
View Source
BasicRecoverAsync(Boolean)
Declaration
public virtual void BasicRecoverAsync(bool requeue)
Parameters
| Type |
Name |
Description |
| System.Boolean |
requeue |
|
|
Edit this page
View Source
BasicReject(UInt64, Boolean)
Declaration
public virtual void BasicReject(ulong deliveryTag, bool requeue)
Parameters
| Type |
Name |
Description |
| System.UInt64 |
deliveryTag |
|
| System.Boolean |
requeue |
|
|
Edit this page
View Source
Close()
Declaration
public virtual void Close()
|
Edit this page
View Source
Close(UInt16, String)
Declaration
public virtual void Close(ushort replyCode, string replyText)
Parameters
| Type |
Name |
Description |
| System.UInt16 |
replyCode |
|
| System.String |
replyText |
|
|
Edit this page
View Source
ConfirmSelect()
Declaration
public virtual void ConfirmSelect()
|
Edit this page
View Source
ConsumerCount(String)
Declaration
public virtual uint ConsumerCount(string queue)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
Returns
| Type |
Description |
| System.UInt32 |
|
|
Edit this page
View Source
CreateBasicProperties()
Declaration
public virtual RabbitMQ.Client.IBasicProperties CreateBasicProperties()
Returns
| Type |
Description |
| RabbitMQ.Client.IBasicProperties |
|
|
Edit this page
View Source
CreateBasicPublishBatch()
Declaration
public virtual RabbitMQ.Client.IBasicPublishBatch CreateBasicPublishBatch()
Returns
| Type |
Description |
| RabbitMQ.Client.IBasicPublishBatch |
|
|
Edit this page
View Source
Dispose()
Declaration
|
Edit this page
View Source
ExchangeBind(String, String, String, IDictionary<String, Object>)
Declaration
public virtual void ExchangeBind(string destination, string source, string routingKey, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
destination |
|
| System.String |
source |
|
| System.String |
routingKey |
|
| IDictionary<System.String, System.Object> |
arguments |
|
|
Edit this page
View Source
ExchangeBindNoWait(String, String, String, IDictionary<String, Object>)
Declaration
public virtual void ExchangeBindNoWait(string destination, string source, string routingKey, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
destination |
|
| System.String |
source |
|
| System.String |
routingKey |
|
| IDictionary<System.String, System.Object> |
arguments |
|
|
Edit this page
View Source
ExchangeDeclare(String, String, Boolean, Boolean, IDictionary<String, Object>)
Declaration
public virtual void ExchangeDeclare(string exchange, string type, bool durable, bool autoDelete, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
exchange |
|
| System.String |
type |
|
| System.Boolean |
durable |
|
| System.Boolean |
autoDelete |
|
| IDictionary<System.String, System.Object> |
arguments |
|
|
Edit this page
View Source
ExchangeDeclareNoWait(String, String, Boolean, Boolean, IDictionary<String, Object>)
Declaration
public virtual void ExchangeDeclareNoWait(string exchange, string type, bool durable, bool autoDelete, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
exchange |
|
| System.String |
type |
|
| System.Boolean |
durable |
|
| System.Boolean |
autoDelete |
|
| IDictionary<System.String, System.Object> |
arguments |
|
|
Edit this page
View Source
ExchangeDeclarePassive(String)
Declaration
public virtual void ExchangeDeclarePassive(string exchange)
Parameters
| Type |
Name |
Description |
| System.String |
exchange |
|
|
Edit this page
View Source
ExchangeDelete(String, Boolean)
Declaration
public virtual void ExchangeDelete(string exchange, bool ifUnused)
Parameters
| Type |
Name |
Description |
| System.String |
exchange |
|
| System.Boolean |
ifUnused |
|
|
Edit this page
View Source
ExchangeDeleteNoWait(String, Boolean)
Declaration
public virtual void ExchangeDeleteNoWait(string exchange, bool ifUnused)
Parameters
| Type |
Name |
Description |
| System.String |
exchange |
|
| System.Boolean |
ifUnused |
|
|
Edit this page
View Source
ExchangeUnbind(String, String, String, IDictionary<String, Object>)
Declaration
public virtual void ExchangeUnbind(string destination, string source, string routingKey, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
destination |
|
| System.String |
source |
|
| System.String |
routingKey |
|
| IDictionary<System.String, System.Object> |
arguments |
|
|
Edit this page
View Source
ExchangeUnbindNoWait(String, String, String, IDictionary<String, Object>)
Declaration
public virtual void ExchangeUnbindNoWait(string destination, string source, string routingKey, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
destination |
|
| System.String |
source |
|
| System.String |
routingKey |
|
| IDictionary<System.String, System.Object> |
arguments |
|
|
Edit this page
View Source
Expire(IPublisherCallbackChannel.IListener, Int64)
Declaration
public virtual IList<PendingConfirm> Expire(IPublisherCallbackChannel.IListener listener, long cutoffTime)
Parameters
Returns
|
Edit this page
View Source
GetPendingConfirmsCount()
Declaration
public virtual int GetPendingConfirmsCount()
Returns
| Type |
Description |
| System.Int32 |
|
|
Edit this page
View Source
GetPendingConfirmsCount(IPublisherCallbackChannel.IListener)
Declaration
public virtual int GetPendingConfirmsCount(IPublisherCallbackChannel.IListener listener)
Parameters
Returns
| Type |
Description |
| System.Int32 |
|
|
Edit this page
View Source
MessageCount(String)
Declaration
public virtual uint MessageCount(string queue)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
Returns
| Type |
Description |
| System.UInt32 |
|
|
Edit this page
View Source
QueueBind(String, String, String, IDictionary<String, Object>)
Declaration
public virtual void QueueBind(string queue, string exchange, string routingKey, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
| System.String |
exchange |
|
| System.String |
routingKey |
|
| IDictionary<System.String, System.Object> |
arguments |
|
|
Edit this page
View Source
QueueBindNoWait(String, String, String, IDictionary<String, Object>)
Declaration
public virtual void QueueBindNoWait(string queue, string exchange, string routingKey, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
| System.String |
exchange |
|
| System.String |
routingKey |
|
| IDictionary<System.String, System.Object> |
arguments |
|
|
Edit this page
View Source
QueueDeclare(String, Boolean, Boolean, Boolean, IDictionary<String, Object>)
Declaration
public virtual RabbitMQ.Client.QueueDeclareOk QueueDeclare(string queue, bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
| System.Boolean |
durable |
|
| System.Boolean |
exclusive |
|
| System.Boolean |
autoDelete |
|
| IDictionary<System.String, System.Object> |
arguments |
|
Returns
| Type |
Description |
| RabbitMQ.Client.QueueDeclareOk |
|
|
Edit this page
View Source
QueueDeclareNoWait(String, Boolean, Boolean, Boolean, IDictionary<String, Object>)
Declaration
public virtual void QueueDeclareNoWait(string queue, bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
| System.Boolean |
durable |
|
| System.Boolean |
exclusive |
|
| System.Boolean |
autoDelete |
|
| IDictionary<System.String, System.Object> |
arguments |
|
|
Edit this page
View Source
QueueDeclarePassive(String)
Declaration
public virtual RabbitMQ.Client.QueueDeclareOk QueueDeclarePassive(string queue)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
Returns
| Type |
Description |
| RabbitMQ.Client.QueueDeclareOk |
|
|
Edit this page
View Source
QueueDelete(String, Boolean, Boolean)
Declaration
public virtual uint QueueDelete(string queue, bool ifUnused, bool ifEmpty)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
| System.Boolean |
ifUnused |
|
| System.Boolean |
ifEmpty |
|
Returns
| Type |
Description |
| System.UInt32 |
|
|
Edit this page
View Source
QueueDeleteNoWait(String, Boolean, Boolean)
Declaration
public virtual void QueueDeleteNoWait(string queue, bool ifUnused, bool ifEmpty)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
| System.Boolean |
ifUnused |
|
| System.Boolean |
ifEmpty |
|
|
Edit this page
View Source
QueuePurge(String)
Declaration
public virtual uint QueuePurge(string queue)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
Returns
| Type |
Description |
| System.UInt32 |
|
|
Edit this page
View Source
QueueUnbind(String, String, String, IDictionary<String, Object>)
Declaration
public virtual void QueueUnbind(string queue, string exchange, string routingKey, IDictionary<string, object> arguments)
Parameters
| Type |
Name |
Description |
| System.String |
queue |
|
| System.String |
exchange |
|
| System.String |
routingKey |
|
| IDictionary<System.String, System.Object> |
arguments |
|
|
Edit this page
View Source
SetAfterAckCallback(Action<RabbitMQ.Client.IModel>)
Declaration
public virtual void SetAfterAckCallback(Action<RabbitMQ.Client.IModel> callback)
Parameters
| Type |
Name |
Description |
| Action<RabbitMQ.Client.IModel> |
callback |
|
|
Edit this page
View Source
TxCommit()
Declaration
public virtual void TxCommit()
|
Edit this page
View Source
TxRollback()
Declaration
public virtual void TxRollback()
|
Edit this page
View Source
TxSelect()
Declaration
public virtual void TxSelect()
|
Edit this page
View Source
WaitForConfirms()
Declaration
public virtual bool WaitForConfirms()
Returns
| Type |
Description |
| System.Boolean |
|
|
Edit this page
View Source
WaitForConfirms(TimeSpan)
Declaration
public virtual bool WaitForConfirms(TimeSpan timeout)
Parameters
| Type |
Name |
Description |
| TimeSpan |
timeout |
|
Returns
| Type |
Description |
| System.Boolean |
|
|
Edit this page
View Source
WaitForConfirms(TimeSpan, out Boolean)
Declaration
public virtual bool WaitForConfirms(TimeSpan timeout, out bool timedOut)
Parameters
| Type |
Name |
Description |
| TimeSpan |
timeout |
|
| System.Boolean |
timedOut |
|
Returns
| Type |
Description |
| System.Boolean |
|
|
Edit this page
View Source
WaitForConfirmsOrDie()
Declaration
public virtual void WaitForConfirmsOrDie()
|
Edit this page
View Source
WaitForConfirmsOrDie(TimeSpan)
Declaration
public virtual void WaitForConfirmsOrDie(TimeSpan timeout)
Parameters
| Type |
Name |
Description |
| TimeSpan |
timeout |
|
Events
|
Edit this page
View Source
BasicAcks
Declaration
public virtual event EventHandler<BasicAckEventArgs> BasicAcks
Event Type
| Type |
Description |
| EventHandler<BasicAckEventArgs> |
|
|
Edit this page
View Source
BasicNacks
Declaration
public virtual event EventHandler<BasicNackEventArgs> BasicNacks
Event Type
| Type |
Description |
| EventHandler<BasicNackEventArgs> |
|
|
Edit this page
View Source
BasicRecoverOk
Declaration
public virtual event EventHandler<EventArgs> BasicRecoverOk
Event Type
| Type |
Description |
| EventHandler<EventArgs> |
|
|
Edit this page
View Source
BasicReturn
Declaration
public virtual event EventHandler<BasicReturnEventArgs> BasicReturn
Event Type
| Type |
Description |
| EventHandler<BasicReturnEventArgs> |
|
|
Edit this page
View Source
CallbackException
Declaration
public virtual event EventHandler<CallbackExceptionEventArgs> CallbackException
Event Type
| Type |
Description |
| EventHandler<CallbackExceptionEventArgs> |
|
|
Edit this page
View Source
FlowControl
Declaration
public virtual event EventHandler<FlowControlEventArgs> FlowControl
Event Type
| Type |
Description |
| EventHandler<FlowControlEventArgs> |
|
|
Edit this page
View Source
ModelShutdown
Declaration
public virtual event EventHandler<RabbitMQ.Client.ShutdownEventArgs> ModelShutdown
Event Type
| Type |
Description |
| EventHandler<RabbitMQ.Client.ShutdownEventArgs> |
|
Implements
RabbitMQ.Client.IModel