SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename kafka binder classes

Browse Source 
- Move pkg name to `org.springframework.cloud.stream.binder.kafka`
This commit is contained in:
Ilayaperumal Gopinathan
2015-07-21 14:29:59 -07:00
committed by Mark Fisher
parent 06190b1353
commit 46100b2f8f
8 changed files with 6 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/xd/dirt/integration/kafka/IntegerEncoderDecoder.java → spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/IntegerEncoderDecoder.java
View File

@@ -14,7 +14,7 @@
* limitations under the License.
*/
package org.springframework.xd.dirt.integration.kafka;
package org.springframework.cloud.stream.binder.kafka;
import kafka.serializer.Decoder;
import kafka.serializer.Encoder;

2
spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/xd/dirt/integration/kafka/KafkaMessageChannelBinder.java → spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
View File

@@ -14,7 +14,7 @@
* limitations under the License.
*/
package org.springframework.xd.dirt.integration.kafka;
package org.springframework.cloud.stream.binder.kafka;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;

2
spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/xd/dirt/integration/kafka/WindowingOffsetManager.java → spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/WindowingOffsetManager.java
View File

@@ -14,7 +14,7 @@
* limitations under the License.
*/
package org.springframework.xd.dirt.integration.kafka;
package org.springframework.cloud.stream.binder.kafka;
import java.io.IOException;
import java.util.Collection;

2
spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/resources/META-INF/spring-cloud-stream/binder/kafka-binder.xml
View File

@@ -11,7 +11,7 @@
</bean>
<bean id="messageBus" class="org.springframework.xd.dirt.integration.kafka.KafkaMessageChannelBinder">
<bean id="messageBus" class="org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder">
<constructor-arg ref="zookeeperConnect"/>
<constructor-arg value="${xd.messagebus.kafka.brokers}"/>
<constructor-arg value="${xd.messagebus.kafka.zkAddress}"/>

3
spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java
View File

@@ -46,11 +46,10 @@ import org.springframework.messaging.Message;
import org.springframework.cloud.stream.binder.BinderProperties;
import org.springframework.cloud.stream.binder.Binder;
import org.springframework.cloud.stream.binder.Spy;
import org.springframework.xd.dirt.integration.kafka.KafkaMessageChannelBinder;
/**
* Integration tests for the {@link org.springframework.xd.dirt.integration.kafka.KafkaMessageChannelBinder}.
* Integration tests for the {@link KafkaMessageChannelBinder}.
*
* @author Eric Bottard
* @author Marius Bogoevici

3
spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTestBinder.java
View File

@@ -21,12 +21,11 @@ import org.springframework.context.support.GenericApplicationContext;
import org.springframework.integration.kafka.support.ZookeeperConnect;
import org.springframework.xd.dirt.integration.bus.serializer.MultiTypeCodec;
import org.springframework.xd.dirt.integration.bus.serializer.kryo.PojoCodec;
import org.springframework.xd.dirt.integration.kafka.KafkaMessageChannelBinder;
import org.springframework.xd.tuple.serializer.kryo.TupleKryoRegistrar;
/**
* Test support class for {@link org.springframework.xd.dirt.integration.kafka.KafkaMessageChannelBinder}.
* Test support class for {@link KafkaMessageChannelBinder}.
* Creates a binder that uses a test {@link TestKafkaCluster kafka cluster}.
* @author Eric Bottard
* @author Marius Bogoevici

1
spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/RawModeKafkaBinderTests.java
View File

@@ -45,7 +45,6 @@ import org.springframework.messaging.support.GenericMessage;
import org.springframework.cloud.stream.binder.Binding;
import org.springframework.cloud.stream.binder.BinderProperties;
import org.springframework.cloud.stream.binder.Binder;
import org.springframework.xd.dirt.integration.kafka.KafkaMessageChannelBinder;
import org.springframework.cloud.stream.binder.TestUtils;
/**

1
spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/TestKafkaCluster.java
View File

@@ -35,7 +35,6 @@ import org.apache.curator.test.TestingServer;
import org.springframework.util.Assert;
import org.springframework.util.SocketUtils;
import org.springframework.xd.dirt.integration.kafka.KafkaMessageChannelBinder;
import java.io.IOException;
import java.util.Collections;