garyrussell’s gists

garyrussell / Config.java

Last active June 28, 2021 01:37

Demonstration of Synchronous Transactions with Spring-AMQP

	/*
	* Copyright 2013 the original author or authors.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software

garyrussell / LocallPortTcpSocketFactorySupport.java

Created November 6, 2013 18:06

Custom Socket Factory to Configure local TCP Port Bear in mind this will fail if the port is already in use (even if it's in TIME_WAIT since the last use)

	/*
	* Copyright 2013 the original author or authors.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software

garyrussell / AggregatorTests.java

Last active December 28, 2015 08:39

SI RollingMessageStore - See http://stackoverflow.com/questions/19980413/how-to-aggrate-one-message-into-multiple-groups-by-spring-integration-aggregator Minor modification to SimpleMessageStore

	/*
	* Copyright 2002-2013 the original author or authors.
	*
	* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
	* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the

garyrussell / Foo.java

Created December 13, 2013 23:49

Example of how to unwrap a proxied Spring Integration element (in this case a QueueChannel).

	/*
	* Copyright 2013 the original author or authors.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software

garyrussell / ContainerRetryTests-context.xml

Last active December 13, 2022 19:03

Spring AMQP Container Retry Example - uses the default retry template (3 attempts and no recovery - the failed message is just logged at WARN level). Inject a `RetryTemplate` into the factory bean for more options.

 <?xml version="1.0" encoding="UTF-8"?>
 <beans xmlns="http://www.springframework.org/schema/beans"
 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xmlns:rabbit="http://www.springframework.org/schema/rabbit"
 	xsi:schemaLocation="http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.2.xsd
 		http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
 	<rabbit:connection-factory id="connectionFactory" />
 	<rabbit:template id="amqpTemplate" connection-factory="connectionFactory"

garyrussell / Gate.java

Last active August 29, 2015 13:56

Spring Boot App Using Spring Integration AMQP

	/*
	* Copyright 2014 the original author or authors.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software

garyrussell / RequestReplyFixed.java

Last active May 29, 2019 04:38

Spring Boot AMQP Reqest/Reply Example with Fixed Reply Queue

	/*
	* Copyright 2014 the original author or authors.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software

garyrussell / RabbitConsumer.java

Last active August 29, 2015 13:57

	/*
	* Copyright 2014 the original author or authors.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software

garyrussell / Groovy.java

Last active August 29, 2015 13:57

Spring Integration Groovy DSL and Spring Boot

	/*
	* Copyright 2014 the original author or authors.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software

garyrussell / JmsRequestReply.java

Created May 7, 2014 14:58

JMS Outbound Gateway Spring Boot App

	/*
	* Copyright 2014 the original author or authors.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software

Gary Russell garyrussell