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 2010/01/18 23:43:14 UTC
svn commit: r900593 - in
/incubator/cassandra/trunk/src/java/org/apache/cassandra:
db/RowMutation.java utils/FBUtilities.java
Author: jbellis
Date: Mon Jan 18 22:43:14 2010
New Revision: 900593
URL: http://svn.apache.org/viewvc?rev=900593&view=rev
Log:
minor cleanup. patch by jbellis
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutation.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/utils/FBUtilities.java
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutation.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutation.java?rev=900593&r1=900592&r2=900593&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutation.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutation.java Mon Jan 18 22:43:14 2010
@@ -208,15 +208,10 @@
public Message makeRowMutationMessage() throws IOException
{
- return makeRowMutationMessage(StorageService.mutationVerbHandler_);
- }
-
- public Message makeRowMutationMessage(String verbHandlerName) throws IOException
- {
ByteArrayOutputStream bos = new ByteArrayOutputStream();
DataOutputStream dos = new DataOutputStream(bos);
serializer().serialize(this, dos);
- return new Message(FBUtilities.getLocalAddress(), StageManager.MUTATION_STAGE, verbHandlerName, bos.toByteArray());
+ return new Message(FBUtilities.getLocalAddress(), StageManager.MUTATION_STAGE, StorageService.mutationVerbHandler_, bos.toByteArray());
}
public static RowMutation getRowMutationFromMutations(String keyspace, String key, Map<String, List<Mutation>> cfmap)
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/utils/FBUtilities.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/utils/FBUtilities.java?rev=900593&r1=900592&r2=900593&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/utils/FBUtilities.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/utils/FBUtilities.java Mon Jan 18 22:43:14 2010
@@ -275,7 +275,7 @@
public static String mapToString(Map<?,?> map)
{
- StringBuilder sb = new StringBuilder("");
+ StringBuilder sb = new StringBuilder("{");
for (Map.Entry entry : map.entrySet())
{