QueueReceiver qr = s_rec.createReceiver(q);
/* Create a sender for sending messages */
QueueSender qsender = s_send.createSender(q);
qsender.setDisableMessageTimestamp(false);
/* create a text message for sending */
StreamMessage msg = s_send.createStreamMessage();
/* and write values into it */
msg.writeByte((byte)0);
msg.writeBoolean(true);
msg.writeChar('c');
msg.writeDouble(1.11d);
msg.writeFloat(1.1f);
msg.writeInt(1);
msg.writeShort((short)1);
msg.writeString(TEXT);
/* Send the message */
qsender.send(msg);
/* Commit the sending session */
s_send.commit();
/* Receive the message */
msg = (StreamMessage) qr.receiveNoWait();
Assert.assertNotNull("message recieved", msg);
/* Commit the session to clear the queue */
s_rec.commit();
/* Check, that the text of the message is still the same */
Assert.assertEquals("byte", msg.readByte(), (byte) 0);
Assert.assertEquals("boolean", msg.readBoolean(), true);
Assert.assertEquals("char", msg.readChar(), 'c');
Assert.assertEquals("double", msg.readDouble(), 1.11d, 0);
Assert.assertEquals("float", msg.readFloat(), 1.1f, 0);
Assert.assertEquals("int", msg.readInt(), 1);
Assert.assertEquals("short", msg.readShort(), (short) 1);
Assert.assertEquals("string", msg.readString(), TEXT);
} finally {
try {
s_rec.close();
} catch (Exception ex) {