pax95

package test;

import static java.time.temporal.ChronoUnit.MILLIS;

import java.time.LocalDateTime;
import java.util.List;
import java.util.Optional;

public class Test {
    public static void main(String[] args) {

pax95

public class IronMqRoute extends RouteBuilder {

	@Override
	public void configure() throws Exception {
		from("file://src/test/input")
		    .to("ironmq://examplequeue?projectId=ironprojectid&token=irontoken&preserveHeaders=true");

		from("ironmq://examplequeue?projectId=ironprojectid&token=irontoken&maxMessagesPerPoll=50&preserveHeaders=true")
			.to("file://src/test/output");
	}

pax95

@Override
protected RouteBuilder createRouteBuilder() throws Exception {
    return new RouteBuilder() {
        public void configure() throws Exception {
            from("ironmq:testqueue?projectId=myproject&token=mytoken&maxMessagesPerPoll=100&wait=30&ironMQCloud=http://mq-aws-eu-west-1-1.iron.io" +
                + "&concurrentConsumers=20&batchDelete=true").to("mock:result");
            from("seda:push?concurrentConsumers=20").to("ironmq:testqueue?projectId=myproject&token=mytoken&maxMessagesPerPoll=100&ironMQCloud=http://mq-aws-eu-west-1-1.iron.io").to("mock:iron");
        }
    };
}

pax95

<row>
    <single>
      <title>Health status</title>
      <searchString>index="surveillance-status" sourcetype="drip" | sort _time | eval range=case(status == "OK", "low", status == "WARN", "guarded", status == "ERROR", "severe")</searchString>
      <earliestTime>rt-6m</earliestTime>
      <latestTime>rt</latestTime>
      <option name="classField">range</option>
      <option name="field">status</option>
      <option name="linkView">search</option>
    </single>

pax95

<mbean domain="java.lang" properties="type=OperatingSystem">
    <!-- simple attributes -->
    <attribute name="Version" outputname="version"/>
    <attribute name="TotalSwapSpaceSize" outputname="swapSpace"/>
    <attribute name="TotalPhysicalMemorySize" outputname="physMem"/>
    <attribute name="SystemLoadAverage" outputname="sysLoad"/>
    <attribute name="ProcessCpuTime" outputname="cpuTime"/>
    <attribute name="OpenFileDescriptorCount" outputname="openFD"/>
    <attribute name="Name" outputname="name"/>
    <attribute name="MaxFileDescriptorCount" outputname="maxFD"/>

pax95

<row>
    <chart>
        <title>Messages per adapter last 2 hours</title>
        <searchString>index="audit-trail" | timechart span="5m" limit=25 count(adapterName) by adapterName</searchString>
        <earliestTime>rt-2h</earliestTime>
        <latestTime>rt</latestTime>  <option name="charting.chart">area</option>
        <option name="charting.chart.nullValueMode">gaps</option>
        <option name="charting.chart.stackMode">stacked</option>
        <option name="charting.layout.splitSeries">false</option>
        <option name="charting.legend.labelStyle.overflowMode">ellipsisMiddle</option>

pax95

<route id="splunk-route">
    <from uri="seda:splunk?concurrentConsumers=5"/> 
    <!-- use a converter to convert to a SplunkEvent type -->
    <convertBodyTo type="org.apache.camel.component.splunk.event.SplunkEvent"/>
    <to uri="splunk://submit?host=splunkhost&amp;username=foo&amp;password=bar&amp;index=audit-trail&amp;sourceType=audit"/>
</route>

pax95

<route id="audit-trail-route"> 
    <from uri="hubQueue:queue:AUDIT_HUB?concurrentConsumers=5" />
    <transacted />
    <!-- convert jms payload to a jpa entity bean -->
    <bean ref="auditService" method="convertBody" />
    <to uri="jpa:org.test.AuditTrail" />
    <!-- send a copy to seda queue -->
    <to uri="seda:splunk"/>
</route>

pax95

<route id="cms-content-route">
    <from uri="drupalqueue://message_export?consumer.bridgeErrorHandler=true&amp;delay={{delay}}&amp;username={{username}}&amp;password={{password}}&amp;host={{host}}&amp;port={{port}}&amp;maxMessagesPerPoll={{maxmessagesperpoll}}&amp;keyStore={{keystore}}&amp;keyStorePassword={{keystorePW}}" />
    <filter>
        <xpath>/m_node/Content != ''</xpath>
            <idempotentConsumer eager="false" messageIdRepositoryRef="myRepo">
                <header>MESSAGE_ID</header>
                <setHeader headerName="MessageID"><simple>${header.MESSAGE_ID}</simple></setHeader>
                <to uri="hubTopic:topic:CMS_CONTENT_HUB"/>
                <to uri="direct:audit"/>                   
            </idempotentConsumer>

pax95

<route id="audit-trail-route">
	<from uri="hubQueue:queue:AUDIT_HUB?concurrentConsumers=5" />
	<transacted />
	<!-- convert jms payload to a jpa entity bean -->
	<bean ref="auditService" method="convertBody" />
	<to uri="jpa:org.test.AuditTrail" />
	<!-- send a copy to seda queue -->
	<to uri="seda:bam"/>
</route>