[hornetq-commits] JBoss hornetq SVN: r8839 - in branches/HORNETQ-129_STOMP_protocol/src/main/org/hornetq: core/protocol/core/impl and 1 other directory.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-01-22 07:23:23 -0500 (Fri, 22 Jan 2010)
New Revision: 8839

Modified:
   branches/HORNETQ-129_STOMP_protocol/src/main/org/hornetq/api/core/Message.java
   branches/HORNETQ-129_STOMP_protocol/src/main/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-129: Implement STOMP v1.0

* updated code with trunk's refactoring of protocol support

Modified: branches/HORNETQ-129_STOMP_protocol/src/main/org/hornetq/api/core/Message.java
===================================================================
--- branches/HORNETQ-129_STOMP_protocol/src/main/org/hornetq/api/core/Message.java	2010-01-22 12:22:23 UTC (rev 8838)
+++ branches/HORNETQ-129_STOMP_protocol/src/main/org/hornetq/api/core/Message.java	2010-01-22 12:23:23 UTC (rev 8839)
@@ -70,6 +70,18 @@
 
    public static final SimpleString HDR_LAST_VALUE_NAME = new SimpleString("_HQ_LVQ_NAME");
 
+   public static final byte DEFAULT_TYPE = 0;
+
+   public static final byte OBJECT_TYPE = 2;
+
+   public static final byte TEXT_TYPE = 3;
+
+   public static final byte BYTES_TYPE = 4;
+
+   public static final byte MAP_TYPE = 5;
+
+   public static final byte STREAM_TYPE = 6;
+   
    /**
     * Returns the messageID.
     * <br>

Modified: branches/HORNETQ-129_STOMP_protocol/src/main/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java
===================================================================
--- branches/HORNETQ-129_STOMP_protocol/src/main/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java	2010-01-22 12:22:23 UTC (rev 8838)
+++ branches/HORNETQ-129_STOMP_protocol/src/main/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java	2010-01-22 12:23:23 UTC (rev 8839)
@@ -30,6 +30,7 @@
 import org.hornetq.core.server.HornetQServer;
 import org.hornetq.spi.core.protocol.ConnectionEntry;
 import org.hornetq.spi.core.protocol.ProtocolManager;
+import org.hornetq.spi.core.protocol.RemotingConnection;
 import org.hornetq.spi.core.remoting.Connection;
 
 /**
@@ -120,7 +121,7 @@
       sessionHandlers.remove(name);
    }
 
-   public void bufferReceived(Object connectionID, HornetQBuffer buffer)
+   public void handleBuffer(RemotingConnection connection, HornetQBuffer buffer)
    {
    }