in src/ActiveMQ/Providers/ActiveMQTriggerServiceOperationProvider.cs [152:271]
public ActiveMQTriggerServiceOperationProvider()
{
serviceOperationsList = new List<ServiceOperation>();
apiOperationsList = new InsensitiveDictionary<ServiceOperation>();
apiOperationsList.AddRange(new InsensitiveDictionary<ServiceOperation>
{
{ "ReceiveMessagesrigger", ReceiveMessagesTrigger },
});
serviceOperationsList.AddRange(new List<ServiceOperation>
{
{
ReceiveMessagesTrigger.CloneWithManifest(new ServiceOperationManifest
{
ConnectionReference = new ConnectionReferenceFormat
{
ReferenceKeyFormat = ConnectionReferenceKeyFormat.ServiceProvider,
},
Settings = new OperationManifestSettings
{
SecureData = new OperationManifestSettingWithOptions<SecureDataOptions>(),
TrackedProperties = new OperationManifestSetting
{
Scopes = new OperationScope[] { OperationScope.Trigger },
},
},
InputsLocation = new InputsLocation[]
{
InputsLocation.Inputs,
InputsLocation.Parameters,
},
Outputs = new SwaggerSchema
{
Type = SwaggerSchemaType.Object,
Properties = new OrdinalDictionary<SwaggerSchema>
{
{
"body", new SwaggerSchema
{
Type = SwaggerSchemaType.Array,
Title = "Messages",
Description = "Receive ActiveMQ messages as array ",
Items = new SwaggerSchema
{
Type = SwaggerSchemaType.Object,
Properties = new OrdinalDictionary<SwaggerSchema>
{
{
"contentData", new SwaggerSchema
{
Type = SwaggerSchemaType.String,
Title = "Content",
Format = "byte",
Description = "content",
}
},
{
"Properties", new SwaggerSchema
{
Type = SwaggerSchemaType.Object,
Title = "Properties",
Description = "ActiveMQ messages properties",
Properties = new OrdinalDictionary<SwaggerSchema>
{
{
"NMSMessageId", new SwaggerSchema
{
Type = SwaggerSchemaType.String,
Title = "NMSMessageId",
Format = "byte",
Description = "NMSMessageId",
}
},
},
}
},
},
},
}
},
},
},
Inputs = new SwaggerSchema
{
Type = SwaggerSchemaType.Object,
Properties = new OrdinalDictionary<SwaggerSchema>
{
{
"queue", new SwaggerSchema
{
Type = SwaggerSchemaType.String,
Title = "Queue name",
Description = "Queue name",
}
},
{
"MaximumNumber", new SwaggerSchema
{
Type = SwaggerSchemaType.Number,
Title = "Maximum number of messages",
}
},
},
Required = new string[]
{
"queue",
"MaximumNumber"
},
},
Connector = ActiveMQTriggerApi,
Trigger = TriggerType.Batch,
Recurrence = new RecurrenceSetting
{
Type = RecurrenceType.Basic,
},
})
},
});
}