Skip navigation links
A C D E G K L O R S T 

A

AbstractExternalResourceTestSupport<R> - Class in org.springframework.cloud.stream.test.junit
Abstract base class for JUnit Rules that detect the presence of some external resource.
AbstractExternalResourceTestSupport(String) - Constructor for class org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport
 
apply(Statement, Description) - Method in class org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport
 

C

cleanupResource() - Method in class org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport
Perform cleanup of the AbstractExternalResourceTestSupport.resource field, which is guaranteed to be non null.
cleanupResource() - Method in class org.springframework.cloud.stream.test.junit.kafka.KafkaTestSupport
 
cleanupResource() - Method in class org.springframework.cloud.stream.test.junit.rabbit.RabbitTestSupport
 
cleanupResource() - Method in class org.springframework.cloud.stream.test.junit.redis.RedisTestSupport
 

D

defaultEmbedded - Static variable in class org.springframework.cloud.stream.test.junit.kafka.KafkaTestSupport
 

E

embedded - Variable in class org.springframework.cloud.stream.test.junit.kafka.KafkaTestSupport
 
EmbeddedZookeeper - Class in org.springframework.cloud.stream.test.junit.kafka
A port of kafka.zk.EmbeddedZookeeper, compatible with Zookeeper 3.4 API
EmbeddedZookeeper(String) - Constructor for class org.springframework.cloud.stream.test.junit.kafka.EmbeddedZookeeper
 

G

getBrokerAddress() - Method in class org.springframework.cloud.stream.test.junit.kafka.KafkaTestSupport
 
getConnectString() - Method in class org.springframework.cloud.stream.test.junit.kafka.EmbeddedZookeeper
 
getKafkaBrokerString() - Method in class org.springframework.cloud.stream.test.junit.kafka.TestKafkaCluster
 
getKafkaServer() - Method in class org.springframework.cloud.stream.test.junit.kafka.KafkaTestSupport
 
getLogDir() - Method in class org.springframework.cloud.stream.test.junit.kafka.EmbeddedZookeeper
 
getPort() - Method in class org.springframework.cloud.stream.test.junit.kafka.EmbeddedZookeeper
 
getPort() - Method in class org.springframework.cloud.stream.test.junit.rabbit.RabbitTestSupport.RabbitProxy
 
getResource() - Method in class org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport
 
getSnapshotDir() - Method in class org.springframework.cloud.stream.test.junit.kafka.EmbeddedZookeeper
 
getTickTime() - Method in class org.springframework.cloud.stream.test.junit.kafka.EmbeddedZookeeper
 
getZkClient() - Method in class org.springframework.cloud.stream.test.junit.kafka.KafkaTestSupport
 
getZkConnectString() - Method in class org.springframework.cloud.stream.test.junit.kafka.KafkaTestSupport
 
getZkConnectString() - Method in class org.springframework.cloud.stream.test.junit.kafka.TestKafkaCluster
 
getZookeeper() - Method in class org.springframework.cloud.stream.test.junit.kafka.EmbeddedZookeeper
 

K

KafkaTestSupport - Class in org.springframework.cloud.stream.test.junit.kafka
JUnit Rule that starts an embedded Kafka server (with an associated Zookeeper)
KafkaTestSupport() - Constructor for class org.springframework.cloud.stream.test.junit.kafka.KafkaTestSupport
 
KafkaTestSupport(boolean) - Constructor for class org.springframework.cloud.stream.test.junit.kafka.KafkaTestSupport
 

L

logger - Variable in class org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport
 

O

obtainResource() - Method in class org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport
Try to obtain and validate a resource.
obtainResource() - Method in class org.springframework.cloud.stream.test.junit.kafka.KafkaTestSupport
 
obtainResource() - Method in class org.springframework.cloud.stream.test.junit.rabbit.RabbitTestSupport
 
obtainResource() - Method in class org.springframework.cloud.stream.test.junit.redis.RedisTestSupport
 
org.springframework.cloud.stream.test.junit - package org.springframework.cloud.stream.test.junit
 
org.springframework.cloud.stream.test.junit.kafka - package org.springframework.cloud.stream.test.junit.kafka
 
org.springframework.cloud.stream.test.junit.rabbit - package org.springframework.cloud.stream.test.junit.rabbit
 
org.springframework.cloud.stream.test.junit.redis - package org.springframework.cloud.stream.test.junit.redis
 

R

RabbitProxy() - Constructor for class org.springframework.cloud.stream.test.junit.rabbit.RabbitTestSupport.RabbitProxy
 
RabbitTestSupport - Class in org.springframework.cloud.stream.test.junit.rabbit
JUnit Rule that detects the fact that RabbitMQ is available on localhost.
RabbitTestSupport() - Constructor for class org.springframework.cloud.stream.test.junit.rabbit.RabbitTestSupport
 
RabbitTestSupport(boolean) - Constructor for class org.springframework.cloud.stream.test.junit.rabbit.RabbitTestSupport
 
RabbitTestSupport.RabbitProxy - Class in org.springframework.cloud.stream.test.junit.rabbit
Test class to allow testing deferred entity declarations when RabbitMQ is down.
RedisTestSupport - Class in org.springframework.cloud.stream.test.junit.redis
JUnit Rule that detects the fact that a Redis server is running on localhost.
RedisTestSupport() - Constructor for class org.springframework.cloud.stream.test.junit.redis.RedisTestSupport
 
resource - Variable in class org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport
 

S

SCS_EXTERNAL_SERVERS_REQUIRED - Static variable in class org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport
 
shutdown() - Method in class org.springframework.cloud.stream.test.junit.kafka.EmbeddedZookeeper
 
start() - Method in class org.springframework.cloud.stream.test.junit.rabbit.RabbitTestSupport.RabbitProxy
 
stop() - Method in class org.springframework.cloud.stream.test.junit.kafka.TestKafkaCluster
 
stop() - Method in class org.springframework.cloud.stream.test.junit.rabbit.RabbitTestSupport.RabbitProxy
 

T

TestKafkaCluster - Class in org.springframework.cloud.stream.test.junit.kafka
A test Kafka + ZooKeeper pair for testing purposes.
TestKafkaCluster() - Constructor for class org.springframework.cloud.stream.test.junit.kafka.TestKafkaCluster
 
A C D E G K L O R S T 
Skip navigation links

Copyright © 2016 Pivotal Software, Inc.. All rights reserved.