You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2016/04/18 13:40:22 UTC
[16/20] camel git commit: Delete all the old karaf osgi tests that do
not work. We should use the new camel-test-karaf module as base for testing.
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/OSGiIntegrationSpringTestSupport.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/OSGiIntegrationSpringTestSupport.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/OSGiIntegrationSpringTestSupport.java
deleted file mode 100644
index 8de7f9c..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/OSGiIntegrationSpringTestSupport.java
+++ /dev/null
@@ -1,42 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spring.SpringCamelContext;
-import org.springframework.osgi.context.support.OsgiBundleXmlApplicationContext;
-
-public abstract class OSGiIntegrationSpringTestSupport extends OSGiIntegrationTestSupport {
- protected OsgiBundleXmlApplicationContext applicationContext;
- protected abstract OsgiBundleXmlApplicationContext createApplicationContext();
-
- @Override
- protected CamelContext createCamelContext() throws Exception {
- setThreadContextClassLoader();
- applicationContext = createApplicationContext();
- assertNotNull("Should have created a valid spring context", applicationContext);
- applicationContext.setBundleContext(bundleContext);
- applicationContext.refresh();
- String[] names = applicationContext.getBeanNamesForType(SpringCamelContext.class);
- if (names.length == 1) {
- return applicationContext.getBean(names[0], SpringCamelContext.class);
- } else {
- throw new IllegalStateException("Exactly 1 bean of type SpringCamelContext expected but found " + names.length + " beans.");
- }
- }
-
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/OSGiIntegrationTestSupport.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/OSGiIntegrationTestSupport.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/OSGiIntegrationTestSupport.java
deleted file mode 100644
index a9fce54..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/OSGiIntegrationTestSupport.java
+++ /dev/null
@@ -1,216 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi;
-import java.io.File;
-import java.io.InputStream;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Properties;
-import java.util.concurrent.atomic.AtomicInteger;
-
-import javax.inject.Inject;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.osgi.CamelContextFactory;
-import org.apache.camel.test.junit4.CamelTestSupport;
-import org.ops4j.pax.exam.Configuration;
-import org.ops4j.pax.exam.Option;
-import org.ops4j.pax.exam.karaf.options.KarafDistributionOption;
-import org.ops4j.pax.exam.karaf.options.LogLevelOption;
-import org.ops4j.pax.exam.options.MavenArtifactProvisionOption;
-import org.ops4j.pax.exam.options.UrlReference;
-import org.osgi.framework.Bundle;
-import org.osgi.framework.BundleContext;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import static org.ops4j.pax.exam.CoreOptions.maven;
-import static org.ops4j.pax.exam.CoreOptions.mavenBundle;
-import static org.ops4j.pax.exam.OptionUtils.combine;
-
-public class OSGiIntegrationTestSupport extends CamelTestSupport {
- protected static final Logger LOG = LoggerFactory.getLogger(OSGiIntegrationTestSupport.class);
- protected static final AtomicInteger COUNTER = new AtomicInteger();
- protected static String workDir = "target/paxrunner/";
- @Inject
- protected BundleContext bundleContext;
-
- protected Bundle getInstalledBundle(String symbolicName) {
- for (Bundle b : bundleContext.getBundles()) {
- if (b.getSymbolicName().equals(symbolicName)) {
- return b;
- }
- }
- for (Bundle b : bundleContext.getBundles()) {
- LOG.warn("Bundle: " + b.getSymbolicName());
- }
- throw new RuntimeException("Bundle " + symbolicName + " does not exist");
- }
-
- protected CamelContext createCamelContext() throws Exception {
- LOG.info("Get the bundleContext is " + bundleContext);
- LOG.info("Application installed as bundle id: " + bundleContext.getBundle().getBundleId());
-
- setThreadContextClassLoader();
-
- CamelContextFactory factory = new CamelContextFactory();
- factory.setBundleContext(bundleContext);
- factory.setRegistry(createRegistry());
- return factory.createContext();
- }
-
- protected void setThreadContextClassLoader() {
- // set the thread context classloader current bundle classloader
- Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());
- }
-
- public static UrlReference getCamelKarafFeatureUrl() {
- return getCamelKarafFeatureUrl(null);
- }
-
- public static MavenArtifactProvisionOption getJUnitBundle() {
- MavenArtifactProvisionOption mavenOption = mavenBundle().groupId("org.apache.servicemix.bundles")
- .artifactId("org.apache.servicemix.bundles.junit");
- mavenOption.versionAsInProject().start(true).startLevel(10);
- return mavenOption;
- }
-
- public static UrlReference getCamelKarafFeatureUrl(String version) {
- String type = "xml/features";
- MavenArtifactProvisionOption mavenOption = mavenBundle().groupId("org.apache.camel.karaf").artifactId("apache-camel");
- if (version == null) {
- return mavenOption.versionAsInProject().type(type);
- } else {
- return mavenOption.version(version).type(type);
- }
- }
-
- public static UrlReference getKarafFeatureUrl() {
- String karafVersion = System.getProperty("karafVersion");
- LOG.info("*** The karaf version is " + karafVersion + " ***");
-
- String type = "xml/features";
- return mavenBundle().groupId("org.apache.karaf.assemblies.features").
- artifactId("standard").version(karafVersion).type(type);
- }
-
- public static UrlReference getKarafEnterpriseFeatureUrl() {
- String karafVersion = System.getProperty("karafVersion");
- LOG.info("*** The karaf version is " + karafVersion + " ***");
-
- String type = "xml/features";
- return mavenBundle().groupId("org.apache.karaf.assemblies.features").
- artifactId("enterprise").version(karafVersion).type(type);
- }
-
- public static Option loadCamelFeatures(String... features) {
-
- List<String> result = new ArrayList<String>();
- result.add("cxf-jaxb");
- result.add("camel-core");
- result.add("camel-spring");
- result.add("camel-test");
- for (String feature : features) {
- result.add(feature);
- }
- return scanFeatures(getCamelKarafFeatureUrl(), result.toArray(new String[4 + features.length]));
- }
- public static Option scanFeatures(UrlReference ref, String ... features) {
- return KarafDistributionOption.features(ref, features);
- }
- public static Option scanFeatures(String ref, String ... features) {
- return KarafDistributionOption.features(ref, features);
- }
- public static Option felix() {
- return KarafDistributionOption.editConfigurationFileExtend("etc/config.properties",
- "karaf.framework",
- "felix");
- }
- public static Option equinox() {
- return KarafDistributionOption.editConfigurationFileExtend("etc/config.properties",
- "karaf.framework",
- "equinox");
- }
-
- private static String getKarafVersion() {
- InputStream ins = OSGiIntegrationTestSupport.class.getResourceAsStream("/META-INF/maven/dependencies.properties");
- Properties p = new Properties();
- try {
- p.load(ins);
- } catch (Throwable t) {
- //
- }
- String karafVersion = p.getProperty("org.apache.karaf/apache-karaf/version");
- if (karafVersion == null) {
- karafVersion = System.getProperty("karafVersion");
- }
- if (karafVersion == null) {
- // setup the default version of it
- karafVersion = "2.4.4";
- }
- return karafVersion;
- }
-
- public static Option[] getDefaultCamelKarafOptions() {
- String karafVersion = getKarafVersion();
- LOG.info("*** The karaf version is " + karafVersion + " ***");
-
- Option[] options =
- // Set the karaf environment with some customer configuration
- new Option[] {
- // for remote debugging
- //org.ops4j.pax.exam.CoreOptions.vmOption("-Xdebug"),
- //org.ops4j.pax.exam.CoreOptions.vmOption("-Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=5008"),
-
- KarafDistributionOption.karafDistributionConfiguration()
- .frameworkUrl(maven().groupId("org.apache.karaf")
- .artifactId("apache-karaf").type("tar.gz").versionAsInProject())
- .karafVersion(karafVersion)
- .name("Apache Karaf")
- .useDeployFolder(false)
- .unpackDirectory(new File("target/paxexam/unpack/")),
-
- //KarafDistributionOption.keepRuntimeFolder(),
- // override the config.properties (to fix pax-exam bug)
- // KarafDistributionOption.replaceConfigurationFile("etc/config.properties", new File("src/test/resources/org/apache/camel/itest/karaf/config.properties")),
- // Need to override the jre setting
- KarafDistributionOption.replaceConfigurationFile("etc/jre.properties", new File("src/test/resources/org/apache/camel/itest/karaf/jre.properties")),
- KarafDistributionOption.replaceConfigurationFile("etc/custom.properties", new File("src/test/resources/org/apache/camel/itest/karaf/custom.properties")),
- KarafDistributionOption.replaceConfigurationFile("etc/org.ops4j.pax.url.mvn.cfg", new File("src/test/resources/org/apache/camel/itest/karaf/org.ops4j.pax.url.mvn.cfg")),
-
- //Grab JUnit and put it very early in the startup to make sure any bundles that are loaded
- //will use the same version/bundle
- getJUnitBundle(),
- // we need INFO logging otherwise we cannot see what happens
- new LogLevelOption(LogLevelOption.LogLevel.INFO),
- // install the cxf jaxb spec as the karaf doesn't provide it by default
- scanFeatures(getCamelKarafFeatureUrl(), "cxf-jaxb", "camel-core", "camel-spring", "camel-test")};
-
- return options;
-
- }
-
- @Configuration
- public static Option[] configure() throws Exception {
- Option[] options = combine(
- getDefaultCamelKarafOptions()
- );
-
- return options;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/ahc/AhcTest.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/ahc/AhcTest.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/ahc/AhcTest.java
deleted file mode 100644
index f9ea05b..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/ahc/AhcTest.java
+++ /dev/null
@@ -1,77 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi.ahc;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.itest.osgi.OSGiIntegrationTestSupport;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.ops4j.pax.exam.Configuration;
-import org.ops4j.pax.exam.Option;
-import org.ops4j.pax.exam.junit.PaxExam;
-import org.ops4j.pax.exam.spi.reactors.ExamReactorStrategy;
-import org.ops4j.pax.exam.spi.reactors.PerMethod;
-
-import static org.ops4j.pax.exam.OptionUtils.combine;
-/**
- *
- */
-@RunWith(PaxExam.class)
-@ExamReactorStrategy(PerMethod.class)
-public class AhcTest extends OSGiIntegrationTestSupport {
-
- @Test
- public void testAhcGet() throws Exception {
- String reply = template.requestBody("ahc:http://localhost:9081/foo", null, String.class);
- assertEquals("Bye World", reply);
- }
-
- @Test
- public void testAhcPost() throws Exception {
- String reply = template.requestBody("ahc:http://localhost:9081/foo", "Hello World", String.class);
- assertEquals("Bye World", reply);
- }
-
- @Test
- @Ignore("Requires online internet for testing")
- public void testAhcGoogle() throws Exception {
- String reply = template.requestBody("ahc:http://www.google.se", null, String.class);
- assertNotNull(reply);
- log.info(reply);
- }
-
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("jetty:http://0.0.0.0:9081/foo")
- .transform(constant("Bye World"));
- }
- };
- }
-
- @Configuration
- public static Option[] configure() throws Exception {
- Option[] options = combine(
- getDefaultCamelKarafOptions(),
- // using the features to install other camel components
- loadCamelFeatures("camel-jetty", "camel-ahc"));
- return options;
- }
-
-
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonS3ClientMock.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonS3ClientMock.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonS3ClientMock.java
deleted file mode 100644
index 4c46eeb..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonS3ClientMock.java
+++ /dev/null
@@ -1,423 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi.aws;
-
-import java.io.File;
-import java.io.InputStream;
-import java.net.URL;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-
-import com.amazonaws.AmazonClientException;
-import com.amazonaws.AmazonServiceException;
-import com.amazonaws.AmazonWebServiceRequest;
-import com.amazonaws.HttpMethod;
-import com.amazonaws.auth.BasicAWSCredentials;
-import com.amazonaws.services.s3.AmazonS3Client;
-import com.amazonaws.services.s3.S3ResponseMetadata;
-import com.amazonaws.services.s3.model.AbortMultipartUploadRequest;
-import com.amazonaws.services.s3.model.AccessControlList;
-import com.amazonaws.services.s3.model.Bucket;
-import com.amazonaws.services.s3.model.BucketLoggingConfiguration;
-import com.amazonaws.services.s3.model.BucketNotificationConfiguration;
-import com.amazonaws.services.s3.model.BucketPolicy;
-import com.amazonaws.services.s3.model.BucketVersioningConfiguration;
-import com.amazonaws.services.s3.model.CannedAccessControlList;
-import com.amazonaws.services.s3.model.CompleteMultipartUploadRequest;
-import com.amazonaws.services.s3.model.CompleteMultipartUploadResult;
-import com.amazonaws.services.s3.model.CopyObjectRequest;
-import com.amazonaws.services.s3.model.CopyObjectResult;
-import com.amazonaws.services.s3.model.CreateBucketRequest;
-import com.amazonaws.services.s3.model.DeleteBucketRequest;
-import com.amazonaws.services.s3.model.DeleteObjectRequest;
-import com.amazonaws.services.s3.model.DeleteVersionRequest;
-import com.amazonaws.services.s3.model.GeneratePresignedUrlRequest;
-import com.amazonaws.services.s3.model.GetObjectMetadataRequest;
-import com.amazonaws.services.s3.model.GetObjectRequest;
-import com.amazonaws.services.s3.model.InitiateMultipartUploadRequest;
-import com.amazonaws.services.s3.model.InitiateMultipartUploadResult;
-import com.amazonaws.services.s3.model.ListBucketsRequest;
-import com.amazonaws.services.s3.model.ListMultipartUploadsRequest;
-import com.amazonaws.services.s3.model.ListObjectsRequest;
-import com.amazonaws.services.s3.model.ListPartsRequest;
-import com.amazonaws.services.s3.model.ListVersionsRequest;
-import com.amazonaws.services.s3.model.MultipartUploadListing;
-import com.amazonaws.services.s3.model.ObjectListing;
-import com.amazonaws.services.s3.model.ObjectMetadata;
-import com.amazonaws.services.s3.model.Owner;
-import com.amazonaws.services.s3.model.PartListing;
-import com.amazonaws.services.s3.model.PutObjectRequest;
-import com.amazonaws.services.s3.model.PutObjectResult;
-import com.amazonaws.services.s3.model.Region;
-import com.amazonaws.services.s3.model.S3Object;
-import com.amazonaws.services.s3.model.S3ObjectSummary;
-import com.amazonaws.services.s3.model.SetBucketLoggingConfigurationRequest;
-import com.amazonaws.services.s3.model.SetBucketVersioningConfigurationRequest;
-import com.amazonaws.services.s3.model.StorageClass;
-import com.amazonaws.services.s3.model.UploadPartRequest;
-import com.amazonaws.services.s3.model.UploadPartResult;
-import com.amazonaws.services.s3.model.VersionListing;
-
-public class AmazonS3ClientMock extends AmazonS3Client {
-
- List<S3Object> objects = new ArrayList<S3Object>();
-
- public AmazonS3ClientMock() {
- super(new BasicAWSCredentials("myAccessKey", "mySecretKey"));
- }
-
- @Override
- public VersionListing listNextBatchOfVersions(VersionListing previousVersionListing) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public VersionListing listVersions(String bucketName, String prefix) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public VersionListing listVersions(String bucketName, String prefix, String keyMarker, String versionIdMarker, String delimiter, Integer maxKeys)
- throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public VersionListing listVersions(ListVersionsRequest listVersionsRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ObjectListing listObjects(String bucketName) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ObjectListing listObjects(String bucketName, String prefix) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ObjectListing listObjects(ListObjectsRequest listObjectsRequest) throws AmazonClientException, AmazonServiceException {
- ObjectListing objectListing = new ObjectListing();
- int capacity = listObjectsRequest.getMaxKeys();
-
- for (int index = 0; index < objects.size() && index < capacity; index++) {
- S3ObjectSummary s3ObjectSummary = new S3ObjectSummary();
- s3ObjectSummary.setBucketName(objects.get(index).getBucketName());
- s3ObjectSummary.setKey(objects.get(index).getKey());
-
- objectListing.getObjectSummaries().add(s3ObjectSummary);
- }
-
- return objectListing;
- }
-
- @Override
- public ObjectListing listNextBatchOfObjects(ObjectListing previousObjectListing) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Owner getS3AccountOwner() throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public List<Bucket> listBuckets(ListBucketsRequest listBucketsRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public List<Bucket> listBuckets() throws AmazonClientException, AmazonServiceException {
- return new ArrayList<Bucket>();
- }
-
- @Override
- public String getBucketLocation(String bucketName) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Bucket createBucket(String bucketName) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Bucket createBucket(String bucketName, Region region) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Bucket createBucket(String bucketName, String region) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Bucket createBucket(CreateBucketRequest createBucketRequest) throws AmazonClientException, AmazonServiceException {
- Bucket bucket = new Bucket();
- bucket.setName(createBucketRequest.getBucketName());
- bucket.setCreationDate(new Date());
- bucket.setOwner(new Owner("c2efc7302b9011ba9a78a92ac5fd1cd47b61790499ab5ddf5a37c31f0638a8fc ", "Christian Mueller"));
- return bucket;
- }
-
- @Override
- public AccessControlList getObjectAcl(String bucketName, String key) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public AccessControlList getObjectAcl(String bucketName, String key, String versionId) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setObjectAcl(String bucketName, String key, AccessControlList acl) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setObjectAcl(String bucketName, String key, CannedAccessControlList acl) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setObjectAcl(String bucketName, String key, String versionId, AccessControlList acl) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setObjectAcl(String bucketName, String key, String versionId, CannedAccessControlList acl) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public AccessControlList getBucketAcl(String bucketName) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setBucketAcl(String bucketName, AccessControlList acl) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setBucketAcl(String bucketName, CannedAccessControlList acl) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ObjectMetadata getObjectMetadata(String bucketName, String key) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ObjectMetadata getObjectMetadata(GetObjectMetadataRequest getObjectMetadataRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public S3Object getObject(String bucketName, String key) throws AmazonClientException, AmazonServiceException {
- for (S3Object s3Object : objects) {
- if (bucketName.equals(s3Object.getBucketName()) && key.equals(s3Object.getKey())) {
- return s3Object;
- }
- }
-
- return null;
- }
-
- @Override
- public boolean doesBucketExist(String bucketName) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void changeObjectStorageClass(String bucketName, String key, StorageClass newStorageClass) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public S3Object getObject(GetObjectRequest getObjectRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ObjectMetadata getObject(GetObjectRequest getObjectRequest, File destinationFile) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void deleteBucket(String bucketName) throws AmazonClientException, AmazonServiceException {
- // noop
- }
-
- @Override
- public void deleteBucket(DeleteBucketRequest deleteBucketRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public PutObjectResult putObject(String bucketName, String key, File file) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public PutObjectResult putObject(String bucketName, String key, InputStream input, ObjectMetadata metadata) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public PutObjectResult putObject(PutObjectRequest putObjectRequest) throws AmazonClientException, AmazonServiceException {
- S3Object s3Object = new S3Object();
- s3Object.setBucketName(putObjectRequest.getBucketName());
- s3Object.setKey(putObjectRequest.getKey());
- s3Object.setObjectContent(putObjectRequest.getInputStream());
- objects.add(s3Object);
-
- PutObjectResult putObjectResult = new PutObjectResult();
- putObjectResult.setETag("3a5c8b1ad448bca04584ecb55b836264");
- return putObjectResult;
- }
-
- @Override
- public CopyObjectResult copyObject(String sourceBucketName, String sourceKey, String destinationBucketName, String destinationKey) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public CopyObjectResult copyObject(CopyObjectRequest copyObjectRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void deleteObject(String bucketName, String key) throws AmazonClientException, AmazonServiceException {
- //noop
- }
-
- @Override
- public void deleteObject(DeleteObjectRequest deleteObjectRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void deleteVersion(String bucketName, String key, String versionId) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void deleteVersion(DeleteVersionRequest deleteVersionRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setBucketVersioningConfiguration(SetBucketVersioningConfigurationRequest setBucketVersioningConfigurationRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public BucketVersioningConfiguration getBucketVersioningConfiguration(String bucketName) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setBucketNotificationConfiguration(String bucketName, BucketNotificationConfiguration bucketNotificationConfiguration) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public BucketNotificationConfiguration getBucketNotificationConfiguration(String bucketName) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public BucketLoggingConfiguration getBucketLoggingConfiguration(String bucketName) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setBucketLoggingConfiguration(SetBucketLoggingConfigurationRequest setBucketLoggingConfigurationRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public BucketPolicy getBucketPolicy(String bucketName) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setBucketPolicy(String bucketName, String policyText) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void deleteBucketPolicy(String bucketName) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public URL generatePresignedUrl(String bucketName, String key, Date expiration) throws AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public URL generatePresignedUrl(String bucketName, String key, Date expiration, HttpMethod method) throws AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public URL generatePresignedUrl(GeneratePresignedUrlRequest generatePresignedUrlRequest) throws AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void abortMultipartUpload(AbortMultipartUploadRequest abortMultipartUploadRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public CompleteMultipartUploadResult completeMultipartUpload(CompleteMultipartUploadRequest completeMultipartUploadRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public InitiateMultipartUploadResult initiateMultipartUpload(InitiateMultipartUploadRequest initiateMultipartUploadRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public MultipartUploadListing listMultipartUploads(ListMultipartUploadsRequest listMultipartUploadsRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public PartListing listParts(ListPartsRequest listPartsRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public UploadPartResult uploadPart(UploadPartRequest uploadPartRequest) throws AmazonClientException, AmazonServiceException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public S3ResponseMetadata getCachedResponseMetadata(AmazonWebServiceRequest request) {
- throw new UnsupportedOperationException();
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSDBClientMock.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSDBClientMock.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSDBClientMock.java
deleted file mode 100644
index 2cbc91e..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSDBClientMock.java
+++ /dev/null
@@ -1,142 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi.aws;
-
-import com.amazonaws.AmazonClientException;
-import com.amazonaws.AmazonServiceException;
-import com.amazonaws.auth.BasicAWSCredentials;
-import com.amazonaws.services.simpledb.AmazonSimpleDBClient;
-import com.amazonaws.services.simpledb.model.Attribute;
-import com.amazonaws.services.simpledb.model.BatchDeleteAttributesRequest;
-import com.amazonaws.services.simpledb.model.BatchPutAttributesRequest;
-import com.amazonaws.services.simpledb.model.CreateDomainRequest;
-import com.amazonaws.services.simpledb.model.DeleteAttributesRequest;
-import com.amazonaws.services.simpledb.model.DeleteDomainRequest;
-import com.amazonaws.services.simpledb.model.DomainMetadataRequest;
-import com.amazonaws.services.simpledb.model.DomainMetadataResult;
-import com.amazonaws.services.simpledb.model.GetAttributesRequest;
-import com.amazonaws.services.simpledb.model.GetAttributesResult;
-import com.amazonaws.services.simpledb.model.Item;
-import com.amazonaws.services.simpledb.model.ListDomainsRequest;
-import com.amazonaws.services.simpledb.model.ListDomainsResult;
-import com.amazonaws.services.simpledb.model.NoSuchDomainException;
-import com.amazonaws.services.simpledb.model.PutAttributesRequest;
-import com.amazonaws.services.simpledb.model.SelectRequest;
-import com.amazonaws.services.simpledb.model.SelectResult;
-
-public class AmazonSDBClientMock extends AmazonSimpleDBClient {
-
- protected BatchDeleteAttributesRequest batchDeleteAttributesRequest;
- protected BatchPutAttributesRequest batchPutAttributesRequest;
- protected CreateDomainRequest createDomainRequest;
- protected DeleteAttributesRequest deleteAttributesRequest;
- protected DeleteDomainRequest deleteDomainRequest;
- protected DomainMetadataRequest domainMetadataRequest;
- protected GetAttributesRequest getAttributesRequest;
- protected ListDomainsRequest listDomainsRequest;
- protected PutAttributesRequest putAttributesRequest;
- protected SelectRequest selectRequest;
-
- public AmazonSDBClientMock() {
- super(new BasicAWSCredentials("user", "secret"));
- }
-
- @Override
- public void batchDeleteAttributes(BatchDeleteAttributesRequest batchDeleteAttributesRequest) throws AmazonServiceException, AmazonClientException {
- this.batchDeleteAttributesRequest = batchDeleteAttributesRequest;
- }
-
- @Override
- public void batchPutAttributes(BatchPutAttributesRequest batchPutAttributesRequest) throws AmazonServiceException, AmazonClientException {
- this.batchPutAttributesRequest = batchPutAttributesRequest;
- }
-
- @Override
- public void createDomain(CreateDomainRequest createDomainRequest) throws AmazonServiceException, AmazonClientException {
- this.createDomainRequest = createDomainRequest;
- }
-
- @Override
- public void deleteAttributes(DeleteAttributesRequest deleteAttributesRequest) throws AmazonServiceException, AmazonClientException {
- this.deleteAttributesRequest = deleteAttributesRequest;
-
- String domainName = deleteAttributesRequest.getDomainName();
- if ("MissingDomain".equals(domainName)) {
- throw new NoSuchDomainException(domainName);
- }
- }
-
- @Override
- public void deleteDomain(DeleteDomainRequest deleteDomainRequest) throws AmazonServiceException, AmazonClientException {
- this.deleteDomainRequest = deleteDomainRequest;
- }
-
- @Override
- public DomainMetadataResult domainMetadata(DomainMetadataRequest domainMetadataRequest) throws AmazonServiceException, AmazonClientException {
- this.domainMetadataRequest = domainMetadataRequest;
-
- if ("NonExistingDomain".equals(domainMetadataRequest.getDomainName())) {
- throw new NoSuchDomainException("Domain 'NonExistingDomain' doesn't exist.");
- }
-
- DomainMetadataResult result = new DomainMetadataResult();
- result.setTimestamp(new Integer(10));
- result.setItemCount(new Integer(11));
- result.setAttributeNameCount(new Integer(12));
- result.setAttributeValueCount(new Integer(13));
- result.setAttributeNamesSizeBytes(new Long(1000000));
- result.setAttributeValuesSizeBytes(new Long(2000000));
- result.setItemNamesSizeBytes(new Long(3000000));
- return result;
- }
-
- @Override
- public GetAttributesResult getAttributes(GetAttributesRequest getAttributesRequest) throws AmazonServiceException, AmazonClientException {
- this.getAttributesRequest = getAttributesRequest;
-
- return new GetAttributesResult()
- .withAttributes(new Attribute("AttributeOne", "Value One"))
- .withAttributes(new Attribute("AttributeTwo", "Value Two"));
- }
-
- @Override
- public ListDomainsResult listDomains(ListDomainsRequest listDomainsRequest) throws AmazonServiceException, AmazonClientException {
- this.listDomainsRequest = listDomainsRequest;
-
- ListDomainsResult result = new ListDomainsResult();
- result.getDomainNames().add("DOMAIN1");
- result.getDomainNames().add("DOMAIN2");
- result.setNextToken("TOKEN2");
- return result;
- }
-
- @Override
- public void putAttributes(PutAttributesRequest putAttributesRequest) throws AmazonServiceException, AmazonClientException {
- this.putAttributesRequest = putAttributesRequest;
- }
-
- @Override
- public SelectResult select(SelectRequest selectRequest) throws AmazonServiceException, AmazonClientException {
- this.selectRequest = selectRequest;
-
- SelectResult result = new SelectResult();
- result.setNextToken("TOKEN2");
- result.getItems().add(new Item("ITEM1", null));
- result.getItems().add(new Item("ITEM2", null));
- return result;
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSESClientMock.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSESClientMock.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSESClientMock.java
deleted file mode 100644
index 2d83424..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSESClientMock.java
+++ /dev/null
@@ -1,45 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi.aws;
-
-import com.amazonaws.AmazonClientException;
-import com.amazonaws.AmazonServiceException;
-import com.amazonaws.auth.BasicAWSCredentials;
-import com.amazonaws.services.simpleemail.AmazonSimpleEmailServiceClient;
-import com.amazonaws.services.simpleemail.model.SendEmailRequest;
-import com.amazonaws.services.simpleemail.model.SendEmailResult;
-
-public class AmazonSESClientMock extends AmazonSimpleEmailServiceClient {
- private SendEmailRequest sendEmailRequest;
-
- public AmazonSESClientMock() {
- super(new BasicAWSCredentials("myAccessKey", "mySecretKey"));
- }
-
- @Override
- public SendEmailResult sendEmail(SendEmailRequest sendEmailRequest) throws AmazonServiceException, AmazonClientException {
- this.sendEmailRequest = sendEmailRequest;
- SendEmailResult result = new SendEmailResult();
- result.setMessageId("1");
-
- return result;
- }
-
- public SendEmailRequest getSendEmailRequest() {
- return sendEmailRequest;
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSNSClientMock.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSNSClientMock.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSNSClientMock.java
deleted file mode 100644
index e2ee427..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSNSClientMock.java
+++ /dev/null
@@ -1,136 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi.aws;
-
-import com.amazonaws.AmazonClientException;
-import com.amazonaws.AmazonServiceException;
-import com.amazonaws.AmazonWebServiceRequest;
-import com.amazonaws.ResponseMetadata;
-import com.amazonaws.auth.BasicAWSCredentials;
-import com.amazonaws.services.sns.AmazonSNSClient;
-import com.amazonaws.services.sns.model.AddPermissionRequest;
-import com.amazonaws.services.sns.model.ConfirmSubscriptionRequest;
-import com.amazonaws.services.sns.model.ConfirmSubscriptionResult;
-import com.amazonaws.services.sns.model.CreateTopicRequest;
-import com.amazonaws.services.sns.model.CreateTopicResult;
-import com.amazonaws.services.sns.model.DeleteTopicRequest;
-import com.amazonaws.services.sns.model.GetTopicAttributesRequest;
-import com.amazonaws.services.sns.model.GetTopicAttributesResult;
-import com.amazonaws.services.sns.model.ListSubscriptionsByTopicRequest;
-import com.amazonaws.services.sns.model.ListSubscriptionsByTopicResult;
-import com.amazonaws.services.sns.model.ListSubscriptionsRequest;
-import com.amazonaws.services.sns.model.ListSubscriptionsResult;
-import com.amazonaws.services.sns.model.ListTopicsRequest;
-import com.amazonaws.services.sns.model.ListTopicsResult;
-import com.amazonaws.services.sns.model.PublishRequest;
-import com.amazonaws.services.sns.model.PublishResult;
-import com.amazonaws.services.sns.model.RemovePermissionRequest;
-import com.amazonaws.services.sns.model.SetTopicAttributesRequest;
-import com.amazonaws.services.sns.model.SubscribeRequest;
-import com.amazonaws.services.sns.model.SubscribeResult;
-import com.amazonaws.services.sns.model.UnsubscribeRequest;
-
-public class AmazonSNSClientMock extends AmazonSNSClient {
-
- public AmazonSNSClientMock() {
- super(new BasicAWSCredentials("myAccessKey", "mySecretKey"));
- }
-
- @Override
- public ConfirmSubscriptionResult confirmSubscription(ConfirmSubscriptionRequest confirmSubscriptionRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public GetTopicAttributesResult getTopicAttributes(GetTopicAttributesRequest getTopicAttributesRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public SubscribeResult subscribe(SubscribeRequest subscribeRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setTopicAttributes(SetTopicAttributesRequest setTopicAttributesRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void deleteTopic(DeleteTopicRequest deleteTopicRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void removePermission(RemovePermissionRequest removePermissionRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ListSubscriptionsResult listSubscriptions(ListSubscriptionsRequest listSubscriptionsRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void addPermission(AddPermissionRequest addPermissionRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public CreateTopicResult createTopic(CreateTopicRequest createTopicRequest) throws AmazonServiceException, AmazonClientException {
- CreateTopicResult createTopicResult = new CreateTopicResult();
- createTopicResult.setTopicArn("arn:aws:sns:us-east-1:541925086079:MyTopic");
- return createTopicResult;
- }
-
- @Override
- public ListTopicsResult listTopics(ListTopicsRequest listTopicsRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void unsubscribe(UnsubscribeRequest unsubscribeRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ListSubscriptionsByTopicResult listSubscriptionsByTopic(ListSubscriptionsByTopicRequest listSubscriptionsByTopicRequest) throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public PublishResult publish(PublishRequest publishRequest) throws AmazonServiceException, AmazonClientException {
- PublishResult publishResult = new PublishResult();
- publishResult.setMessageId("dcc8ce7a-7f18-4385-bedd-b97984b4363c");
- return publishResult;
- }
-
- @Override
- public ListSubscriptionsResult listSubscriptions() throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ListTopicsResult listTopics() throws AmazonServiceException, AmazonClientException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ResponseMetadata getCachedResponseMetadata(AmazonWebServiceRequest request) {
- throw new UnsupportedOperationException();
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSQSClientMock.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSQSClientMock.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSQSClientMock.java
deleted file mode 100644
index 0612646..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AmazonSQSClientMock.java
+++ /dev/null
@@ -1,100 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi.aws;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Iterator;
-import java.util.List;
-
-import com.amazonaws.AmazonClientException;
-import com.amazonaws.AmazonServiceException;
-import com.amazonaws.auth.BasicAWSCredentials;
-import com.amazonaws.services.sqs.AmazonSQSClient;
-import com.amazonaws.services.sqs.model.CreateQueueRequest;
-import com.amazonaws.services.sqs.model.CreateQueueResult;
-import com.amazonaws.services.sqs.model.DeleteMessageRequest;
-import com.amazonaws.services.sqs.model.ListQueuesResult;
-import com.amazonaws.services.sqs.model.Message;
-import com.amazonaws.services.sqs.model.ReceiveMessageRequest;
-import com.amazonaws.services.sqs.model.ReceiveMessageResult;
-import com.amazonaws.services.sqs.model.SendMessageRequest;
-import com.amazonaws.services.sqs.model.SendMessageResult;
-
-public class AmazonSQSClientMock extends AmazonSQSClient {
-
- List<Message> messages = new ArrayList<Message>();
-
- public AmazonSQSClientMock() {
- super(new BasicAWSCredentials("myAccessKey", "mySecretKey"));
- }
-
- @Override
- public ListQueuesResult listQueues() throws AmazonServiceException, AmazonClientException {
- ListQueuesResult result = new ListQueuesResult();
- return result;
- }
-
- @Override
- public CreateQueueResult createQueue(CreateQueueRequest createQueueRequest) throws AmazonServiceException, AmazonClientException {
- CreateQueueResult result = new CreateQueueResult();
- result.setQueueUrl("https://queue.amazonaws.com/541925086079/MyQueue");
- return result;
- }
-
- @Override
- public SendMessageResult sendMessage(SendMessageRequest sendMessageRequest) throws AmazonServiceException, AmazonClientException {
- Message message = new Message();
- message.setBody(sendMessageRequest.getMessageBody());
- message.setMD5OfBody("6a1559560f67c5e7a7d5d838bf0272ee");
- message.setMessageId("f6fb6f99-5eb2-4be4-9b15-144774141458");
- message.setReceiptHandle("0NNAq8PwvXsyZkR6yu4nQ07FGxNmOBWi5zC9+4QMqJZ0DJ3gVOmjI2Gh/oFnb0IeJqy5Zc8kH4JX7GVpfjcEDjaAPSeOkXQZRcaBqt"
- + "4lOtyfj0kcclVV/zS7aenhfhX5Ixfgz/rHhsJwtCPPvTAdgQFGYrqaHly+etJiawiNPVc=");
-
- synchronized (messages) {
- messages.add(message);
- }
-
- SendMessageResult result = new SendMessageResult();
- result.setMessageId("f6fb6f99-5eb2-4be4-9b15-144774141458");
- result.setMD5OfMessageBody("6a1559560f67c5e7a7d5d838bf0272ee");
- return result;
- }
-
- @Override
- public ReceiveMessageResult receiveMessage(ReceiveMessageRequest receiveMessageRequest) throws AmazonServiceException, AmazonClientException {
- Integer maxNumberOfMessages = receiveMessageRequest.getMaxNumberOfMessages() != null ? receiveMessageRequest.getMaxNumberOfMessages() : Integer.MAX_VALUE;
- ReceiveMessageResult result = new ReceiveMessageResult();
- Collection<Message> resultMessages = new ArrayList<Message>();
-
- synchronized (messages) {
- int fetchSize = 0;
- for (Iterator<Message> iterator = messages.iterator(); iterator.hasNext() && fetchSize < maxNumberOfMessages; fetchSize++) {
- resultMessages.add(iterator.next());
- iterator.remove();
- }
- }
-
- result.setMessages(resultMessages);
- return result;
- }
-
- @Override
- public void deleteMessage(DeleteMessageRequest deleteMessageRequest) throws AmazonServiceException, AmazonClientException {
- // noop
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsS3IntegrationTest.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsS3IntegrationTest.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsS3IntegrationTest.java
deleted file mode 100644
index 8b490fa..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsS3IntegrationTest.java
+++ /dev/null
@@ -1,102 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi.aws;
-
-import java.io.InputStream;
-
-import org.apache.camel.EndpointInject;
-import org.apache.camel.Exchange;
-import org.apache.camel.ExchangePattern;
-import org.apache.camel.Message;
-import org.apache.camel.Processor;
-import org.apache.camel.component.aws.s3.S3Constants;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.ops4j.pax.exam.junit.PaxExam;
-import org.springframework.osgi.context.support.OsgiBundleXmlApplicationContext;
-
-@RunWith(PaxExam.class)
-@Ignore("Test fails")
-public class AwsS3IntegrationTest extends AwsTestSupport {
-
- @EndpointInject(uri = "mock:result")
- private MockEndpoint result;
-
- @Override
- protected OsgiBundleXmlApplicationContext createApplicationContext() {
- return new OsgiBundleXmlApplicationContext(new String[]{"org/apache/camel/itest/osgi/aws/CamelContext.xml"});
- }
-
- @Test
- public void sendInOnly() throws Exception {
- result.expectedMessageCount(1);
-
- Exchange exchange = template.send("direct:start-s3", ExchangePattern.InOnly, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(S3Constants.KEY, "CamelUnitTest");
- exchange.getIn().setBody("This is my bucket content.");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- assertResultExchange(result.getExchanges().get(0));
-
- assertResponseMessage(exchange.getIn());
- }
-
- @Test
- public void sendInOut() throws Exception {
- result.expectedMessageCount(1);
-
- Exchange exchange = template.send("direct:start-s3", ExchangePattern.InOut, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(S3Constants.KEY, "CamelUnitTest");
- exchange.getIn().setBody("This is my bucket content.");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- assertResultExchange(result.getExchanges().get(0));
-
- assertResponseMessage(exchange.getOut());
- }
-
- private void assertResultExchange(Exchange resultExchange) {
- assertIsInstanceOf(InputStream.class, resultExchange.getIn().getBody());
- assertEquals("This is my bucket content.", resultExchange.getIn().getBody(String.class));
- assertEquals("mycamelbucket", resultExchange.getIn().getHeader(S3Constants.BUCKET_NAME));
- assertEquals("CamelUnitTest", resultExchange.getIn().getHeader(S3Constants.KEY));
- assertNull(resultExchange.getIn().getHeader(S3Constants.VERSION_ID)); // not enabled on this bucket
- assertNull(resultExchange.getIn().getHeader(S3Constants.LAST_MODIFIED));
- assertNull(resultExchange.getIn().getHeader(S3Constants.E_TAG));
- assertNull(resultExchange.getIn().getHeader(S3Constants.CONTENT_TYPE));
- assertNull(resultExchange.getIn().getHeader(S3Constants.CONTENT_ENCODING));
- assertEquals(0L, resultExchange.getIn().getHeader(S3Constants.CONTENT_LENGTH));
- assertNull(resultExchange.getIn().getHeader(S3Constants.CONTENT_DISPOSITION));
- assertNull(resultExchange.getIn().getHeader(S3Constants.CONTENT_MD5));
- assertNull(resultExchange.getIn().getHeader(S3Constants.CACHE_CONTROL));
- }
-
- private void assertResponseMessage(Message message) {
- assertEquals("3a5c8b1ad448bca04584ecb55b836264", message.getHeader(S3Constants.E_TAG));
- assertNull(message.getHeader(S3Constants.VERSION_ID));
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsS3Test.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsS3Test.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsS3Test.java
deleted file mode 100644
index 63a457e..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsS3Test.java
+++ /dev/null
@@ -1,101 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi.aws;
-
-import java.io.InputStream;
-
-import org.apache.camel.EndpointInject;
-import org.apache.camel.Exchange;
-import org.apache.camel.ExchangePattern;
-import org.apache.camel.Message;
-import org.apache.camel.Processor;
-import org.apache.camel.component.aws.s3.S3Constants;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.ops4j.pax.exam.junit.PaxExam;
-import org.springframework.osgi.context.support.OsgiBundleXmlApplicationContext;
-
-@RunWith(PaxExam.class)
-public class AwsS3Test extends AwsTestSupport {
-
- @EndpointInject(uri = "mock:result-s3")
- private MockEndpoint result;
-
- @Override
- protected OsgiBundleXmlApplicationContext createApplicationContext() {
- return new OsgiBundleXmlApplicationContext(new String[]{"org/apache/camel/itest/osgi/aws/CamelContext.xml"});
- }
-
- @Test
- public void sendInOnly() throws Exception {
- result.expectedMessageCount(1);
-
- Exchange exchange = template.send("direct:start-s3", ExchangePattern.InOnly, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(S3Constants.KEY, "CamelUnitTest");
- exchange.getIn().setBody("This is my bucket content.");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- assertResultExchange(result.getExchanges().get(0));
-
- assertResponseMessage(exchange.getIn());
- }
-
- @Test
- public void sendInOut() throws Exception {
- result.expectedMessageCount(1);
-
- Exchange exchange = template.send("direct:start-s3", ExchangePattern.InOut, new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(S3Constants.KEY, "CamelUnitTest");
- exchange.getIn().setBody("This is my bucket content.");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- assertResultExchange(result.getExchanges().get(0));
-
- assertResponseMessage(exchange.getOut());
- }
-
- private void assertResultExchange(Exchange resultExchange) {
- assertIsInstanceOf(InputStream.class, resultExchange.getIn().getBody());
- assertEquals("This is my bucket content.", resultExchange.getIn().getBody(String.class));
- assertEquals("mycamelbucket", resultExchange.getIn().getHeader(S3Constants.BUCKET_NAME));
- assertEquals("CamelUnitTest", resultExchange.getIn().getHeader(S3Constants.KEY));
- assertNull(resultExchange.getIn().getHeader(S3Constants.VERSION_ID)); // not enabled on this bucket
- assertNull(resultExchange.getIn().getHeader(S3Constants.LAST_MODIFIED));
- assertNull(resultExchange.getIn().getHeader(S3Constants.E_TAG));
- assertNull(resultExchange.getIn().getHeader(S3Constants.CONTENT_TYPE));
- assertNull(resultExchange.getIn().getHeader(S3Constants.CONTENT_ENCODING));
- assertEquals(0L, resultExchange.getIn().getHeader(S3Constants.CONTENT_LENGTH));
- assertNull(resultExchange.getIn().getHeader(S3Constants.CONTENT_DISPOSITION));
- assertNull(resultExchange.getIn().getHeader(S3Constants.CONTENT_MD5));
- assertNull(resultExchange.getIn().getHeader(S3Constants.CACHE_CONTROL));
- }
-
- private void assertResponseMessage(Message message) {
- assertEquals("3a5c8b1ad448bca04584ecb55b836264", message.getHeader(S3Constants.E_TAG));
- assertNull(message.getHeader(S3Constants.VERSION_ID));
- }
-
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/6b77d012/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsSdbIntegrationTest.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsSdbIntegrationTest.java b/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsSdbIntegrationTest.java
deleted file mode 100644
index 7a49890..0000000
--- a/tests/camel-itest-osgi/src/test/java/org/apache/camel/itest/osgi/aws/AwsSdbIntegrationTest.java
+++ /dev/null
@@ -1,175 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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 specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.itest.osgi.aws;
-
-import java.util.Arrays;
-import java.util.List;
-
-import com.amazonaws.services.simpledb.model.Attribute;
-import com.amazonaws.services.simpledb.model.DeletableItem;
-import com.amazonaws.services.simpledb.model.ReplaceableAttribute;
-import com.amazonaws.services.simpledb.model.ReplaceableItem;
-import com.amazonaws.services.simpledb.model.UpdateCondition;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.component.aws.sdb.SdbConstants;
-import org.apache.camel.component.aws.sdb.SdbOperations;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.ops4j.pax.exam.junit.PaxExam;
-import org.springframework.osgi.context.support.OsgiBundleXmlApplicationContext;
-
-@RunWith(PaxExam.class)
-@Ignore("Must be manually tested. Provide your own accessKey and secretKey!")
-public class AwsSdbIntegrationTest extends AwsTestSupport {
-
- @Override
- protected OsgiBundleXmlApplicationContext createApplicationContext() {
- return new OsgiBundleXmlApplicationContext(
- new String[]{"org/apache/camel/itest/osgi/aws/CamelIntegrationContext.xml"});
- }
-
- @Test
- public void batchDeleteAttributes() {
- final List<DeletableItem> deletableItems = Arrays.asList(new DeletableItem[] {
- new DeletableItem("ITEM1", null),
- new DeletableItem("ITEM2", null)});
-
- template.send("direct:start-sdb", new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(SdbConstants.OPERATION, SdbOperations.BatchDeleteAttributes);
- exchange.getIn().setHeader(SdbConstants.DELETABLE_ITEMS, deletableItems);
- }
- });
- }
-
- @Test
- public void batchPutAttributes() {
- final List<ReplaceableItem> replaceableItems = Arrays.asList(new ReplaceableItem[] {
- new ReplaceableItem("ITEM1")});
-
- template.send("direct:start-sdb", new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(SdbConstants.OPERATION, SdbOperations.BatchPutAttributes);
- exchange.getIn().setHeader(SdbConstants.REPLACEABLE_ITEMS, replaceableItems);
- }
- });
- }
-
- @Test
- public void deleteAttributes() {
- final List<Attribute> attributes = Arrays.asList(new Attribute[] {
- new Attribute("NAME1", "VALUE1")});
- final UpdateCondition condition = new UpdateCondition("Key1", "Value1", true);
-
- template.send("direct:start-sdb", new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(SdbConstants.OPERATION, SdbOperations.DeleteAttributes);
- exchange.getIn().setHeader(SdbConstants.ATTRIBUTES, attributes);
- exchange.getIn().setHeader(SdbConstants.ITEM_NAME, "ITEM1");
- exchange.getIn().setHeader(SdbConstants.UPDATE_CONDITION, condition);
- }
- });
- }
-
- @Test
- public void deleteDomain() {
- template.send("direct:start-sdb", new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(SdbConstants.OPERATION, SdbOperations.DeleteDomain);
- }
- });
- }
-
- @Test
- public void domainMetadata() {
- Exchange exchange = template.send("direct:start-sdb", new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(SdbConstants.OPERATION, SdbOperations.DomainMetadata);
- }
- });
-
- assertNotNull(exchange.getIn().getHeader(SdbConstants.TIMESTAMP));
- assertNotNull(exchange.getIn().getHeader(SdbConstants.ITEM_COUNT));
- assertNotNull(exchange.getIn().getHeader(SdbConstants.ATTRIBUTE_NAME_COUNT));
- assertNotNull(exchange.getIn().getHeader(SdbConstants.ATTRIBUTE_VALUE_COUNT));
- assertNotNull(exchange.getIn().getHeader(SdbConstants.ATTRIBUTE_NAME_SIZE));
- assertNotNull(exchange.getIn().getHeader(SdbConstants.ATTRIBUTE_VALUE_SIZE));
- assertNotNull(exchange.getIn().getHeader(SdbConstants.ITEM_NAME_SIZE));
- }
-
- @Test
- public void getAttributes() {
- final List<String> attributeNames = Arrays.asList(new String[] {"ATTRIBUTE1"});
-
- Exchange exchange = template.send("direct:start-sdb", new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(SdbConstants.OPERATION, SdbOperations.GetAttributes);
- exchange.getIn().setHeader(SdbConstants.ITEM_NAME, "ITEM1");
- exchange.getIn().setHeader(SdbConstants.CONSISTENT_READ, Boolean.TRUE);
- exchange.getIn().setHeader(SdbConstants.ATTRIBUTE_NAMES, attributeNames);
- }
- });
-
- assertNotNull(exchange.getIn().getHeader(SdbConstants.ATTRIBUTES, List.class));
- }
-
- @Test
- public void listDomains() {
- Exchange exchange = template.send("direct:start-sdb", new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(SdbConstants.OPERATION, SdbOperations.ListDomains);
- exchange.getIn().setHeader(SdbConstants.MAX_NUMBER_OF_DOMAINS, new Integer(5));
- exchange.getIn().setHeader(SdbConstants.NEXT_TOKEN, "TOKEN1");
- }
- });
-
- assertNotNull(exchange.getIn().getHeader(SdbConstants.DOMAIN_NAMES, List.class));
- }
-
- @Test
- public void putAttributes() {
- final List<ReplaceableAttribute> replaceableAttributes = Arrays.asList(new ReplaceableAttribute[] {
- new ReplaceableAttribute("NAME1", "VALUE1", true)});
- final UpdateCondition updateCondition = new UpdateCondition("NAME1", "VALUE1", true);
-
- template.send("direct:start-sdb", new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(SdbConstants.OPERATION, SdbOperations.PutAttributes);
- exchange.getIn().setHeader(SdbConstants.ITEM_NAME, "ITEM1");
- exchange.getIn().setHeader(SdbConstants.UPDATE_CONDITION, updateCondition);
- exchange.getIn().setHeader(SdbConstants.REPLACEABLE_ATTRIBUTES, replaceableAttributes);
- }
- });
- }
-
- @Test
- public void select() {
- Exchange exchange = template.send("direct:start-sdb", new Processor() {
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(SdbConstants.OPERATION, SdbOperations.Select);
- exchange.getIn().setHeader(SdbConstants.NEXT_TOKEN, "TOKEN1");
- exchange.getIn().setHeader(SdbConstants.CONSISTENT_READ, Boolean.TRUE);
- exchange.getIn().setHeader(SdbConstants.SELECT_EXPRESSION, "SELECT NAME1 FROM DOMAIN1 WHERE NAME1 LIKE 'VALUE1'");
- }
- });
-
- assertNotNull(exchange.getIn().getHeader(SdbConstants.ITEMS, List.class));
- }
-}
\ No newline at end of file