You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/01/09 12:31:39 UTC
svn commit: r367276 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/
Author: jstrachan
Date: Mon Jan 9 03:31:05 2006
New Revision: 367276
URL: http://svn.apache.org/viewcvs?rev=367276&view=rev
Log:
added the numeric values from CommandTypes to the annotations for generation of other languages
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTransaction.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveSubscriptionInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Response.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionId.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ShutdownInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java Mon Jan 9 03:31:05 2006
@@ -63,7 +63,7 @@
* <CODE>MessageNotReadableException</CODE> is thrown. <P> If a client attempts to write a message in read-only mode, a
* <CODE>MessageNotWriteableException</CODE> is thrown.
*
- * @openwire:marshaller
+ * @openwire:marshaller code=24
* @see javax.jms.Session#createBytesMessage()
* @see javax.jms.MapMessage
* @see javax.jms.Message
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java Mon Jan 9 03:31:05 2006
@@ -68,7 +68,7 @@
* <code>String</code> conversion, attempting to read a null value as a <code>char</code> must throw a
* <code>NullPointerException</code>.
*
- * @openwire:marshaller
+ * @openwire:marshaller code="25"
* @see javax.jms.Session#createMapMessage()
* @see javax.jms.BytesMessage
* @see javax.jms.Message
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java Mon Jan 9 03:31:05 2006
@@ -35,8 +35,9 @@
import org.apache.activemq.util.TypeConversionSupport;
/**
- * @version $Revision$
- * @openwire:marshaller
+ * @openwire:marshaller code="23"
+ *
+ * @version $Revision:$
*/
public class ActiveMQMessage extends Message implements javax.jms.Message {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java Mon Jan 9 03:31:05 2006
@@ -54,7 +54,7 @@
* the message at this point, a <CODE>MessageNotWriteableException</CODE> is thrown. If <CODE>clearBody</CODE> is
* called, the message can now be both read from and written to.
*
- * @openwire:marshaller
+ * @openwire:marshaller code="26"
* @see javax.jms.Session#createObjectMessage()
* @see javax.jms.Session#createObjectMessage(Serializable)
* @see javax.jms.BytesMessage
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java Mon Jan 9 03:31:05 2006
@@ -20,7 +20,7 @@
import javax.jms.Queue;
/**
- * @openwire:marshaller
+ * @openwire:marshaller code="100"
* @version $Revision: 1.5 $
*/
public class ActiveMQQueue extends ActiveMQDestination implements Queue {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java Mon Jan 9 03:31:05 2006
@@ -96,7 +96,7 @@
* support a <code>String</code> conversion, attempting to read a null value
* as a <code>char</code> must throw a <code>NullPointerException</code>.
*
- * @openwire:marshaller
+ * @openwire:marshaller code="27"
* @see javax.jms.Session#createStreamMessage()
* @see javax.jms.BytesMessage
* @see javax.jms.MapMessage
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java Mon Jan 9 03:31:05 2006
@@ -20,7 +20,7 @@
import javax.jms.TemporaryQueue;
/**
- * @openwire:marshaller
+ * @openwire:marshaller code="102"
* @version $Revision: 1.6 $
*/
public class ActiveMQTempQueue extends ActiveMQTempDestination implements TemporaryQueue {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java Mon Jan 9 03:31:05 2006
@@ -20,7 +20,7 @@
import javax.jms.TemporaryTopic;
/**
- * @openwire:marshaller
+ * @openwire:marshaller code="103"
* @version $Revision: 1.6 $
*/
public class ActiveMQTempTopic extends ActiveMQTempDestination implements TemporaryTopic {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java Mon Jan 9 03:31:05 2006
@@ -38,7 +38,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="28"
* @version $Revision$
*/
public class ActiveMQTextMessage extends ActiveMQMessage implements TextMessage {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java Mon Jan 9 03:31:05 2006
@@ -20,7 +20,7 @@
import javax.jms.Topic;
/**
- * @openwire:marshaller
+ * @openwire:marshaller code="101"
* @version $Revision: 1.5 $
*/
public class ActiveMQTopic extends ActiveMQDestination implements Topic {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java Mon Jan 9 03:31:05 2006
@@ -19,7 +19,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="124"
* @version $Revision$
*/
public class BrokerId implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java Mon Jan 9 03:31:05 2006
@@ -25,7 +25,7 @@
* that the node has in his cluster. This is the broker helping the client out
* in discovering other nodes in the cluster.
*
- * @openwire:marshaller
+ * @openwire:marshaller code="2"
* @version $Revision: 1.7 $
*/
public class BrokerInfo extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java Mon Jan 9 03:31:05 2006
@@ -44,7 +44,6 @@
byte KEEP_ALIVE_INFO = 10;
byte SHUTDOWN_INFO = 11;
byte REMOVE_INFO = 12;
- byte REDELIVERY_POLICY = 13;
byte CONTROL_COMMAND = 14;
byte FLUSH_COMMAND = 15;
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java Mon Jan 9 03:31:05 2006
@@ -19,7 +19,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="120"
* @version $Revision$
*/
public class ConnectionId implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java Mon Jan 9 03:31:05 2006
@@ -21,7 +21,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="3"
* @version $Revision: 1.11 $
*/
public class ConnectionInfo extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java Mon Jan 9 03:31:05 2006
@@ -19,7 +19,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="122"
* @version $Revision$
*/
public class ConsumerId implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java Mon Jan 9 03:31:05 2006
@@ -22,7 +22,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="5"
* @version $Revision: 1.20 $
*/
public class ConsumerInfo extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java Mon Jan 9 03:31:05 2006
@@ -21,7 +21,7 @@
/**
* Used to start and stop transports as well as terminating clients.
*
- * @openwire:marshaller
+ * @openwire:marshaller code="14"
*
* @version $Revision: 1.1 $
*/
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="33"
* @version $Revision$
*/
public class DataArrayResponse extends Response {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="32"
* @version $Revision$
*/
public class DataResponse extends Response {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java Mon Jan 9 03:31:05 2006
@@ -23,7 +23,7 @@
/**
* Used to create and destroy destinations on the broker.
*
- * @openwire:marshaller
+ * @openwire:marshaller code="8"
* @version $Revision: 1.9 $
*/
public class DestinationInfo extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java Mon Jan 9 03:31:05 2006
@@ -20,7 +20,8 @@
/**
* Represents a discovery event containing the details of the service
*
- * @version $Revision$
+ * @openwire:marshaller code="55"
+ * @version $Revision:$
*/
public class DiscoveryEvent implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="31"
* @version $Revision: 1.4 $
*/
public class ExceptionResponse extends Response {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java Mon Jan 9 03:31:05 2006
@@ -21,7 +21,7 @@
/**
* An indication to the transport layer that a flush is required.
*
- * @openwire:marshaller
+ * @openwire:marshaller code="15"
* @version $Revision$
*/
public class FlushCommand extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="34"
* @version $Revision$
*/
public class IntegerResponse extends Response {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="52"
* @version $Revision$
*/
public class JournalQueueAck implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="50"
* @version $Revision$
*/
public class JournalTopicAck implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="53"
* @version $Revision: 1.6 $
*/
public class JournalTrace implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTransaction.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTransaction.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTransaction.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTransaction.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
- * @openwire:marshaller
+ * @openwire:marshaller code="54"
*/
public class JournalTransaction implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java Mon Jan 9 03:31:05 2006
@@ -19,7 +19,7 @@
import org.apache.activemq.state.CommandVisitor;
/**
- * @openwire:marshaller
+ * @openwire:marshaller code="10"
* @version $Revision$
*/
public class KeepAliveInfo implements Command {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java Mon Jan 9 03:31:05 2006
@@ -17,7 +17,7 @@
package org.apache.activemq.command;
/**
- * @openwire:marshaller
+ * @openwire:marshaller code="111"
* @version $Revision: 1.11 $
*/
public class LocalTransactionId extends TransactionId {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java Mon Jan 9 03:31:05 2006
@@ -21,7 +21,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="22"
* @version $Revision: 1.11 $
*/
public class MessageAck extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java Mon Jan 9 03:31:05 2006
@@ -21,7 +21,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="21"
* @version $Revision$
*/
public class MessageDispatch extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
- * @openwire:marshaller
+ * @openwire:marshaller code="110"
* @version $Revision: 1.12 $
*/
public class MessageId implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="123"
* @version $Revision$
*/
public class ProducerId implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerInfo.java Mon Jan 9 03:31:05 2006
@@ -20,7 +20,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="6"
* @version $Revision: 1.13 $
*/
public class ProducerInfo extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveInfo.java Mon Jan 9 03:31:05 2006
@@ -23,7 +23,7 @@
/**
* Removes a consumer, producer, session or connection.
*
- * @openwire:marshaller
+ * @openwire:marshaller code="12"
* @version $Revision$
*/
public class RemoveInfo extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveSubscriptionInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveSubscriptionInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveSubscriptionInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveSubscriptionInfo.java Mon Jan 9 03:31:05 2006
@@ -20,7 +20,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller command="9"
* @version $Revision: 1.7 $
*/
public class RemoveSubscriptionInfo extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Response.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Response.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Response.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Response.java Mon Jan 9 03:31:05 2006
@@ -19,7 +19,7 @@
import org.apache.activemq.state.CommandVisitor;
/**
- * @openwire:marshaller
+ * @openwire:marshaller code="30"
* @version $Revision: 1.6 $
*/
public class Response extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionId.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionId.java Mon Jan 9 03:31:05 2006
@@ -18,7 +18,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="121"
* @version $Revision$
*/
public class SessionId implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionInfo.java Mon Jan 9 03:31:05 2006
@@ -20,7 +20,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="4"
* @version $Revision: 1.13 $
*/
public class SessionInfo extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ShutdownInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ShutdownInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ShutdownInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ShutdownInfo.java Mon Jan 9 03:31:05 2006
@@ -20,7 +20,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="11"
* @version $Revision$
*/
public class ShutdownInfo extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java Mon Jan 9 03:31:05 2006
@@ -21,7 +21,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="55"
* @version $Revision: 1.6 $
*/
public class SubscriptionInfo implements DataStructure {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionInfo.java Mon Jan 9 03:31:05 2006
@@ -22,7 +22,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="7"
* @version $Revision: 1.10 $
*/
public class TransactionInfo extends BaseCommand {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java Mon Jan 9 03:31:05 2006
@@ -22,7 +22,7 @@
/**
*
- * @openwire:marshaller
+ * @openwire:marshaller code="1"
* @version $Revision$
*/
public class WireFormatInfo implements Command {
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java?rev=367276&r1=367275&r2=367276&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java Mon Jan 9 03:31:05 2006
@@ -24,7 +24,7 @@
/**
- * @openwire:marshaller
+ * @openwire:marshaller code="112"
* @version $Revision: 1.6 $
*/
public class XATransactionId extends TransactionId implements Xid {