PR comments Add Summary
This commit is contained in:
Родитель
5aed737167
Коммит
ed13276da3
|
@ -9,21 +9,48 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ
|
|||
using Newtonsoft.Json.Linq;
|
||||
|
||||
/// <summary>
|
||||
/// combined the needed proprieties form the API and the action in one class
|
||||
/// Combined the needed proprieties form the API and the action in one class.
|
||||
/// </summary>
|
||||
internal class ActiveMQTriggerParameters
|
||||
{
|
||||
private InsensitiveDictionary<JToken> connectionParameters;
|
||||
private ServiceOperationRequest serviceOperationRequest;
|
||||
|
||||
/// <summary>
|
||||
/// BrokerUri ActiveMQ BrokerUri.
|
||||
/// </summary>
|
||||
public string BrokerUri { get; }
|
||||
|
||||
/// <summary>
|
||||
/// ClientId for the ActiveMQ client.
|
||||
/// </summary>
|
||||
public string ClientId { get; }
|
||||
|
||||
/// <summary>
|
||||
/// The user name that will be used to connect to the BrokerUri.
|
||||
/// </summary>
|
||||
public string UserName { get; }
|
||||
|
||||
/// <summary>
|
||||
/// Password.
|
||||
/// </summary>
|
||||
public string Password { get; }
|
||||
|
||||
/// <summary>
|
||||
/// Maximum Number of messages to be received in one trigger.
|
||||
/// </summary>
|
||||
public int MaximumNumber { get; }
|
||||
|
||||
/// <summary>
|
||||
/// ActiveMQ Queue name.
|
||||
/// </summary>
|
||||
public string QueueName { get; }
|
||||
|
||||
/// <summary>
|
||||
/// Initializes a new instance of the <see cref="ActiveMQTriggerParameters"/> class.
|
||||
/// </summary>
|
||||
/// <param name="connectionParameters"></param>
|
||||
/// <param name="serviceOperationRequest"></param>
|
||||
public ActiveMQTriggerParameters(InsensitiveDictionary<JToken> connectionParameters, ServiceOperationRequest serviceOperationRequest)
|
||||
{
|
||||
this.connectionParameters = connectionParameters;
|
||||
|
|
|
@ -10,6 +10,10 @@
|
|||
<NoWarn>$(NoWarn);NU5104;CS8002</NoWarn>
|
||||
</PropertyGroup>
|
||||
|
||||
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
|
||||
<DocumentationFile>C:\temp\logicapps-connector-extensions\src\ActiveMQ\Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.xml</DocumentationFile>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="StyleCop.Analyzers" Version="1.1.0-beta004">
|
||||
<PrivateAssets>all</PrivateAssets>
|
||||
|
|
|
@ -0,0 +1,231 @@
|
|||
<?xml version="1.0"?>
|
||||
<doc>
|
||||
<assembly>
|
||||
<name>Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ</name>
|
||||
</assembly>
|
||||
<members>
|
||||
<member name="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerParameters">
|
||||
<summary>
|
||||
Combined the needed proprieties form the API and the action in one class.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerParameters.BrokerUri">
|
||||
<summary>
|
||||
BrokerUri ActiveMQ BrokerUri.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerParameters.ClientId">
|
||||
<summary>
|
||||
ClientId for the ActiveMQ client.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerParameters.UserName">
|
||||
<summary>
|
||||
The user name that will be used to connect to the BrokerUri.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerParameters.Password">
|
||||
<summary>
|
||||
Password.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerParameters.MaximumNumber">
|
||||
<summary>
|
||||
Maximum Number of messages to be received in one trigger.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerParameters.QueueName">
|
||||
<summary>
|
||||
ActiveMQ Queue name.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerParameters.#ctor(Microsoft.WindowsAzure.ResourceStack.Common.Collections.InsensitiveDictionary{Newtonsoft.Json.Linq.JToken},Microsoft.Azure.Workflows.ServiceProviders.Abstractions.ServiceOperationRequest)">
|
||||
<summary>
|
||||
Initializes a new instance of the <see cref="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerParameters"/> class.
|
||||
</summary>
|
||||
<param name="connectionParameters"></param>
|
||||
<param name="serviceOperationRequest"></param>
|
||||
</member>
|
||||
<member name="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Properties.Resources">
|
||||
<summary>
|
||||
A strongly-typed resource class, for looking up localized strings, etc.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Properties.Resources.ResourceManager">
|
||||
<summary>
|
||||
Returns the cached ResourceManager instance used by this class.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Properties.Resources.Culture">
|
||||
<summary>
|
||||
Overrides the current thread's CurrentUICulture property for all
|
||||
resource lookups using this strongly typed resource class.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Properties.Resources.IconUri">
|
||||
<summary>
|
||||
Looks up a localized string similar to data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAEAAAABACAMAAACdt4HsAAAA/1BMVEVHcEwxABcPAAcDAAEXAAsuABYMAAZOACYCAAAGAAMFAAEhABBOACZCACAyABhEACFEACErABQOAAZZACssABUhABBBAB9UAChXACtKACRKACQ8AB0NAAY2ABo+AB4/AB5oADO4uLhpBDS3t7dmADL///9eAC6XcYKtoKZkADGnk5ukjJZsCzlwFUB0Hke3tba1srSDQ2CqmqG0sLJ7MVOTaXuITmmwpaqBPFylkJmbeIfm2N6KVGx4KU6yqa2GSWV/N1jOs76PXXOdfovVvsizrbCufpKSZHmhh5LDo6+TUG7Yw8vp3uKYW3Xu5un8+vq0r7Gpdoy4i5+6kqLayM9WdZUQAAAAIHRSTlMAuCIFRoEb/gERClzt0KfG9ps0/49s7Pb81+GbK9aytz26P6AAAAQASURBVFjDpVeHduIwEKSX0AkQLg [rest of string was truncated]";.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQConnectionParameters">
|
||||
<summary>
|
||||
ActiveMQConnectionParameters API connection parameters
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQConnectionParameters.BrokerUri">
|
||||
<summary>
|
||||
BrokerUri ActiveMQ BrokerUri.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQConnectionParameters.ClientId">
|
||||
<summary>
|
||||
ClientId for the ActiveMQ client.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQConnectionParameters.QueueName">
|
||||
<summary>
|
||||
ActiveMQ Queue name.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQConnectionParameters.UserName">
|
||||
<summary>
|
||||
The user name that will be used to connect to the BrokerUri.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="P:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQConnectionParameters.Password">
|
||||
<summary>
|
||||
Password.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQServiceProvider">
|
||||
<summary>
|
||||
ActiveMQ service provider.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQServiceProvider.#ctor(Microsoft.Azure.Workflows.ServiceProviders.Abstractions.ServiceOperationsProvider,Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider)">
|
||||
<summary>
|
||||
Initializes a new instance of the <see cref="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQServiceProvider"/> class.
|
||||
</summary>
|
||||
<param name="serviceOperationsProvider">The service provider.</param>
|
||||
<param name="operationsProvider">The operations provider.</param>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQServiceProvider.Initialize(Microsoft.Azure.WebJobs.Host.Config.ExtensionConfigContext)">
|
||||
<summary>
|
||||
Initialize.
|
||||
</summary>
|
||||
<param name="context">The context.</param>
|
||||
</member>
|
||||
<member name="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerResponse">
|
||||
<summary>
|
||||
ActiveMQ trigger response.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerResponse.#ctor(Newtonsoft.Json.Linq.JToken,System.Net.HttpStatusCode)">
|
||||
<summary>
|
||||
Initializes a new instance of the <see cref="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerResponse"/> class.
|
||||
</summary>
|
||||
<param name="body">The body.</param>
|
||||
<param name="statusCode">The HTTP status code.</param>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerResponse.CompleteOperation">
|
||||
<summary>
|
||||
Completes the operation.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerResponse.FailOperation">
|
||||
<summary>
|
||||
Fails the operation.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider">
|
||||
<summary>
|
||||
This is the service operation provider class where you define all the operations and apis.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="F:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.messageReceiveTimeout">
|
||||
<summary>
|
||||
Amount of time to wait to receive new ActiveMQ message.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="F:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.ServiceName">
|
||||
<summary>
|
||||
The service name.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="F:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.ServiceId">
|
||||
<summary>
|
||||
The service id.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="F:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.serviceOperationsList">
|
||||
<summary>
|
||||
Gets or sets service Operations.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="F:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.apiOperationsList">
|
||||
<summary>
|
||||
The set of all API Operations.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="F:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.ReceiveMessagesTrigger">
|
||||
<summary>
|
||||
Gwe ReceiveMessagesTrigger Service Operation.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.#ctor">
|
||||
<summary>
|
||||
Initializes a new instance of the <see cref="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider"/> class.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.GetBindingConnectionInformation(System.String,Microsoft.WindowsAzure.ResourceStack.Common.Collections.InsensitiveDictionary{Newtonsoft.Json.Linq.JToken})">
|
||||
<summary>
|
||||
Gets the connection.
|
||||
</summary>
|
||||
<param name="operationId">The operation id.</param>
|
||||
<param name="connectionParameters">The connection parameters.</param>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.GetFunctionTriggerType">
|
||||
<summary>
|
||||
Trigger is not available.
|
||||
</summary>
|
||||
<returns></returns>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.GetOperations(System.Boolean)">
|
||||
<summary>
|
||||
Gets the operations.
|
||||
</summary>
|
||||
<param name="expandManifest">The expand anifest flag.</param>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.GetApiOperations">
|
||||
<summary>
|
||||
Gets the operations.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.GetService">
|
||||
<summary>
|
||||
Get service operation.
|
||||
</summary>
|
||||
<returns>Service operation api.</returns>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQTriggerServiceOperationProvider.InvokeOperation(System.String,Microsoft.WindowsAzure.ResourceStack.Common.Collections.InsensitiveDictionary{Newtonsoft.Json.Linq.JToken},Microsoft.Azure.Workflows.ServiceProviders.Abstractions.ServiceOperationRequest)">
|
||||
<summary>
|
||||
the InvokeOperation will be executed periodical to fetch the new ActiveMQ messages
|
||||
</summary>
|
||||
<param name="operationId"></param>
|
||||
<param name="connectionParameters"></param>
|
||||
<param name="serviceOperationRequest"></param>
|
||||
<returns></returns>
|
||||
</member>
|
||||
<member name="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQStartup">
|
||||
<summary>
|
||||
ActiveMQ startup class.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.ActiveMQStartup.Configure(Microsoft.Azure.WebJobs.IWebJobsBuilder)">
|
||||
<summary>
|
||||
Configures the service provider here.
|
||||
</summary>
|
||||
<param name="builder">The builder.</param>
|
||||
</member>
|
||||
</members>
|
||||
</doc>
|
|
@ -4,19 +4,34 @@
|
|||
namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ
|
||||
{
|
||||
using Microsoft.Azure.Workflows.ServiceProviders.Abstractions;
|
||||
|
||||
/// <summary>
|
||||
/// ActiveMQConnectionParameters API connection parameters
|
||||
/// </summary>
|
||||
public class ActiveMQConnectionParameters : ConnectionParameters
|
||||
{
|
||||
{/// <summary>
|
||||
/// BrokerUri ActiveMQ BrokerUri.
|
||||
/// </summary>
|
||||
public ConnectionStringParameters BrokerUri { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// ClientId for the ActiveMQ client.
|
||||
/// </summary>
|
||||
public ConnectionStringParameters ClientId { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// ActiveMQ Queue name.
|
||||
/// </summary>
|
||||
public ConnectionStringParameters QueueName { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// The user name that will be used to connect to the BrokerUri.
|
||||
/// </summary>
|
||||
public ConnectionStringParameters UserName { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// Password.
|
||||
/// </summary>
|
||||
public ConnectionStringParameters Password { get; set; }
|
||||
}
|
||||
}
|
|
@ -7,7 +7,6 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ
|
|||
using Microsoft.Azure.WebJobs.Host.Config;
|
||||
using Microsoft.Azure.Workflows.ServiceProviders.Abstractions;
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// ActiveMQ service provider.
|
||||
/// </summary>
|
||||
|
|
|
@ -9,7 +9,7 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ
|
|||
using System.Threading.Tasks;
|
||||
|
||||
/// <summary>
|
||||
/// The ActiveMQ trigger response.
|
||||
/// ActiveMQ trigger response.
|
||||
/// </summary>
|
||||
public class ActiveMQTriggerResponse : ServiceOperationResponse
|
||||
{
|
||||
|
|
|
@ -21,16 +21,34 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ
|
|||
[ServiceOperationsProvider(Id = ServiceId, Name = ServiceName)]
|
||||
public class ActiveMQTriggerServiceOperationProvider : IServiceOperationsTriggerProvider
|
||||
{
|
||||
/// <summary>
|
||||
/// Amount of time to wait to receive new ActiveMQ message.
|
||||
/// </summary>
|
||||
private readonly TimeSpan messageReceiveTimeout = new TimeSpan(0, 0, 0, 1);
|
||||
|
||||
/// <summary>
|
||||
/// The service name.
|
||||
/// </summary>
|
||||
public const string ServiceName = "activemq";
|
||||
|
||||
/// <summary>
|
||||
/// The service id.
|
||||
/// </summary>
|
||||
public const string ServiceId = "/serviceProviders/activemq";
|
||||
|
||||
/// <summary>
|
||||
/// Gets or sets service Operations.
|
||||
/// </summary>
|
||||
private readonly List<ServiceOperation> serviceOperationsList;
|
||||
|
||||
/// <summary>
|
||||
/// The set of all API Operations.
|
||||
/// </summary>
|
||||
private readonly InsensitiveDictionary<ServiceOperation> apiOperationsList;
|
||||
|
||||
/// <summary>
|
||||
/// Get ReceiveMessagesTrigger Service Operation.
|
||||
/// </summary>
|
||||
public readonly ServiceOperation ReceiveMessagesTrigger = new ServiceOperation
|
||||
{
|
||||
Name = "ActiveMQ_ReceiveMessages",
|
||||
|
@ -48,7 +66,9 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ
|
|||
Trigger = TriggerType.Batch,
|
||||
},
|
||||
};
|
||||
|
||||
/// <summary>
|
||||
/// Get AtiveMQTriggerApi Service Operation.API used for the connection API.
|
||||
/// </summary>
|
||||
private static readonly ServiceOperationApi AtiveMQTriggerApi = new ServiceOperationApi
|
||||
{
|
||||
Name = "activemq",
|
||||
|
@ -58,8 +78,8 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ
|
|||
{
|
||||
BrandColor = 0xC4D5FF,
|
||||
IconUri = new Uri(Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Properties.Resources.IconUri),
|
||||
Description = "AtiveMQ",
|
||||
DisplayName = "AtiveMQ",
|
||||
Description = "ActiveMQ",
|
||||
DisplayName = "ActiveMQ",
|
||||
Capabilities = new ApiCapability[] { ApiCapability.Triggers },
|
||||
ConnectionParameters = new ActiveMQConnectionParameters
|
||||
{
|
||||
|
@ -284,13 +304,17 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ
|
|||
return apiOperationsList.Values;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Get service operation.
|
||||
/// </summary>
|
||||
/// <returns>Service operation api.</returns>
|
||||
public ServiceOperationApi GetService()
|
||||
{
|
||||
return AtiveMQTriggerApi;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// the InvokeOperation will be executed periodical to fitch the new ActiveMQ messages
|
||||
/// the InvokeOperation will be executed periodical to fetch the new ActiveMQ messages
|
||||
/// </summary>
|
||||
/// <param name="operationId"></param>
|
||||
/// <param name="connectionParameters"></param>
|
||||
|
@ -333,7 +357,7 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ
|
|||
}
|
||||
else
|
||||
{
|
||||
//the we will exit the loop if there are no message
|
||||
//Will exit the loop if there are no message
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
|
|
@ -9,7 +9,6 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ
|
|||
{
|
||||
using Microsoft.Azure.WebJobs;
|
||||
using Microsoft.Azure.WebJobs.Hosting;
|
||||
using Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ;
|
||||
using Microsoft.Extensions.DependencyInjection.Extensions;
|
||||
|
||||
/// <summary>
|
||||
|
|
|
@ -112,3 +112,4 @@
|
|||
|
||||
# execute the above function here.
|
||||
#add-extension $args[0] $args[1]
|
||||
# or you can Import-Module C:\pathto the file\add-extension.ps1 then run add-extension
|
|
@ -3,9 +3,6 @@
|
|||
|
||||
namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests
|
||||
{
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Threading.Tasks;
|
||||
using Microsoft.AspNetCore.Hosting;
|
||||
using Microsoft.Azure.WebJobs;
|
||||
using Microsoft.Azure.WebJobs.Host.TestCommon;
|
||||
|
@ -16,6 +13,9 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests
|
|||
using Microsoft.Extensions.Hosting;
|
||||
using Microsoft.Extensions.Logging;
|
||||
using Microsoft.WindowsAzure.ResourceStack.Common.Extensions;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Threading.Tasks;
|
||||
using Xunit;
|
||||
|
||||
/// <summary>
|
||||
|
@ -65,7 +65,6 @@ namespace Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests
|
|||
var host = new HostBuilder()
|
||||
.ConfigureWebJobs(builder =>
|
||||
{
|
||||
|
||||
var serviceOperationProvider = new ServiceOperationsProvider();
|
||||
var operationProvider = new ActiveMQTriggerServiceOperationProvider();
|
||||
builder.AddExtension(new ActiveMQServiceProvider(serviceOperationProvider, operationProvider));
|
||||
|
|
|
@ -7,6 +7,10 @@
|
|||
<CodeAnalysisRuleSet>..\..\..\src.ruleset</CodeAnalysisRuleSet>
|
||||
</PropertyGroup>
|
||||
|
||||
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
|
||||
<DocumentationFile>C:\temp\logicapps-connector-extensions\test\ActiveMQ\Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests\Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.xml</DocumentationFile>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Microsoft.AspNetCore" Version="2.2.0" />
|
||||
<PackageReference Include="Microsoft.Azure.Cosmos" Version="3.17.0" />
|
||||
|
|
|
@ -0,0 +1,56 @@
|
|||
<?xml version="1.0"?>
|
||||
<doc>
|
||||
<assembly>
|
||||
<name>Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests</name>
|
||||
</assembly>
|
||||
<members>
|
||||
<member name="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.ActiveMQEndToEndTests">
|
||||
<summary>
|
||||
ActiveMQ end to end tests.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="F:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.ActiveMQEndToEndTests.loggerProvider">
|
||||
<summary>
|
||||
Logger provider.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.ActiveMQEndToEndTests.ActiveMQEndToEnd">
|
||||
<summary>
|
||||
ActiveMQ EndToEnd Test.
|
||||
</summary>
|
||||
<returns>A <see cref="T:System.Threading.Tasks.Task"/> representing the asynchronous unit test.</returns>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.ActiveMQEndToEndTests.StartHostAsync">
|
||||
<summary>
|
||||
Start web host.
|
||||
</summary>
|
||||
<returns>IHost task.</returns>
|
||||
</member>
|
||||
<member name="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.ActiveMQOperationsTests">
|
||||
<summary>
|
||||
ActiveMQ operation tests.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="F:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.ActiveMQOperationsTests.outputLogger">
|
||||
<summary>
|
||||
output logger for test.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.ActiveMQOperationsTests.#ctor(Xunit.Abstractions.ITestOutputHelper)">
|
||||
<summary>
|
||||
Initializes a new instance of the <see cref="T:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.ActiveMQOperationsTests"/> class.
|
||||
</summary>
|
||||
<param name="output">Output</param>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.ActiveMQOperationsTests.OperationConnectionParametersTest">
|
||||
<summary>
|
||||
Operation connection parameters test.
|
||||
</summary>
|
||||
</member>
|
||||
<member name="M:Microsoft.Azure.Workflows.ServiceProvider.Extensions.ActiveMQ.Tests.ActiveMQOperationsTests.OperationTriggerCapabilityTest">
|
||||
<summary>
|
||||
Operation connection parameters test.
|
||||
</summary>
|
||||
</member>
|
||||
</members>
|
||||
</doc>
|
Загрузка…
Ссылка в новой задаче