Author: robbie
Date: Fri Jun 20 16:03:13 2014
New Revision: 1604199
URL: http://svn.apache.org/r1604199
Log:
PROTON-613: send 'Hello World!' in the message if no alternative bodies are
provided. Use the same initial address as other languages
Modified:
qpid/proton/trunk/examples/messenger/java/src/main/java/org/apache/qpid/proton/example/Send.java
Modified:
qpid/proton/trunk/examples/messenger/java/src/main/java/org/apache/qpid/proton/example/Send.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/examples/messenger/java/src/main/java/org/apache/qpid/proton/example/Send.java?rev=1604199&r1=1604198&r2=1604199&view=diff
==============================================================================
---
qpid/proton/trunk/examples/messenger/java/src/main/java/org/apache/qpid/proton/example/Send.java
(original)
+++
qpid/proton/trunk/examples/messenger/java/src/main/java/org/apache/qpid/proton/example/Send.java
Fri Jun 20 16:03:13 2014
@@ -40,9 +40,9 @@ import java.util.logging.Logger;
public class Send {
private static Logger tracer = Logger.getLogger("proton.example");
- private String address = "amqp://0.0.0.0/test";
+ private String address = "amqp://0.0.0.0";
private String subject;
- private String[] bodies;
+ private String[] bodies = new String[]{"Hello World!"};
private static void usage() {
System.err.println("Usage: send [-a ADDRESS] [-s SUBJECT] MSG+");
@@ -67,7 +67,11 @@ public class Send {
break;
}
}
- bodies = Arrays.copyOfRange(args, i, args.length);
+
+ if(i != args.length)
+ {
+ bodies = Arrays.copyOfRange(args, i, args.length);
+ }
}
private void run() {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
