Added: synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/async/TextPlainTestCase.java URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/async/TextPlainTestCase.java?rev=684513&view=auto ============================================================================== --- synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/async/TextPlainTestCase.java (added) +++ synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/async/TextPlainTestCase.java Sun Aug 10 07:55:31 2008 @@ -0,0 +1,56 @@ +/* + * 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.synapse.transport.testkit.tests.async; + +import org.apache.synapse.transport.testkit.listener.AsyncChannel; +import org.apache.synapse.transport.testkit.listener.AsyncMessageSender; +import org.apache.synapse.transport.testkit.listener.AsyncMessageTestCase; +import org.apache.synapse.transport.testkit.listener.ContentTypeMode; +import org.apache.synapse.transport.testkit.listener.MessageTestData; +import org.apache.synapse.transport.testkit.listener.NameBuilder; +import org.apache.synapse.transport.testkit.message.StringMessage; +import org.apache.synapse.transport.testkit.name.DisplayName; +import org.apache.synapse.transport.testkit.server.AsyncEndpointFactory; + [EMAIL PROTECTED]("AsyncTextPlain") +public class TextPlainTestCase<C extends AsyncChannel<?>> extends AsyncMessageTestCase<C,StringMessage,StringMessage> { + private final MessageTestData data; + + public TextPlainTestCase(C channel, AsyncMessageSender<? super C,StringMessage> sender, AsyncEndpointFactory<? super C,StringMessage> endpointFactory, ContentTypeMode contentTypeMode, MessageTestData data) { + super(channel, sender, endpointFactory, contentTypeMode, "text/plain; charset=\"" + data.getCharset() + "\"", data.getCharset()); + this.data = data; + } + + @Override + protected void buildName(NameBuilder name) { + super.buildName(name); + data.buildName(name); + } + + @Override + protected StringMessage prepareMessage() throws Exception { + return new StringMessage(contentType, data.getText()); + } + + @Override + protected void checkMessageData(StringMessage message, StringMessage messageData) throws Exception { + assertEquals(message.getContent(), messageData.getContent()); + } +}
Modified: synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/vfs/VFSTransportSenderTest.java URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/vfs/VFSTransportSenderTest.java?rev=684513&r1=684512&r2=684513&view=diff ============================================================================== --- synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/vfs/VFSTransportSenderTest.java (original) +++ synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/vfs/VFSTransportSenderTest.java Sun Aug 10 07:55:31 2008 @@ -34,6 +34,7 @@ import org.apache.synapse.transport.testkit.server.AsyncEndpoint; import org.apache.synapse.transport.testkit.server.AsyncEndpointFactory; import org.apache.synapse.transport.testkit.server.DummyServer; +import org.apache.synapse.transport.testkit.server.Server; public class VFSTransportSenderTest extends TestCase { public static TestSuite suite() { @@ -42,8 +43,14 @@ VFSTestSetup setup = new VFSTestSetup(); + final Server<VFSTestSetup> server = new DummyServer<VFSTestSetup>(setup); + AsyncEndpointFactory<VFSFileChannel,ByteArrayMessage> endpointFactory = new AsyncEndpointFactory<VFSFileChannel,ByteArrayMessage>() { + + public Server<?> getServer() { + return server; + } public AsyncEndpoint<ByteArrayMessage> createAsyncEndpoint( VFSFileChannel channel, String contentType) @@ -53,7 +60,7 @@ } }; - VFSFileChannel channel = new VFSFileChannel(new DummyServer<VFSTestSetup>(setup), new File("target/vfs3/req/in").getAbsoluteFile()); + VFSFileChannel channel = new VFSFileChannel(server, new File("target/vfs3/req/in").getAbsoluteFile()); AxisAsyncMessageSender sender = new AxisAsyncMessageSender(); suite.addBinaryTest(channel, adapt(sender, MessageConverter.BINARY_WRAPPER), endpointFactory, ContentTypeMode.SERVICE);
