Skip to main content

BackgroundMqClient

Assembly: ServiceStack.dll
View Source
Declaration
public class BackgroundMqClient : IMessageQueueClient, IMessageProducer, IDisposable, IOneWayClient

Methods

Publish<T>(T)

View Source
Declaration
public void Publish<T>(T messageBody)
Parameters
TypeName
<T>messageBody
Type Parameters
  • T

Publish<T>(IMessage<T>)

View Source
Declaration
public void Publish<T>(IMessage<T> message)
Parameters
TypeName
ServiceStack.Messaging.IMessage<T>message
Type Parameters
  • T

Publish(String, IMessage)

View Source
Declaration
public void Publish(string queueName, IMessage message)
Parameters
TypeName
System.StringqueueName
ServiceStack.Messaging.IMessagemessage

Notify(String, IMessage)

View Source
Declaration
public void Notify(string queueName, IMessage message)
Parameters
TypeName
System.StringqueueName
ServiceStack.Messaging.IMessagemessage

Get<T>(String, Nullable<TimeSpan>)

View Source
Declaration
public IMessage<T> Get<T>(string queueName, TimeSpan? timeout = null)
Returns

ServiceStack.Messaging.IMessage<T>

Parameters
TypeName
System.StringqueueName
System.Nullable<System.TimeSpan>timeout
Type Parameters
  • T

GetAsync<T>(String)

View Source
Declaration
public IMessage<T> GetAsync<T>(string queueName)
Returns

ServiceStack.Messaging.IMessage<T>

Parameters
TypeName
System.StringqueueName
Type Parameters
  • T

Ack(IMessage)

View Source
Declaration
public void Ack(IMessage message)
Parameters
TypeName
ServiceStack.Messaging.IMessagemessage

Nak(IMessage, Boolean, Exception)

View Source
Declaration
public void Nak(IMessage message, bool requeue, Exception exception = null)
Parameters
TypeName
ServiceStack.Messaging.IMessagemessage
System.Booleanrequeue
System.Exceptionexception

CreateMessage<T>(Object)

View Source
Declaration
public IMessage<T> CreateMessage<T>(object mqResponse)
Returns

ServiceStack.Messaging.IMessage<T>

Parameters
TypeName
System.ObjectmqResponse
Type Parameters
  • T

GetTempQueueName()

View Source
Declaration
public string GetTempQueueName()
Returns

System.String

SendOneWay(Object)

View Source
Declaration
public void SendOneWay(object requestDto)
Parameters
TypeName
System.ObjectrequestDto

SendOneWay(String, Object)

View Source
Declaration
public void SendOneWay(string queueName, object requestDto)
Parameters
TypeName
System.StringqueueName
System.ObjectrequestDto

SendAllOneWay(IEnumerable<Object>)

View Source
Declaration
public void SendAllOneWay(IEnumerable<object> requests)
Parameters
TypeName
System.Collections.Generic.IEnumerable<System.Object>requests

Dispose()

View Source
Declaration
public void Dispose()

Implements