diff --git a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/config/AmqpChannelFactoryBean.java b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/config/AmqpChannelFactoryBean.java
index 7d8710d4eb..3098f713d1 100644
--- a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/config/AmqpChannelFactoryBean.java
+++ b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/config/AmqpChannelFactoryBean.java
@@ -280,7 +280,7 @@ public class AmqpChannelFactoryBean extends AbstractFactoryBean<AbstractAmqpChan
 	}
 
 	public void setTxSize(int txSize) {
-		this.txSize = this.txSize;
+		this.txSize = txSize;
 	}
 
 	@Override
diff --git a/spring-integration-ws/src/main/java/org/springframework/integration/ws/MarshallingWebServiceInboundGateway.java b/spring-integration-ws/src/main/java/org/springframework/integration/ws/MarshallingWebServiceInboundGateway.java
index edf5f042f3..419db797c5 100644
--- a/spring-integration-ws/src/main/java/org/springframework/integration/ws/MarshallingWebServiceInboundGateway.java
+++ b/spring-integration-ws/src/main/java/org/springframework/integration/ws/MarshallingWebServiceInboundGateway.java
@@ -60,7 +60,7 @@ public class MarshallingWebServiceInboundGateway extends AbstractWebServiceInbou
 		Assert.isInstanceOf(Unmarshaller.class, marshaller, "When using this constructor the provided " +
 				"Marshaller must also implement Unmarshaller");
 		this.marshaller = marshaller;
-		this.unmarshaller = unmarshaller;
+		this.unmarshaller = (Unmarshaller) marshaller;
 	}
 
 	/**