scott-kloud

0x153f33eB318f25a1C7BFA376D10158540CE7c12D

scott-kloud

// Load our retry handler helper
#load "retryhandler.csx"

#r "Microsoft.ServiceBus"
using Microsoft.ServiceBus.Messaging;

using System;
using System.Threading.Tasks;

public static void Run(BrokeredMessage mySbMsg, TraceWriter log)

scott-kloud

#r "Microsoft.ServiceBus"
using Microsoft.ServiceBus.Messaging;

using System;
using System.Threading.Tasks;

public static void RetryHandler(BrokeredMessage mySbMsg, Exception ex, TraceWriter log)
{
    RetryPolicy policy;

scott-kloud

#r "Microsoft.ServiceBus"
using Microsoft.ServiceBus.Messaging;

using System;
using System.Threading.Tasks;

public static void Run(BrokeredMessage mySbMsg, TraceWriter log)
{

    log.Info($"C# ServiceBus topic trigger function received message id: {mySbMsg.MessageId} Retry attempt: {mySbMsg.DeliveryCount}");

scott-kloud

#r "Microsoft.ServiceBus"
using Microsoft.ServiceBus.Messaging;

using System;
using System.Threading.Tasks;

public static void Run(BrokeredMessage mySbMsg, TraceWriter log)
{

    log.Info($"C# ServiceBus topic trigger function received message id: {mySbMsg.MessageId}");

scott-kloud

#r "Microsoft.ServiceBus"
using Microsoft.ServiceBus.Messaging;

using System;
using System.Threading.Tasks;

public static void Run(BrokeredMessage mySbMsg, TraceWriter log)
{
    log.Info($"C# ServiceBus topic trigger function processed message id: {mySbMsg.MessageId}");
}

scott-kloud

#r "System.ServiceModel"
#r "Blog.Apr2017.TimeMachineServiceClient.dll"

using System;

using System.ServiceModel;
using System.ServiceModel.Channels;

using Blog.Apr2017.TimeMachineServiceClient.TimeMachineService;

scott-kloud

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:batch="http://www.mulesoft.org/schema/mule/batch" xmlns:s3="http://www.mulesoft.org/schema/mule/s3" xmlns:json="http://www.mulesoft.org/schema/mule/json" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:cloudhub="http://www.mulesoft.org/schema/mule/cloudhub" xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
	xmlns:spring="http://www.springframework.org/schema/beans" 
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/s

scott-kloud

<sub-flow name="cloudhubDeployments">
    <set-payload value="{}" mimeType="application/json" doc:name="Set Payload"/>
    <http:request config-ref="CloudHub_Config" path="/v2/applications/{domain}/deployments" method="GET" doc:name="HTTP">
        <http:request-builder>
            <http:uri-param paramName="domain" value="#[flowVars.config.anypointApplication]"/>
            <http:header headerName="X-ANYPNT-ENV-ID" value="#[flowVars.config.anypointEnvironmentId]"/>
            <http:header headerName="Authorization" value="#['Bearer ' + flowVars.access_token]"/>
        </http:request-builder>
    </http:request>
    <json:json-to-object-transformer doc:name="JSON to Object" returnClass="java.util.HashMap"/>

scott-kloud

<sub-flow name="cloudhubLogFiles">
    <set-payload value="{}" mimeType="application/json" doc:name="Set Payload"/>
    <http:request config-ref="CloudHub_Config" path="/v2/applications/{domain}/instances/{instanceId}/log-file" method="GET" doc:name="HTTP">
        <http:request-builder>
            <http:uri-param paramName="domain" value="#[flowVars.config.anypointApplication]"/>
            <http:uri-param paramName="instanceId" value="#[flowVars.instanceId]"/>
            <http:header headerName="X-ANYPNT-ENV-ID" value="#[flowVars.config.anypointEnvironmentId]"/>
            <http:header headerName="Authorization" value="#['Bearer ' + flowVars.access_token]"/>
        </http:request-builder>
    </http:request>