activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r464620 [3/6] - in /incubator/activemq/sandbox/qpid: src/main/java/org/apache/activemq/qpid/command/ src/main/java/org/apache/activemq/qpid/transport/ src/main/java/org/apache/activemq/qpid/wireformat/ src/main/java/org/apache/activemq/qpid...
Date Mon, 16 Oct 2006 18:48:05 GMT
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -45,7 +45,55 @@
     public String routingKey;    
     public boolean nowait;    
     public FieldTable arguments;    
-     
+    
+    public void setTicket(int ticket) {
+    	this.ticket = ticket;
+   	}
+    public int getTicket() {
+    	return this.ticket;
+   	}   	
+   	
+    public void setQueue(String queue) {
+    	this.queue = queue;
+   	}
+    public String getQueue() {
+    	return this.queue;
+   	}   	
+   	
+    public void setExchange(String exchange) {
+    	this.exchange = exchange;
+   	}
+    public String getExchange() {
+    	return this.exchange;
+   	}   	
+   	
+    public void setRoutingKey(String routingKey) {
+    	this.routingKey = routingKey;
+   	}
+    public String getRoutingKey() {
+    	return this.routingKey;
+   	}   	
+   	
+    public void setNowait(boolean nowait) {
+    	this.nowait = nowait;
+   	}
+    public boolean getNowait() {
+    	return this.nowait;
+   	}   	
+   	
+    public void setArguments(FieldTable arguments) {
+    	this.arguments = arguments;
+   	}
+    public FieldTable getArguments() {
+    	return this.arguments;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processQueueBindBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,6 +40,12 @@
     }
 
      
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processQueueBindOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -47,7 +47,69 @@
     public boolean autoDelete;    
     public boolean nowait;    
     public FieldTable arguments;    
-     
+    
+    public void setTicket(int ticket) {
+    	this.ticket = ticket;
+   	}
+    public int getTicket() {
+    	return this.ticket;
+   	}   	
+   	
+    public void setQueue(String queue) {
+    	this.queue = queue;
+   	}
+    public String getQueue() {
+    	return this.queue;
+   	}   	
+   	
+    public void setPassive(boolean passive) {
+    	this.passive = passive;
+   	}
+    public boolean getPassive() {
+    	return this.passive;
+   	}   	
+   	
+    public void setDurable(boolean durable) {
+    	this.durable = durable;
+   	}
+    public boolean getDurable() {
+    	return this.durable;
+   	}   	
+   	
+    public void setExclusive(boolean exclusive) {
+    	this.exclusive = exclusive;
+   	}
+    public boolean getExclusive() {
+    	return this.exclusive;
+   	}   	
+   	
+    public void setAutoDelete(boolean autoDelete) {
+    	this.autoDelete = autoDelete;
+   	}
+    public boolean getAutoDelete() {
+    	return this.autoDelete;
+   	}   	
+   	
+    public void setNowait(boolean nowait) {
+    	this.nowait = nowait;
+   	}
+    public boolean getNowait() {
+    	return this.nowait;
+   	}   	
+   	
+    public void setArguments(FieldTable arguments) {
+    	this.arguments = arguments;
+   	}
+    public FieldTable getArguments() {
+    	return this.arguments;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processQueueDeclareBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -42,7 +42,34 @@
     public String queue;    
     public long messageCount;    
     public long consumerCount;    
-     
+    
+    public void setQueue(String queue) {
+    	this.queue = queue;
+   	}
+    public String getQueue() {
+    	return this.queue;
+   	}   	
+   	
+    public void setMessageCount(long messageCount) {
+    	this.messageCount = messageCount;
+   	}
+    public long getMessageCount() {
+    	return this.messageCount;
+   	}   	
+   	
+    public void setConsumerCount(long consumerCount) {
+    	this.consumerCount = consumerCount;
+   	}
+    public long getConsumerCount() {
+    	return this.consumerCount;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processQueueDeclareOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -44,7 +44,48 @@
     public boolean ifUnused;    
     public boolean ifEmpty;    
     public boolean nowait;    
-     
+    
+    public void setTicket(int ticket) {
+    	this.ticket = ticket;
+   	}
+    public int getTicket() {
+    	return this.ticket;
+   	}   	
+   	
+    public void setQueue(String queue) {
+    	this.queue = queue;
+   	}
+    public String getQueue() {
+    	return this.queue;
+   	}   	
+   	
+    public void setIfUnused(boolean ifUnused) {
+    	this.ifUnused = ifUnused;
+   	}
+    public boolean getIfUnused() {
+    	return this.ifUnused;
+   	}   	
+   	
+    public void setIfEmpty(boolean ifEmpty) {
+    	this.ifEmpty = ifEmpty;
+   	}
+    public boolean getIfEmpty() {
+    	return this.ifEmpty;
+   	}   	
+   	
+    public void setNowait(boolean nowait) {
+    	this.nowait = nowait;
+   	}
+    public boolean getNowait() {
+    	return this.nowait;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processQueueDeleteBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,7 +40,20 @@
     }
 
     public long messageCount;    
-     
+    
+    public void setMessageCount(long messageCount) {
+    	this.messageCount = messageCount;
+   	}
+    public long getMessageCount() {
+    	return this.messageCount;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processQueueDeleteOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -42,7 +42,34 @@
     public int ticket;    
     public String queue;    
     public boolean nowait;    
-     
+    
+    public void setTicket(int ticket) {
+    	this.ticket = ticket;
+   	}
+    public int getTicket() {
+    	return this.ticket;
+   	}   	
+   	
+    public void setQueue(String queue) {
+    	this.queue = queue;
+   	}
+    public String getQueue() {
+    	return this.queue;
+   	}   	
+   	
+    public void setNowait(boolean nowait) {
+    	this.nowait = nowait;
+   	}
+    public boolean getNowait() {
+    	return this.nowait;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processQueuePurgeBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,7 +40,20 @@
     }
 
     public long messageCount;    
-     
+    
+    public void setMessageCount(long messageCount) {
+    	this.messageCount = messageCount;
+   	}
+    public long getMessageCount() {
+    	return this.messageCount;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processQueuePurgeOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -41,7 +41,27 @@
 
     public String consumerTag;    
     public boolean nowait;    
-     
+    
+    public void setConsumerTag(String consumerTag) {
+    	this.consumerTag = consumerTag;
+   	}
+    public String getConsumerTag() {
+    	return this.consumerTag;
+   	}   	
+   	
+    public void setNowait(boolean nowait) {
+    	this.nowait = nowait;
+   	}
+    public boolean getNowait() {
+    	return this.nowait;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processStreamCancelBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,7 +40,20 @@
     }
 
     public String consumerTag;    
-     
+    
+    public void setConsumerTag(String consumerTag) {
+    	this.consumerTag = consumerTag;
+   	}
+    public String getConsumerTag() {
+    	return this.consumerTag;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processStreamCancelOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -45,7 +45,55 @@
     public boolean noLocal;    
     public boolean exclusive;    
     public boolean nowait;    
-     
+    
+    public void setTicket(int ticket) {
+    	this.ticket = ticket;
+   	}
+    public int getTicket() {
+    	return this.ticket;
+   	}   	
+   	
+    public void setQueue(String queue) {
+    	this.queue = queue;
+   	}
+    public String getQueue() {
+    	return this.queue;
+   	}   	
+   	
+    public void setConsumerTag(String consumerTag) {
+    	this.consumerTag = consumerTag;
+   	}
+    public String getConsumerTag() {
+    	return this.consumerTag;
+   	}   	
+   	
+    public void setNoLocal(boolean noLocal) {
+    	this.noLocal = noLocal;
+   	}
+    public boolean getNoLocal() {
+    	return this.noLocal;
+   	}   	
+   	
+    public void setExclusive(boolean exclusive) {
+    	this.exclusive = exclusive;
+   	}
+    public boolean getExclusive() {
+    	return this.exclusive;
+   	}   	
+   	
+    public void setNowait(boolean nowait) {
+    	this.nowait = nowait;
+   	}
+    public boolean getNowait() {
+    	return this.nowait;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processStreamConsumeBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,7 +40,20 @@
     }
 
     public String consumerTag;    
-     
+    
+    public void setConsumerTag(String consumerTag) {
+    	this.consumerTag = consumerTag;
+   	}
+    public String getConsumerTag() {
+    	return this.consumerTag;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processStreamConsumeOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -43,7 +43,41 @@
     public long deliveryTag;    
     public String exchange;    
     public String queue;    
-     
+    
+    public void setConsumerTag(String consumerTag) {
+    	this.consumerTag = consumerTag;
+   	}
+    public String getConsumerTag() {
+    	return this.consumerTag;
+   	}   	
+   	
+    public void setDeliveryTag(long deliveryTag) {
+    	this.deliveryTag = deliveryTag;
+   	}
+    public long getDeliveryTag() {
+    	return this.deliveryTag;
+   	}   	
+   	
+    public void setExchange(String exchange) {
+    	this.exchange = exchange;
+   	}
+    public String getExchange() {
+    	return this.exchange;
+   	}   	
+   	
+    public void setQueue(String queue) {
+    	this.queue = queue;
+   	}
+    public String getQueue() {
+    	return this.queue;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processStreamDeliverBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -44,7 +44,48 @@
     public String routingKey;    
     public boolean mandatory;    
     public boolean immediate;    
-     
+    
+    public void setTicket(int ticket) {
+    	this.ticket = ticket;
+   	}
+    public int getTicket() {
+    	return this.ticket;
+   	}   	
+   	
+    public void setExchange(String exchange) {
+    	this.exchange = exchange;
+   	}
+    public String getExchange() {
+    	return this.exchange;
+   	}   	
+   	
+    public void setRoutingKey(String routingKey) {
+    	this.routingKey = routingKey;
+   	}
+    public String getRoutingKey() {
+    	return this.routingKey;
+   	}   	
+   	
+    public void setMandatory(boolean mandatory) {
+    	this.mandatory = mandatory;
+   	}
+    public boolean getMandatory() {
+    	return this.mandatory;
+   	}   	
+   	
+    public void setImmediate(boolean immediate) {
+    	this.immediate = immediate;
+   	}
+    public boolean getImmediate() {
+    	return this.immediate;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processStreamPublishBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -43,7 +43,41 @@
     public int prefetchCount;    
     public long consumeRate;    
     public boolean global;    
-     
+    
+    public void setPrefetchSize(long prefetchSize) {
+    	this.prefetchSize = prefetchSize;
+   	}
+    public long getPrefetchSize() {
+    	return this.prefetchSize;
+   	}   	
+   	
+    public void setPrefetchCount(int prefetchCount) {
+    	this.prefetchCount = prefetchCount;
+   	}
+    public int getPrefetchCount() {
+    	return this.prefetchCount;
+   	}   	
+   	
+    public void setConsumeRate(long consumeRate) {
+    	this.consumeRate = consumeRate;
+   	}
+    public long getConsumeRate() {
+    	return this.consumeRate;
+   	}   	
+   	
+    public void setGlobal(boolean global) {
+    	this.global = global;
+   	}
+    public boolean getGlobal() {
+    	return this.global;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processStreamQosBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,6 +40,12 @@
     }
 
      
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processStreamQosOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -43,7 +43,41 @@
     public String replyText;    
     public String exchange;    
     public String routingKey;    
-     
+    
+    public void setReplyCode(int replyCode) {
+    	this.replyCode = replyCode;
+   	}
+    public int getReplyCode() {
+    	return this.replyCode;
+   	}   	
+   	
+    public void setReplyText(String replyText) {
+    	this.replyText = replyText;
+   	}
+    public String getReplyText() {
+    	return this.replyText;
+   	}   	
+   	
+    public void setExchange(String exchange) {
+    	this.exchange = exchange;
+   	}
+    public String getExchange() {
+    	return this.exchange;
+   	}   	
+   	
+    public void setRoutingKey(String routingKey) {
+    	this.routingKey = routingKey;
+   	}
+    public String getRoutingKey() {
+    	return this.routingKey;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processStreamReturnBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,6 +40,12 @@
     }
 
      
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTestContentBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,7 +40,20 @@
     }
 
     public long contentChecksum;    
-     
+    
+    public void setContentChecksum(long contentChecksum) {
+    	this.contentChecksum = contentChecksum;
+   	}
+    public long getContentChecksum() {
+    	return this.contentChecksum;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTestContentOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -44,7 +44,48 @@
     public long integer3;    
     public long integer4;    
     public short operation;    
-     
+    
+    public void setInteger1(short integer1) {
+    	this.integer1 = integer1;
+   	}
+    public short getInteger1() {
+    	return this.integer1;
+   	}   	
+   	
+    public void setInteger2(int integer2) {
+    	this.integer2 = integer2;
+   	}
+    public int getInteger2() {
+    	return this.integer2;
+   	}   	
+   	
+    public void setInteger3(long integer3) {
+    	this.integer3 = integer3;
+   	}
+    public long getInteger3() {
+    	return this.integer3;
+   	}   	
+   	
+    public void setInteger4(long integer4) {
+    	this.integer4 = integer4;
+   	}
+    public long getInteger4() {
+    	return this.integer4;
+   	}   	
+   	
+    public void setOperation(short operation) {
+    	this.operation = operation;
+   	}
+    public short getOperation() {
+    	return this.operation;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTestIntegerBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,7 +40,20 @@
     }
 
     public long result;    
-     
+    
+    public void setResult(long result) {
+    	this.result = result;
+   	}
+    public long getResult() {
+    	return this.result;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTestIntegerOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -42,7 +42,34 @@
     public String string1;    
     public byte[] string2;    
     public short operation;    
-     
+    
+    public void setString1(String string1) {
+    	this.string1 = string1;
+   	}
+    public String getString1() {
+    	return this.string1;
+   	}   	
+   	
+    public void setString2(byte[] string2) {
+    	this.string2 = string2;
+   	}
+    public byte[] getString2() {
+    	return this.string2;
+   	}   	
+   	
+    public void setOperation(short operation) {
+    	this.operation = operation;
+   	}
+    public short getOperation() {
+    	return this.operation;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTestStringBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,7 +40,20 @@
     }
 
     public byte[] result;    
-     
+    
+    public void setResult(byte[] result) {
+    	this.result = result;
+   	}
+    public byte[] getResult() {
+    	return this.result;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTestStringOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -42,7 +42,34 @@
     public FieldTable table;    
     public short integerOp;    
     public short stringOp;    
-     
+    
+    public void setTable(FieldTable table) {
+    	this.table = table;
+   	}
+    public FieldTable getTable() {
+    	return this.table;
+   	}   	
+   	
+    public void setIntegerOp(short integerOp) {
+    	this.integerOp = integerOp;
+   	}
+    public short getIntegerOp() {
+    	return this.integerOp;
+   	}   	
+   	
+    public void setStringOp(short stringOp) {
+    	this.stringOp = stringOp;
+   	}
+    public short getStringOp() {
+    	return this.stringOp;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTestTableBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -41,7 +41,27 @@
 
     public long integerResult;    
     public byte[] stringResult;    
-     
+    
+    public void setIntegerResult(long integerResult) {
+    	this.integerResult = integerResult;
+   	}
+    public long getIntegerResult() {
+    	return this.integerResult;
+   	}   	
+   	
+    public void setStringResult(byte[] stringResult) {
+    	this.stringResult = stringResult;
+   	}
+    public byte[] getStringResult() {
+    	return this.stringResult;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTestTableOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,7 +40,20 @@
     }
 
     public FieldTable metaData;    
-     
+    
+    public void setMetaData(FieldTable metaData) {
+    	this.metaData = metaData;
+   	}
+    public FieldTable getMetaData() {
+    	return this.metaData;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTunnelRequestBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,6 +40,12 @@
     }
 
      
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTxCommitBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,6 +40,12 @@
     }
 
      
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTxCommitOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,6 +40,12 @@
     }
 
      
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTxRollbackBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,6 +40,12 @@
     }
 
      
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTxRollbackOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,6 +40,12 @@
     }
 
      
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTxSelectBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
 /**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*    http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
     
 package org.apache.activemq.qpid.command;
 
@@ -40,6 +40,12 @@
     }
 
      
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processTxSelectOkBody(this);
+    }
 
     public String toString()
     {



Mime
View raw message