Bilgin Ibryam bibryam

🏠

Working from home

Author of @k8spatterns | Committer @apache #Camel | Product Manager Diagrid

bibryam / RedisProducerIntegrationTest.java

Last active August 29, 2015 13:57

	package org.apache.camel.component.redis;

	import org.apache.camel.impl.JndiRegistry;
	import org.junit.Ignore;
	import org.junit.Test;
	import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
	import org.springframework.data.redis.core.RedisTemplate;

	@Ignore
	public class RedisProducerIntegrationTest extends RedisTestSupport {

bibryam / WorkflowConsumer.java

Created January 3, 2014 14:32

	package com.ofbizian.swf.demo;

	import org.apache.camel.builder.RouteBuilder;
	import org.apache.camel.component.aws.swf.SWFConstants;
	import org.apache.camel.main.Main;

	public class WorkflowConsumer {

	public static void main(String[] args) throws Exception {
	Main main = new Main();

bibryam / WorkflowProducer.java

Created January 3, 2014 14:24

	package com.ofbizian.swf.demo;

	import org.apache.camel.builder.RouteBuilder;
	import org.apache.camel.main.Main;

	public class WorkflowProducer {

	public static String COMMON_OPTIONS =
	"accessKey=XXX"
	+ "&secretKey=XXX"

bibryam / ActivityConsumer.java

Created January 3, 2014 14:23

	package com.ofbizian.swf.demo;

	import org.apache.camel.builder.RouteBuilder;
	import org.apache.camel.main.Main;

	public class ActivityConsumer {

	public static void main(String[] args) throws Exception {
	Main main = new Main();
	main.enableHangupSupport();

bibryam / ActivityWorker.java

Created December 10, 2013 00:11

AWS SWF ActivityWorker

	from("aws-swf://activity?domainName=demo&activityList=demo-activity&version=1.0&eventName=processActivities")
	.log("Received Activity task ${body}")
	.setBody(constant("1"));

bibryam / WorkflowDecider.java

Last active December 30, 2015 20:49

AWS SWF Decider

	from("aws-swf://workflow?domainName=demo&workflowList=demo-flow&version=1.0&eventName=processWorkflows")
	.log("Received a workflow task ${body}")
	.filter(header(SWFConstants.ACTION).isEqualTo(SWFConstants.EXECUTE_ACTION))
	.to("aws-swf://activity?domainName=demo&activityList=demo-activity&version=1.0&eventName=processActivities");

bibryam / WorkflowStarter.java

Last active December 30, 2015 20:49

AWS SWF Starter

	from("direct:start")
	.setHeader(SWFConstants.OPERATION, constant("START"))
	.log("Starting a workflow task ${body}")
	.to("aws-swf://workflow?domainName=demo&workflowList=demo-flow&version=1.0&eventName=processWorkflows");

bibryam / SQS-FIFO-Consumer.xml

Created September 18, 2013 22:21

SQS FIFO Consumer

	<camel:route>
	<camel:from uri="aws-sqs://{{aws.queue}}?amazonSQSClient=#amazonSQSClient"/>
	<convertBodyTo type="java.lang.Integer"/>
	<camel:to uri="log:com.ofbizian.before?level=INFO"/>

	<camel:resequence>
	<!--<camel:batch-config batchSize="100" batchTimeout="1000" />-->
	<stream-config capacity="100" timeout="1000"/>
	<camel:simple>body</camel:simple>
	<camel:to uri="log:com.ofbizian.before?level=INFO"/>

bibryam / SQS-Consumer.xml

Last active December 23, 2015 09:39

A Camel route for consuming and printing message from SQS

	<camel:route>
	<camel:from uri="aws-sqs://{{aws.queue}}?amazonSQSClient=#amazonSQSClient"/>
	<convertBodyTo type="java.lang.Integer"/>
	<camel:to uri="log:com.ofbizian.before?level=INFO"/>
	<camel:to uri="mock:result"/>
	</camel:route>

bibryam / SQS-Publish.xml

Last active December 23, 2015 09:39

A route for sending 100 messages to SQS

	<route>
	<camel:from uri="timer://publish?repeatCount=100&period=1&fixedRate=true"/>
	<setBody>
	<property>Exchange.TIMER_COUNTER</property>
	</setBody>
	<camel:to uri="aws-sqs://{{aws.queue}}?amazonSQSClient=#amazonSQSClient"/>
	</route>