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) { }