diff --git a/activemq-client/src/main/java/org/apache/activemq/command/Message.java b/activemq-client/src/main/java/org/apache/activemq/command/Message.java index 4c57feb7c8..b2640b35c3 100755 --- a/activemq-client/src/main/java/org/apache/activemq/command/Message.java +++ b/activemq-client/src/main/java/org/apache/activemq/command/Message.java @@ -16,6 +16,7 @@ */ package org.apache.activemq.command; +import java.beans.Transient; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; @@ -628,6 +629,7 @@ public abstract class Message extends BaseCommand implements MarshallAware, Mess } @Override + @Transient public MessageDestination getRegionDestination() { return regionDestination; } diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQTextMessageTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQTextMessageTest.java index 28fc307c5e..174e20bea1 100755 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQTextMessageTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQTextMessageTest.java @@ -16,8 +16,10 @@ */ package org.apache.activemq.command; +import java.beans.Transient; import java.io.DataOutputStream; import java.io.IOException; +import java.lang.reflect.Method; import javax.jms.JMSException; import javax.jms.MessageNotReadableException; @@ -148,6 +150,11 @@ public class ActiveMQTextMessageTest extends TestCase { setContent(nullMessage, null); assertTrue(nullMessage.toString().contains("text = null")); } + + public void testTransient() throws Exception { + Method method = ActiveMQTextMessage.class.getMethod("getRegionDestination", null); + assertTrue(method.isAnnotationPresent(Transient.class)); + } protected void setContent(Message message, String text) throws Exception { ByteArrayOutputStream baos = new ByteArrayOutputStream();