diff options
Diffstat (limited to 'M4-RCs/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java')
-rw-r--r-- | M4-RCs/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java | 122 |
1 files changed, 0 insertions, 122 deletions
diff --git a/M4-RCs/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java b/M4-RCs/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java deleted file mode 100644 index 39ecf0a209..0000000000 --- a/M4-RCs/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java +++ /dev/null @@ -1,122 +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.qpid.test.unit.message; - -import org.apache.qpid.test.utils.QpidTestCase; -import org.apache.qpid.transport.Connection; -import org.apache.qpid.transport.Session; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import javax.naming.InitialContext; -import javax.jms.*; -import java.util.Properties; -import java.io.*; - - -/** - * @author Apache Software Foundation - * This test makes sure that utf8 characters can be used for - * specifying exchange, queue name and routing key. - * - * those tests are related to qpid-1384 - */ -public class UTF8Test extends QpidTestCase -{ - private static final Logger _logger = LoggerFactory.getLogger(UTF8Test.class); - - - public void testPlainEn() throws Exception - { - invoke("UTF8En"); - } - - - public void testUTF8Jp() throws Exception - { - invoke("UTF8Jp"); - } - - - private void invoke(String name) throws Exception - { - String path = System.getProperties().getProperty("QPID_HOME"); - path = path + "/../systests/src/main/java/org/apache/qpid/test/unit/message/" + name; - BufferedReader in = new BufferedReader(new InputStreamReader(new FileInputStream(path), "UTF8")); - runTest(in.readLine(), in.readLine(), in.readLine(), in.readLine()); - in.close(); - } - private void runTest(String exchangeName, String queueName, String routingKey, String data) throws Exception - { - _logger.info("Running test for exchange: " + exchangeName - + " queue Name: " + queueName - + " routing key: " + routingKey); - declareQueue(exchangeName, routingKey, queueName); - - javax.jms.Connection con = getConnection(); - javax.jms.Session sess = con.createSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE); - Destination dest = getDestination(exchangeName, routingKey, queueName); - // Send data - MessageProducer msgProd = sess.createProducer(dest); - TextMessage message = sess.createTextMessage(data); - msgProd.send(message); - // consume data - MessageConsumer msgCons = sess.createConsumer(dest); - con.start(); - TextMessage m = (TextMessage) msgCons.receive(RECEIVE_TIMEOUT); - assertNotNull(m); - assertEquals(m.getText(), data); - } - - private void declareQueue(String exch, String routkey, String qname) throws Exception - { - Connection conn = new Connection(); - if (!_broker.equals(QpidTestCase.EXTERNAL) && !isBroker08()) - { - conn.connect("localhost", 5672, "test", "guest", "guest",false); - } - else - { - throw new Exception("unsupported test " + - "configuration. broker: " + _broker + " version > 0.10 "+ !isBroker08() + " This test must be run on a local broker using protocol 0.10 or higher."); - } - Session sess = conn.createSession(0); - sess.exchangeDeclare(exch, "direct", null, null); - sess.queueDeclare(qname, null, null); - sess.exchangeBind(qname, exch, routkey, null); - sess.sync(); - conn.close(); - } - - private Destination getDestination(String exch, String routkey, String qname) - throws Exception - { - Properties props = new Properties(); - props.setProperty("destination.directUTF8Queue", - "direct://" + exch + "//" + qname + "?autodelete='false'&durable='false'" - + "&routingkey='" + routkey + "'"); - - // Get our connection context - InitialContext ctx = new InitialContext(props); - return (Destination) ctx.lookup("directUTF8Queue"); - } -} |