diff options
Diffstat (limited to 'qpid/java/amqp-1-0-client-jms/example/src/main/java/org/apache/qpid/amqp_1_0/jms/example/Hello.java')
| -rw-r--r-- | qpid/java/amqp-1-0-client-jms/example/src/main/java/org/apache/qpid/amqp_1_0/jms/example/Hello.java | 20 |
1 files changed, 19 insertions, 1 deletions
diff --git a/qpid/java/amqp-1-0-client-jms/example/src/main/java/org/apache/qpid/amqp_1_0/jms/example/Hello.java b/qpid/java/amqp-1-0-client-jms/example/src/main/java/org/apache/qpid/amqp_1_0/jms/example/Hello.java index 5963068a69..97cbc837c4 100644 --- a/qpid/java/amqp-1-0-client-jms/example/src/main/java/org/apache/qpid/amqp_1_0/jms/example/Hello.java +++ b/qpid/java/amqp-1-0-client-jms/example/src/main/java/org/apache/qpid/amqp_1_0/jms/example/Hello.java @@ -97,6 +97,19 @@ public class Hello System.out.println("======================="); System.out.println(((BytesMessage) message).readUTF()); } + else if(message instanceof StreamMessage) + { + System.out.println("Received Stream Message:"); + System.out.println("========================"); + StreamMessage streamMessage = (StreamMessage)message; + Object o = streamMessage.readObject(); + System.out.println(o.getClass().getName() + ": " + o); + o = streamMessage.readObject(); + System.out.println(o.getClass().getName() + ": " + o); + o = streamMessage.readObject(); + System.out.println(o.getClass().getName() + ": " + o); + + } } catch (JMSException e) { @@ -126,7 +139,12 @@ public class Hello messageProducer.send(bytesMessage); - + StreamMessage streamMessage = producersession.createStreamMessage(); + streamMessage.writeBoolean(true); + streamMessage.writeLong(18031974L); + streamMessage.writeString("this is a stream Message"); + streamMessage.writeChar('£'); + messageProducer.send(streamMessage); Thread.sleep(50000L); |