You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2009/03/27 17:35:50 UTC
svn commit: r759210 -
/incubator/cassandra/trunk/src/org/apache/cassandra/net/Message.java
Author: jbellis
Date: Fri Mar 27 16:35:49 2009
New Revision: 759210
URL: http://svn.apache.org/viewvc?rev=759210&view=rev
Log:
change Object[] to Object... so passing a single one is easier
Modified:
incubator/cassandra/trunk/src/org/apache/cassandra/net/Message.java
Modified: incubator/cassandra/trunk/src/org/apache/cassandra/net/Message.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/net/Message.java?rev=759210&r1=759209&r2=759210&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/org/apache/cassandra/net/Message.java (original)
+++ incubator/cassandra/trunk/src/org/apache/cassandra/net/Message.java Fri Mar 27 16:35:49 2009
@@ -53,27 +53,20 @@
Header header_;
private Object[] body_ = new Object[0];
- /* Ctor for JAXB. DO NOT DELETE */
- private Message()
+ protected Message(String id, EndPoint from, String messageType, String verb, Object... body)
{
- }
-
- protected Message(String id, EndPoint from, String messageType, String verb, Object[] body)
- {
- header_ = new Header(id, from, messageType, verb);
- body_ = body;
+ this(new Header(id, from, messageType, verb), body);
}
- protected Message(Header header, Object[] body)
+ protected Message(Header header, Object... body)
{
header_ = header;
body_ = body;
}
- public Message(EndPoint from, String messageType, String verb, Object[] body)
+ public Message(EndPoint from, String messageType, String verb, Object... body)
{
- header_ = new Header(from, messageType, verb);
- body_ = body;
+ this(new Header(from, messageType, verb), body);
}
public byte[] getHeader(Object key)
@@ -164,7 +157,7 @@
header_.setMessageId(id);
}
- public Message getReply(EndPoint from, Object[] args)
+ public Message getReply(EndPoint from, Object... args)
{
Message response = new Message(getMessageId(),
from,