Method CreateQueue
CreateQueue<T>(String)
Creates Distributed Queue against the provided collection name.
Declaration
IDistributedQueue<T> CreateQueue<T>(string key)
Parameters
Type | Name | Description |
---|---|---|
System.String | key | Name of collection to be created. |
Returns
Type | Description |
---|---|
IDistributedQueue<T> | Interface for using Queue. |
Type Parameters
Name | Description |
---|---|
T | Type of Queue items. |
Examples
The following code sample shows how to create a Distributed Queue.
ICache cache = CacheManager.GetCache("demoClusteredCache");
string dataTypeName = "DistributedQueue";
IDistributedQueue<Product> queue = cache.DataTypeManager.CreateQueue<Product>(dataTypeName);
CreateQueue<T>(String, DataTypeAttributes, WriteThruOptions)
Creates Distributed Queue against the provided collection name and configures it according to the provided user configuration as attributes of collection.
Declaration
IDistributedQueue<T> CreateQueue<T>(string key, DataTypeAttributes attributes, WriteThruOptions options = null)
Parameters
Type | Name | Description |
---|---|---|
System.String | key | Name of collection to be created |
DataTypeAttributes | attributes | DataTypeAttributes for providing user configuration for this collection. |
WriteThruOptions | options | WriteThruOptions regarding updating data source. This can be WriteThru, WriteBehind or none. |
Returns
Type | Description |
---|---|
IDistributedQueue<T> | Interface for using Queue. |
Type Parameters
Name | Description |
---|---|
T | Type of Queue items. |
Examples
The following code sample shows how to create a Distributed Queue with absoulte expiration of 1 minutes.
ICache cache = CacheManager.GetCache("demoClusteredCache");
string dataTypeName = "DistributedQueue";
DataTypeAttributes attributes = new DataTypeAttributes();
attributes.Expiration = new Expiration(ExpirationType.Absolute, new TimeSpan(0, 1, 0));
IDistributedQueue<Product> queue = cache.DataTypeManager.CreateQueue<Product>(dataTypeName, attributes);