Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-6130 - java beans @Transient annotation

This commit is contained in:
Dejan Bosanac 2016-01-18 09:35:45 +01:00
parent df868fe4a3
commit a3fa0da6ec
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-client/src/main/java/org/apache/activemq/command/Message.java
View File

@ -16,6 +16,7 @@
*/ */
package org.apache.activemq.command; package org.apache.activemq.command;
import java.beans.Transient;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
@ -628,6 +629,7 @@ public abstract class Message extends BaseCommand implements MarshallAware, Mess
} }
@Override @Override
@Transient
public MessageDestination getRegionDestination() { public MessageDestination getRegionDestination() {
return regionDestination; return regionDestination;
} }

7
activemq-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQTextMessageTest.java
View File

@ -16,8 +16,10 @@
*/ */
package org.apache.activemq.command; package org.apache.activemq.command;
import java.beans.Transient;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import java.lang.reflect.Method;
import javax.jms.JMSException; import javax.jms.JMSException;
import javax.jms.MessageNotReadableException; import javax.jms.MessageNotReadableException;
@ -149,6 +151,11 @@ public class ActiveMQTextMessageTest extends TestCase {
assertTrue(nullMessage.toString().contains("text = 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 { protected void setContent(Message message, String text) throws Exception {
ByteArrayOutputStream baos = new ByteArrayOutputStream(); ByteArrayOutputStream baos = new ByteArrayOutputStream();
DataOutputStream dataOut = new DataOutputStream(baos); DataOutputStream dataOut = new DataOutputStream(baos);