Repository: qpid-jms Updated Branches: refs/heads/master c6618625d -> 6a221b168
Add a set of JMS Message implementations that can be used to test support for Foreign JMS Types. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/12cc2f37 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/12cc2f37 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/12cc2f37 Branch: refs/heads/master Commit: 12cc2f37c03984817213ce1c9d03a0ceb2c7eca8 Parents: c661862 Author: Timothy Bish <tabish...@gmail.com> Authored: Wed Oct 15 15:12:32 2014 -0400 Committer: Timothy Bish <tabish...@gmail.com> Committed: Wed Oct 15 15:12:32 2014 -0400 ---------------------------------------------------------------------- .../message/JmsMessageTransformationTest.java | 13 + .../message/foreign/ForeignJmsBytesMessage.java | 171 ++++++++++++ .../message/foreign/ForeignJmsMapMessage.java | 163 +++++++++++ .../jms/message/foreign/ForeignJmsMessage.java | 268 +++++++++++++++++++ .../foreign/ForeignJmsObjectMessage.java | 48 ++++ .../foreign/ForeignJmsStreamMessage.java | 156 +++++++++++ .../message/foreign/ForeignJmsTextMessage.java | 46 ++++ 7 files changed, 865 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/12cc2f37/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java index 8dc485b..9893946 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java @@ -36,6 +36,8 @@ import org.apache.qpid.jms.JmsConnection; import org.apache.qpid.jms.JmsDestination; import org.apache.qpid.jms.JmsTopic; import org.apache.qpid.jms.message.facade.defaults.JmsDefaultMessageFacade; +import org.apache.qpid.jms.message.facade.defaults.JmsDefaultMessageFactory; +import org.apache.qpid.jms.message.foreign.ForeignJmsMessage; import org.junit.Test; import org.mockito.Mockito; @@ -65,6 +67,15 @@ public class JmsMessageTransformationTest { assertNotSame(source, copy); } + @Test + public void testBasicMessageTransformCreateNewMessage() throws JMSException { + ForeignJmsMessage foreignMessage = new ForeignJmsMessage(); + + JmsMessage transformed = JmsMessageTransformation.transformMessage(createMockJmsConnection(), foreignMessage); + assertNotSame(foreignMessage, transformed); + assertFalse(transformed.equals(foreignMessage)); + } + //---------- Test Generic Property Copy ----------------------------------// @Test @@ -205,6 +216,8 @@ public class JmsMessageTransformationTest { private JmsConnection createMockJmsConnection() { JmsConnection connection = Mockito.mock(JmsConnection.class); + Mockito.when(connection.getMessageFactory()).thenReturn(new JmsDefaultMessageFactory()); + return connection; } http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/12cc2f37/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsBytesMessage.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsBytesMessage.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsBytesMessage.java new file mode 100644 index 0000000..d8ea4be --- /dev/null +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsBytesMessage.java @@ -0,0 +1,171 @@ +/** + * 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.jms.message.foreign; + +import javax.jms.BytesMessage; +import javax.jms.JMSException; + +import org.apache.qpid.jms.message.JmsBytesMessage; +import org.apache.qpid.jms.message.facade.defaults.JmsDefaultBytesMessageFacade; + +/** + * Foreign JMS BytesMessage type. + */ +public class ForeignJmsBytesMessage extends ForeignJmsMessage implements BytesMessage { + + private final JmsBytesMessage message; + + public ForeignJmsBytesMessage() { + super(new JmsBytesMessage(new JmsDefaultBytesMessageFacade())); + this.message = (JmsBytesMessage) super.message; + } + + @Override + public long getBodyLength() throws JMSException { + return message.getBodyLength(); + } + + @Override + public boolean readBoolean() throws JMSException { + return message.readBoolean(); + } + + @Override + public byte readByte() throws JMSException { + return message.readByte(); + } + + @Override + public int readUnsignedByte() throws JMSException { + return message.readUnsignedByte(); + } + + @Override + public short readShort() throws JMSException { + return message.readShort(); + } + + @Override + public int readUnsignedShort() throws JMSException { + return message.readUnsignedShort(); + } + + @Override + public char readChar() throws JMSException { + return message.readChar(); + } + + @Override + public int readInt() throws JMSException { + return message.readInt(); + } + + @Override + public long readLong() throws JMSException { + return message.readLong(); + } + + @Override + public float readFloat() throws JMSException { + return message.readFloat(); + } + + @Override + public double readDouble() throws JMSException { + return message.readDouble(); + } + + @Override + public String readUTF() throws JMSException { + return message.readUTF(); + } + + @Override + public int readBytes(byte[] value) throws JMSException { + return message.readBytes(value); + } + + @Override + public int readBytes(byte[] value, int length) throws JMSException { + return message.readBytes(value, length); + } + + @Override + public void writeBoolean(boolean value) throws JMSException { + message.writeBoolean(value); + } + + @Override + public void writeByte(byte value) throws JMSException { + message.writeByte(value); + } + + @Override + public void writeShort(short value) throws JMSException { + message.writeShort(value); + } + + @Override + public void writeChar(char value) throws JMSException { + message.writeChar(value); + } + + @Override + public void writeInt(int value) throws JMSException { + message.writeInt(value); + } + + @Override + public void writeLong(long value) throws JMSException { + message.writeLong(value); + } + + @Override + public void writeFloat(float value) throws JMSException { + message.writeFloat(value); + } + + @Override + public void writeDouble(double value) throws JMSException { + message.writeDouble(value); + } + + @Override + public void writeUTF(String value) throws JMSException { + message.writeUTF(value); + } + + @Override + public void writeBytes(byte[] value) throws JMSException { + message.writeBytes(value); + } + + @Override + public void writeBytes(byte[] value, int offset, int length) throws JMSException { + message.writeBytes(value, offset, length); + } + + @Override + public void writeObject(Object value) throws JMSException { + message.writeObject(value); + } + + @Override + public void reset() throws JMSException { + message.reset(); + } +} http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/12cc2f37/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsMapMessage.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsMapMessage.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsMapMessage.java new file mode 100644 index 0000000..9d31868 --- /dev/null +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsMapMessage.java @@ -0,0 +1,163 @@ +/** + * 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.jms.message.foreign; + +import java.util.Enumeration; + +import javax.jms.JMSException; +import javax.jms.MapMessage; + +import org.apache.qpid.jms.message.JmsMapMessage; +import org.apache.qpid.jms.message.facade.defaults.JmsDefaultMapMessageFacade; + +/** + * Foreign JMS MapMessage class + */ +public class ForeignJmsMapMessage extends ForeignJmsMessage implements MapMessage { + + private final JmsMapMessage message; + + public ForeignJmsMapMessage() { + super(new JmsMapMessage(new JmsDefaultMapMessageFacade())); + this.message = (JmsMapMessage) super.message; + } + + @Override + public boolean getBoolean(String name) throws JMSException { + return message.getBoolean(name); + } + + @Override + public byte getByte(String name) throws JMSException { + return message.getByte(name); + } + + @Override + public short getShort(String name) throws JMSException { + return message.getShort(name); + } + + @Override + public char getChar(String name) throws JMSException { + return message.getChar(name); + } + + @Override + public int getInt(String name) throws JMSException { + return message.getInt(name); + } + + @Override + public long getLong(String name) throws JMSException { + return message.getLong(name); + } + + @Override + public float getFloat(String name) throws JMSException { + return message.getFloat(name); + } + + @Override + public double getDouble(String name) throws JMSException { + return message.getDouble(name); + } + + @Override + public String getString(String name) throws JMSException { + return message.getString(name); + } + + @Override + public byte[] getBytes(String name) throws JMSException { + return message.getBytes(name); + } + + @Override + public Object getObject(String name) throws JMSException { + return message.getObject(name); + } + + @Override + public Enumeration<String> getMapNames() throws JMSException { + return message.getMapNames(); + } + + @Override + public void setBoolean(String name, boolean value) throws JMSException { + message.setBoolean(name, value); + } + + @Override + public void setByte(String name, byte value) throws JMSException { + message.setByteProperty(name, value); + } + + @Override + public void setShort(String name, short value) throws JMSException { + message.setShort(name, value); + } + + @Override + public void setChar(String name, char value) throws JMSException { + message.setChar(name, value); + } + + @Override + public void setInt(String name, int value) throws JMSException { + message.setInt(name, value); + } + + @Override + public void setLong(String name, long value) throws JMSException { + message.setLong(name, value); + } + + @Override + public void setFloat(String name, float value) throws JMSException { + message.setFloat(name, value); + } + + @Override + public void setDouble(String name, double value) throws JMSException { + message.setDouble(name, value); + } + + @Override + public void setString(String name, String value) throws JMSException { + message.setString(name, value); + } + + @Override + public void setBytes(String name, byte[] value) throws JMSException { + message.setBytes(name, value); + } + + @Override + public void setBytes(String name, byte[] value, int offset, int length) throws JMSException { + message.setBytes(name, value, offset, length); + } + + @Override + public void setObject(String name, Object value) throws JMSException { + message.setObject(name, value); + } + + @Override + public boolean itemExists(String name) throws JMSException { + return message.itemExists(name); + } +} http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/12cc2f37/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsMessage.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsMessage.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsMessage.java new file mode 100644 index 0000000..3ce20a0 --- /dev/null +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsMessage.java @@ -0,0 +1,268 @@ +/** + * 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.jms.message.foreign; + +import java.util.Enumeration; + +import javax.jms.Destination; +import javax.jms.JMSException; +import javax.jms.Message; + +import org.apache.qpid.jms.message.JmsMessage; +import org.apache.qpid.jms.message.facade.defaults.JmsDefaultMessageFactory; + +/** + * Test class used to simulate receipt of a JMS Message from another + * client library. + */ +public class ForeignJmsMessage implements Message { + + protected final JmsMessage message; + + public ForeignJmsMessage() { + this.message = new JmsDefaultMessageFactory().createMessage(); + } + + protected ForeignJmsMessage(JmsMessage message) { + this.message = message; + } + + @Override + public String getJMSMessageID() throws JMSException { + return message.getJMSMessageID(); + } + + @Override + public void setJMSMessageID(String messageId) throws JMSException { + message.setJMSMessageID(messageId); + } + + @Override + public long getJMSTimestamp() throws JMSException { + return message.getJMSTimestamp(); + } + + @Override + public void setJMSTimestamp(long timestamp) throws JMSException { + message.setJMSTimestamp(timestamp); + } + + @Override + public byte[] getJMSCorrelationIDAsBytes() throws JMSException { + return message.getJMSCorrelationIDAsBytes(); + } + + @Override + public void setJMSCorrelationIDAsBytes(byte[] correlationID) throws JMSException { + message.setJMSCorrelationIDAsBytes(correlationID); + } + + @Override + public void setJMSCorrelationID(String correlationID) throws JMSException { + message.setJMSCorrelationID(correlationID); + } + + @Override + public String getJMSCorrelationID() throws JMSException { + return message.getJMSCorrelationID(); + } + + @Override + public Destination getJMSReplyTo() throws JMSException { + return message.getJMSReplyTo(); + } + + @Override + public void setJMSReplyTo(Destination replyTo) throws JMSException { + message.setJMSReplyTo(replyTo); + } + + @Override + public Destination getJMSDestination() throws JMSException { + return message.getJMSDestination(); + } + + @Override + public void setJMSDestination(Destination destination) throws JMSException { + message.setJMSDestination(destination); + } + + @Override + public int getJMSDeliveryMode() throws JMSException { + return message.getJMSDeliveryMode(); + } + + @Override + public void setJMSDeliveryMode(int deliveryMode) throws JMSException { + message.setJMSDeliveryMode(deliveryMode); + } + + @Override + public boolean getJMSRedelivered() throws JMSException { + return message.getJMSRedelivered(); + } + + @Override + public void setJMSRedelivered(boolean redelivered) throws JMSException { + message.setJMSRedelivered(redelivered); + } + + @Override + public String getJMSType() throws JMSException { + return message.getJMSType(); + } + + @Override + public void setJMSType(String type) throws JMSException { + message.setJMSType(type); + } + + @Override + public long getJMSExpiration() throws JMSException { + return message.getJMSExpiration(); + } + + @Override + public void setJMSExpiration(long expiration) throws JMSException { + message.setJMSExpiration(expiration); + } + + @Override + public int getJMSPriority() throws JMSException { + return message.getJMSPriority(); + } + + @Override + public void setJMSPriority(int priority) throws JMSException { + message.setJMSPriority(priority); + } + + @Override + public void clearProperties() throws JMSException { + message.clearProperties(); + } + + @Override + public boolean propertyExists(String name) throws JMSException { + return message.propertyExists(name); + } + + @Override + public boolean getBooleanProperty(String name) throws JMSException { + return message.getBooleanProperty(name); + } + + @Override + public byte getByteProperty(String name) throws JMSException { + return getByteProperty(name); + } + + @Override + public short getShortProperty(String name) throws JMSException { + return getShortProperty(name); + } + + @Override + public int getIntProperty(String name) throws JMSException { + return getIntProperty(name); + } + + @Override + public long getLongProperty(String name) throws JMSException { + return message.getLongProperty(name); + } + + @Override + public float getFloatProperty(String name) throws JMSException { + return message.getFloatProperty(name); + } + + @Override + public double getDoubleProperty(String name) throws JMSException { + return message.getDoubleProperty(name); + } + + @Override + public String getStringProperty(String name) throws JMSException { + return message.getStringProperty(name); + } + + @Override + public Object getObjectProperty(String name) throws JMSException { + return message.getObjectProperty(name); + } + + @Override + public Enumeration<?> getPropertyNames() throws JMSException { + return message.getPropertyNames(); + } + + @Override + public void setBooleanProperty(String name, boolean value) throws JMSException { + message.setBooleanProperty(name, value); + } + + @Override + public void setByteProperty(String name, byte value) throws JMSException { + message.setByteProperty(name, value); + } + + @Override + public void setShortProperty(String name, short value) throws JMSException { + message.setShortProperty(name, value); + } + + @Override + public void setIntProperty(String name, int value) throws JMSException { + message.setIntProperty(name, value); + } + + @Override + public void setLongProperty(String name, long value) throws JMSException { + message.setLongProperty(name, value); + } + + @Override + public void setFloatProperty(String name, float value) throws JMSException { + message.setFloatProperty(name, value); + } + + @Override + public void setDoubleProperty(String name, double value) throws JMSException { + message.setDoubleProperty(name, value); + } + + @Override + public void setStringProperty(String name, String value) throws JMSException { + message.setStringProperty(name, value); + } + + @Override + public void setObjectProperty(String name, Object value) throws JMSException { + message.setObjectProperty(name, value); + } + + @Override + public void acknowledge() throws JMSException { + message.acknowledge(); + } + + @Override + public void clearBody() throws JMSException { + message.clearBody(); + } +} http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/12cc2f37/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsObjectMessage.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsObjectMessage.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsObjectMessage.java new file mode 100644 index 0000000..dcce895 --- /dev/null +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsObjectMessage.java @@ -0,0 +1,48 @@ +/** + * 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.jms.message.foreign; + +import java.io.Serializable; + +import javax.jms.JMSException; +import javax.jms.ObjectMessage; + +import org.apache.qpid.jms.message.JmsObjectMessage; +import org.apache.qpid.jms.message.facade.defaults.JmsDefaultObjectMessageFacade; + +/** + * Foreign JMS ObjectMessage class + */ +public class ForeignJmsObjectMessage extends ForeignJmsMessage implements ObjectMessage { + + private final JmsObjectMessage message; + + public ForeignJmsObjectMessage() { + super(new JmsObjectMessage(new JmsDefaultObjectMessageFacade())); + this.message = (JmsObjectMessage) super.message; + } + + @Override + public void setObject(Serializable object) throws JMSException { + message.setObject(object); + } + + @Override + public Serializable getObject() throws JMSException { + return message.getObject(); + } +} http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/12cc2f37/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsStreamMessage.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsStreamMessage.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsStreamMessage.java new file mode 100644 index 0000000..b35f455 --- /dev/null +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsStreamMessage.java @@ -0,0 +1,156 @@ +/** + * 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.jms.message.foreign; + +import javax.jms.JMSException; +import javax.jms.StreamMessage; + +import org.apache.qpid.jms.message.JmsStreamMessage; +import org.apache.qpid.jms.message.facade.defaults.JmsDefaultStreamMessageFacade; + +/** + * Foreign JMS StreamMessage class + */ +public class ForeignJmsStreamMessage extends ForeignJmsMessage implements StreamMessage { + + private final JmsStreamMessage message; + + public ForeignJmsStreamMessage() { + super(new JmsStreamMessage(new JmsDefaultStreamMessageFacade())); + this.message = (JmsStreamMessage) super.message; + } + + @Override + public boolean readBoolean() throws JMSException { + return message.readBoolean(); + } + + @Override + public byte readByte() throws JMSException { + return message.readByte(); + } + + @Override + public short readShort() throws JMSException { + return message.readShort(); + } + + @Override + public char readChar() throws JMSException { + return message.readChar(); + } + + @Override + public int readInt() throws JMSException { + return message.readInt(); + } + + @Override + public long readLong() throws JMSException { + return message.readLong(); + } + + @Override + public float readFloat() throws JMSException { + return message.readFloat(); + } + + @Override + public double readDouble() throws JMSException { + return message.readDouble(); + } + + @Override + public String readString() throws JMSException { + return message.readString(); + } + + @Override + public int readBytes(byte[] value) throws JMSException { + return message.readBytes(value); + } + + @Override + public Object readObject() throws JMSException { + return message.readObject(); + } + + @Override + public void writeBoolean(boolean value) throws JMSException { + message.writeBoolean(value); + } + + @Override + public void writeByte(byte value) throws JMSException { + message.writeByte(value); + } + + @Override + public void writeShort(short value) throws JMSException { + message.writeShort(value); + } + + @Override + public void writeChar(char value) throws JMSException { + message.writeChar(value); + } + + @Override + public void writeInt(int value) throws JMSException { + message.writeInt(value); + } + + @Override + public void writeLong(long value) throws JMSException { + message.writeLong(value); + } + + @Override + public void writeFloat(float value) throws JMSException { + message.writeFloat(value); + } + + @Override + public void writeDouble(double value) throws JMSException { + message.writeDouble(value); + } + + @Override + public void writeString(String value) throws JMSException { + message.writeString(value); + } + + @Override + public void writeBytes(byte[] value) throws JMSException { + message.writeBytes(value); + } + + @Override + public void writeBytes(byte[] value, int offset, int length) throws JMSException { + message.writeBytes(value, offset, length); + } + + @Override + public void writeObject(Object value) throws JMSException { + message.writeObject(value); + } + + @Override + public void reset() throws JMSException { + message.reset(); + } +} http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/12cc2f37/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsTextMessage.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsTextMessage.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsTextMessage.java new file mode 100644 index 0000000..1fd2c11 --- /dev/null +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsTextMessage.java @@ -0,0 +1,46 @@ +/** + * 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.jms.message.foreign; + +import javax.jms.JMSException; +import javax.jms.TextMessage; + +import org.apache.qpid.jms.message.JmsTextMessage; +import org.apache.qpid.jms.message.facade.defaults.JmsDefaultTextMessageFacade; + +/** + * Foreign JMS TextMessage class + */ +public class ForeignJmsTextMessage extends ForeignJmsMessage implements TextMessage { + + private final JmsTextMessage message; + + public ForeignJmsTextMessage() { + super(new JmsTextMessage(new JmsDefaultTextMessageFacade())); + this.message = (JmsTextMessage) super.message; + } + + @Override + public void setText(String string) throws JMSException { + message.setText(string); + } + + @Override + public String getText() throws JMSException { + return message.getText(); + } +} --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
