You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2011/10/19 23:11:34 UTC
svn commit: r1186494 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageCompressionTest.java
Author: tabish
Date: Wed Oct 19 21:11:34 2011
New Revision: 1186494
URL: http://svn.apache.org/viewvc?rev=1186494&view=rev
Log:
Remove dependence on fixed port.
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageCompressionTest.java
Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageCompressionTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageCompressionTest.java?rev=1186494&r1=1186493&r2=1186494&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageCompressionTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageCompressionTest.java Wed Oct 19 21:11:34 2011
@@ -17,7 +17,6 @@
package org.apache.activemq.command;
import java.io.UnsupportedEncodingException;
-import java.net.URI;
import javax.jms.BytesMessage;
import javax.jms.JMSException;
@@ -30,37 +29,30 @@ import junit.framework.TestCase;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerService;
-import org.apache.activemq.broker.TransportConnector;
public class MessageCompressionTest extends TestCase {
- private static final String BROKER_URL = "tcp://localhost:61216";
+ private static final String BROKER_URL = "tcp://localhost:0";
// The following text should compress well
- private static final String TEXT = "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
- + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
- + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
- + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
- + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
- + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
- + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
- + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
- + "The quick red fox jumped over the lazy brown dog. ";
+ private static final String TEXT = "The quick red fox jumped over the lazy brown dog. "
+ + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
+ + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
+ + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
+ + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
+ + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
+ + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
+ + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. "
+ + "The quick red fox jumped over the lazy brown dog. " + "The quick red fox jumped over the lazy brown dog. ";
- protected BrokerService broker;
+ private BrokerService broker;
private ActiveMQQueue queue;
+ private String connectionUri;
protected void setUp() throws Exception {
broker = new BrokerService();
-
- TransportConnector tc = new TransportConnector();
- tc.setUri(new URI(BROKER_URL));
- tc.setName("tcp");
-
- queue = new ActiveMQQueue("TEST." + System.currentTimeMillis());
-
- broker.addConnector(tc);
+ connectionUri = broker.addConnector(BROKER_URL).getPublishableConnectString();
broker.start();
-
+ queue = new ActiveMQQueue("TEST." + System.currentTimeMillis());
}
protected void tearDown() throws Exception {
@@ -71,45 +63,48 @@ public class MessageCompressionTest exte
public void testTextMessageCompression() throws Exception {
- ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(BROKER_URL);
+ ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(connectionUri);
factory.setUseCompression(true);
sendTestMessage(factory, TEXT);
ActiveMQTextMessage message = receiveTestMessage(factory);
int compressedSize = message.getContent().getLength();
- factory = new ActiveMQConnectionFactory(BROKER_URL);
+ factory = new ActiveMQConnectionFactory(connectionUri);
factory.setUseCompression(false);
sendTestMessage(factory, TEXT);
message = receiveTestMessage(factory);
int unCompressedSize = message.getContent().getLength();
- assertTrue("expected: compressed Size '" + compressedSize + "' < unCompressedSize '" + unCompressedSize + "'", compressedSize < unCompressedSize);
+ assertTrue("expected: compressed Size '" + compressedSize + "' < unCompressedSize '" + unCompressedSize + "'",
+ compressedSize < unCompressedSize);
}
public void testBytesMessageCompression() throws Exception {
- ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(BROKER_URL);
+ ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(connectionUri);
factory.setUseCompression(true);
sendTestBytesMessage(factory, TEXT);
ActiveMQBytesMessage message = receiveTestBytesMessage(factory);
int compressedSize = message.getContent().getLength();
byte[] bytes = new byte[TEXT.getBytes("UTF8").length];
message.readBytes(bytes);
- assertTrue(message.readBytes( new byte[255]) == -1);
+ assertTrue(message.readBytes(new byte[255]) == -1);
String rcvString = new String(bytes, "UTF8");
assertEquals(TEXT, rcvString);
+ assertTrue(message.isCompressed());
- factory = new ActiveMQConnectionFactory(BROKER_URL);
+ factory = new ActiveMQConnectionFactory(connectionUri);
factory.setUseCompression(false);
sendTestBytesMessage(factory, TEXT);
message = receiveTestBytesMessage(factory);
int unCompressedSize = message.getContent().getLength();
- assertTrue("expected: compressed Size '" + compressedSize + "' < unCompressedSize '" + unCompressedSize + "'", compressedSize < unCompressedSize);
+ assertTrue("expected: compressed Size '" + compressedSize + "' < unCompressedSize '" + unCompressedSize + "'",
+ compressedSize < unCompressedSize);
}
private void sendTestMessage(ActiveMQConnectionFactory factory, String message) throws JMSException {
- ActiveMQConnection connection = (ActiveMQConnection)factory.createConnection();
+ ActiveMQConnection connection = (ActiveMQConnection) factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(queue);
producer.send(session.createTextMessage(message));
@@ -117,17 +112,17 @@ public class MessageCompressionTest exte
}
private ActiveMQTextMessage receiveTestMessage(ActiveMQConnectionFactory factory) throws JMSException {
- ActiveMQConnection connection = (ActiveMQConnection)factory.createConnection();
+ ActiveMQConnection connection = (ActiveMQConnection) factory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer consumer = session.createConsumer(queue);
- ActiveMQTextMessage rc = (ActiveMQTextMessage)consumer.receive();
+ ActiveMQTextMessage rc = (ActiveMQTextMessage) consumer.receive();
connection.close();
return rc;
}
private void sendTestBytesMessage(ActiveMQConnectionFactory factory, String message) throws JMSException, UnsupportedEncodingException {
- ActiveMQConnection connection = (ActiveMQConnection)factory.createConnection();
+ ActiveMQConnection connection = (ActiveMQConnection) factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(queue);
BytesMessage bytesMessage = session.createBytesMessage();
@@ -137,21 +132,12 @@ public class MessageCompressionTest exte
}
private ActiveMQBytesMessage receiveTestBytesMessage(ActiveMQConnectionFactory factory) throws JMSException, UnsupportedEncodingException {
- ActiveMQConnection connection = (ActiveMQConnection)factory.createConnection();
+ ActiveMQConnection connection = (ActiveMQConnection) factory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer consumer = session.createConsumer(queue);
- ActiveMQBytesMessage rc = (ActiveMQBytesMessage)consumer.receive();
+ ActiveMQBytesMessage rc = (ActiveMQBytesMessage) consumer.receive();
connection.close();
return rc;
}
-
- // public void testJavaUtilZip() throws Exception {
- // String str = "When the going gets weird, the weird turn pro.";
- // byte[] bytes = str.getBytes();
- //
- // ByteArrayOutputStream baos = new ByteArrayOutputStream(bytes.length);
- // DeflaterOutputStream dos = new DeflaterOutputStream(baos);
- // dos.
- // }
}