[hornetq-commits] JBoss hornetq SVN: r8839 - in branches/HORNETQ-129_STOMP_protocol/src/main/org/hornetq: core/protocol/core/impl and 1 other directory.
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)
{
}