Class EventQueueClient
Event queue client
Implements
System.IDisposable
Inherited Members
System.Object.ToString()
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
Namespace: Simplic.Cloud.API.DataHub
Assembly: Simplic.Cloud.API.DataHub.dll
Syntax
public class EventQueueClient : ClientBase, IDisposable
Constructors
| Improve this Doc View SourceEventQueueClient()
Initialize new client.
Declaration
public EventQueueClient()
EventQueueClient(IClient)
Initialize client and inherit the authentication
Declaration
public EventQueueClient(IClient client)
Parameters
Type | Name | Description |
---|---|---|
IClient | client | Client instance |
EventQueueClient(String)
Initialize client with different url. DefaultUrl
Declaration
public EventQueueClient(string url)
Parameters
Type | Name | Description |
---|---|---|
System.String | url | Unique url |
Properties
| Improve this Doc View SourceApi
Gets the api name (hr)
Declaration
protected string Api { get; }
Property Value
Type | Description |
---|---|
System.String |
Controller
Gets the controller name (employee)
Declaration
protected string Controller { get; }
Property Value
Type | Description |
---|---|
System.String |
Methods
| Improve this Doc View SourceCommitAsync(CommitModel)
Declaration
public async Task CommitAsync(CommitModel model)
Parameters
Type | Name | Description |
---|---|---|
CommitModel | model |
Returns
Type | Description |
---|---|
System.Threading.Tasks.Task |
CountAsync(Guid)
Declaration
public async Task<int> CountAsync(Guid queueId)
Parameters
Type | Name | Description |
---|---|---|
System.Guid | queueId |
Returns
Type | Description |
---|---|
System.Threading.Tasks.Task<System.Int32> |
EnqueueAsync(EnqueueModel)
Declaration
public async Task EnqueueAsync(EnqueueModel model)
Parameters
Type | Name | Description |
---|---|---|
EnqueueModel | model |
Returns
Type | Description |
---|---|
System.Threading.Tasks.Task |
GetAsync(Guid, Int32)
Declaration
public async Task<IList<QueueEntryModel>> GetAsync(Guid queueId, int chunkSize)
Parameters
Type | Name | Description |
---|---|---|
System.Guid | queueId | |
System.Int32 | chunkSize |
Returns
Type | Description |
---|---|
System.Threading.Tasks.Task<System.Collections.Generic.IList<QueueEntryModel>> |
Implements
System.IDisposable