From 2292fb63f67cfebe586df12fc707860d7e8aa222 Mon Sep 17 00:00:00 2001
From: brettlangdon <brett@blangdon.com>
Date: Wed, 13 Jun 2012 10:07:51 -0400
Subject: [PATCH] ensured that flume events were being properly converted to
 strings before sending to hornet

---
 src/com/blangdon/flume/hornetq/HornetQJMSSink.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/com/blangdon/flume/hornetq/HornetQJMSSink.java b/src/com/blangdon/flume/hornetq/HornetQJMSSink.java
index af54e21..644b790 100644
--- a/src/com/blangdon/flume/hornetq/HornetQJMSSink.java
+++ b/src/com/blangdon/flume/hornetq/HornetQJMSSink.java
@@ -78,7 +78,8 @@ public class HornetQJMSSink extends EventSink.Base {
 	if( this.session == null || this.producer == null )
 	    throw new IllegalStateException("HornetQSink Not Initialized Properly: " + e);
 	try{
-	    TextMessage event = (TextMessage)session.createTextMessage(e.getBody().toString());
+	    String message = new String(e.getBody());
+	    TextMessage event = (TextMessage)session.createTextMessage(message);
 	    this.producer.send(event);
 	}catch(Exception ex){
 	    throw new IOException("HornetQ Exception: " + e);