activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r464620 [2/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/ConnectionCloseOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.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.processConnectionCloseOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.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 virtualHost;    
     public String capabilities;    
     public boolean insist;    
-     
+    
+    public void setVirtualHost(String virtualHost) {
+    	this.virtualHost = virtualHost;
+   	}
+    public String getVirtualHost() {
+    	return this.virtualHost;
+   	}   	
+   	
+    public void setCapabilities(String capabilities) {
+    	this.capabilities = capabilities;
+   	}
+    public String getCapabilities() {
+    	return this.capabilities;
+   	}   	
+   	
+    public void setInsist(boolean insist) {
+    	this.insist = insist;
+   	}
+    public boolean getInsist() {
+    	return this.insist;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processConnectionOpenBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.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 knownHosts;    
-     
+    
+    public void setKnownHosts(String knownHosts) {
+    	this.knownHosts = knownHosts;
+   	}
+    public String getKnownHosts() {
+    	return this.knownHosts;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processConnectionOpenOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.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 host;    
     public String knownHosts;    
-     
+    
+    public void setHost(String host) {
+    	this.host = host;
+   	}
+    public String getHost() {
+    	return this.host;
+   	}   	
+   	
+    public void setKnownHosts(String knownHosts) {
+    	this.knownHosts = knownHosts;
+   	}
+    public String getKnownHosts() {
+    	return this.knownHosts;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processConnectionRedirectBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.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[] challenge;    
-     
+    
+    public void setChallenge(byte[] challenge) {
+    	this.challenge = challenge;
+   	}
+    public byte[] getChallenge() {
+    	return this.challenge;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processConnectionSecureBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureOkBody.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[] response;    
-     
+    
+    public void setResponse(byte[] response) {
+    	this.response = response;
+   	}
+    public byte[] getResponse() {
+    	return this.response;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processConnectionSecureOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartBody.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 FieldTable serverProperties;    
     public byte[] mechanisms;    
     public byte[] locales;    
-     
+    
+    public void setVersionMajor(short versionMajor) {
+    	this.versionMajor = versionMajor;
+   	}
+    public short getVersionMajor() {
+    	return this.versionMajor;
+   	}   	
+   	
+    public void setVersionMinor(short versionMinor) {
+    	this.versionMinor = versionMinor;
+   	}
+    public short getVersionMinor() {
+    	return this.versionMinor;
+   	}   	
+   	
+    public void setServerProperties(FieldTable serverProperties) {
+    	this.serverProperties = serverProperties;
+   	}
+    public FieldTable getServerProperties() {
+    	return this.serverProperties;
+   	}   	
+   	
+    public void setMechanisms(byte[] mechanisms) {
+    	this.mechanisms = mechanisms;
+   	}
+    public byte[] getMechanisms() {
+    	return this.mechanisms;
+   	}   	
+   	
+    public void setLocales(byte[] locales) {
+    	this.locales = locales;
+   	}
+    public byte[] getLocales() {
+    	return this.locales;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processConnectionStartBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartOkBody.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 mechanism;    
     public byte[] response;    
     public String locale;    
-     
+    
+    public void setClientProperties(FieldTable clientProperties) {
+    	this.clientProperties = clientProperties;
+   	}
+    public FieldTable getClientProperties() {
+    	return this.clientProperties;
+   	}   	
+   	
+    public void setMechanism(String mechanism) {
+    	this.mechanism = mechanism;
+   	}
+    public String getMechanism() {
+    	return this.mechanism;
+   	}   	
+   	
+    public void setResponse(byte[] response) {
+    	this.response = response;
+   	}
+    public byte[] getResponse() {
+    	return this.response;
+   	}   	
+   	
+    public void setLocale(String locale) {
+    	this.locale = locale;
+   	}
+    public String getLocale() {
+    	return this.locale;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processConnectionStartOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneBody.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 channelMax;    
     public long frameMax;    
     public int heartbeat;    
-     
+    
+    public void setChannelMax(int channelMax) {
+    	this.channelMax = channelMax;
+   	}
+    public int getChannelMax() {
+    	return this.channelMax;
+   	}   	
+   	
+    public void setFrameMax(long frameMax) {
+    	this.frameMax = frameMax;
+   	}
+    public long getFrameMax() {
+    	return this.frameMax;
+   	}   	
+   	
+    public void setHeartbeat(int heartbeat) {
+    	this.heartbeat = heartbeat;
+   	}
+    public int getHeartbeat() {
+    	return this.heartbeat;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processConnectionTuneBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneOkBody.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 channelMax;    
     public long frameMax;    
     public int heartbeat;    
-     
+    
+    public void setChannelMax(int channelMax) {
+    	this.channelMax = channelMax;
+   	}
+    public int getChannelMax() {
+    	return this.channelMax;
+   	}   	
+   	
+    public void setFrameMax(long frameMax) {
+    	this.frameMax = frameMax;
+   	}
+    public long getFrameMax() {
+    	return this.frameMax;
+   	}   	
+   	
+    public void setHeartbeat(int heartbeat) {
+    	this.heartbeat = heartbeat;
+   	}
+    public int getHeartbeat() {
+    	return this.heartbeat;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processConnectionTuneOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentBody.java Mon Oct 16 11:47:51 2006
@@ -24,9 +24,22 @@
     public static final byte TYPE = 3;
     public ByteSequence payload;
 
-    public byte getType()
+    public byte getFrameType()
     {
         return TYPE;
     }
+
+	public Object process(Visitor visitor) throws Exception {
+		return visitor.processContentBody(this);
+	}
+
+	public ByteSequence getPayload() {
+		return payload;
+	}
+
+	public void setPayload(ByteSequence payload) {
+		this.payload = payload;
+	}
+    
 
 }

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentHeaderBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentHeaderBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentHeaderBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentHeaderBody.java Mon Oct 16 11:47:51 2006
@@ -28,7 +28,7 @@
     /** must never be null */
     public ContentHeaderProperties properties;
         
-    public byte getType()
+    public byte getFrameType()
     {
         return TYPE;
     }
@@ -50,10 +50,40 @@
         this.bodySize = bodySize;
     }
 
-//
-//    public int getSize()
-//    {
-//        return 2 + 2 + 8 + 2 + properties.getPropertyListSize();
-//    }
+	public Object process(Visitor visitor) throws Exception {
+		return visitor.processContentHeaderBody(this);
+	}
+
+	public long getBodySize() {
+		return bodySize;
+	}
+
+	public void setBodySize(long bodySize) {
+		this.bodySize = bodySize;
+	}
+
+	public int getClassId() {
+		return classId;
+	}
+
+	public void setClassId(int classId) {
+		this.classId = classId;
+	}
+
+	public ContentHeaderProperties getProperties() {
+		return properties;
+	}
+
+	public void setProperties(ContentHeaderProperties properties) {
+		this.properties = properties;
+	}
+
+	public int getWeight() {
+		return weight;
+	}
+
+	public void setWeight(int weight) {
+		this.weight = weight;
+	}
 
 }

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectBody.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.processDtxSelectBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectOkBody.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.processDtxSelectOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartBody.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 dtxIdentifier;    
-     
+    
+    public void setDtxIdentifier(String dtxIdentifier) {
+    	this.dtxIdentifier = dtxIdentifier;
+   	}
+    public String getDtxIdentifier() {
+    	return this.dtxIdentifier;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processDtxStartBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartOkBody.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.processDtxStartOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareBody.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;
 
@@ -48,7 +48,76 @@
     public boolean internal;    
     public boolean nowait;    
     public FieldTable arguments;    
-     
+    
+    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 setType(String type) {
+    	this.type = type;
+   	}
+    public String getType() {
+    	return this.type;
+   	}   	
+   	
+    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 setAutoDelete(boolean autoDelete) {
+    	this.autoDelete = autoDelete;
+   	}
+    public boolean getAutoDelete() {
+    	return this.autoDelete;
+   	}   	
+   	
+    public void setInternal(boolean internal) {
+    	this.internal = internal;
+   	}
+    public boolean getInternal() {
+    	return this.internal;
+   	}   	
+   	
+    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.processExchangeDeclareBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareOkBody.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.processExchangeDeclareOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteBody.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 exchange;    
     public boolean ifUnused;    
     public boolean nowait;    
-     
+    
+    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 setIfUnused(boolean ifUnused) {
+    	this.ifUnused = ifUnused;
+   	}
+    public boolean getIfUnused() {
+    	return this.ifUnused;
+   	}   	
+   	
+    public void setNowait(boolean nowait) {
+    	this.nowait = nowait;
+   	}
+    public boolean getNowait() {
+    	return this.nowait;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processExchangeDeleteBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteOkBody.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.processExchangeDeleteOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileAckBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileAckBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileAckBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileAckBody.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 deliveryTag;    
     public boolean multiple;    
-     
+    
+    public void setDeliveryTag(long deliveryTag) {
+    	this.deliveryTag = deliveryTag;
+   	}
+    public long getDeliveryTag() {
+    	return this.deliveryTag;
+   	}   	
+   	
+    public void setMultiple(boolean multiple) {
+    	this.multiple = multiple;
+   	}
+    public boolean getMultiple() {
+    	return this.multiple;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processFileAckBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelBody.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.processFileCancelBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelOkBody.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.processFileCancelOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeBody.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;
 
@@ -46,7 +46,62 @@
     public boolean noAck;    
     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 setNoAck(boolean noAck) {
+    	this.noAck = noAck;
+   	}
+    public boolean getNoAck() {
+    	return this.noAck;
+   	}   	
+   	
+    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.processFileConsumeBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeOkBody.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.processFileConsumeOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileDeliverBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileDeliverBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileDeliverBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileDeliverBody.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 exchange;    
     public String routingKey;    
     public String identifier;    
-     
+    
+    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 setRedelivered(boolean redelivered) {
+    	this.redelivered = redelivered;
+   	}
+    public boolean getRedelivered() {
+    	return this.redelivered;
+   	}   	
+   	
+    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 setIdentifier(String identifier) {
+    	this.identifier = identifier;
+   	}
+    public String getIdentifier() {
+    	return this.identifier;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processFileDeliverBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenBody.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 identifier;    
     public long contentSize;    
-     
+    
+    public void setIdentifier(String identifier) {
+    	this.identifier = identifier;
+   	}
+    public String getIdentifier() {
+    	return this.identifier;
+   	}   	
+   	
+    public void setContentSize(long contentSize) {
+    	this.contentSize = contentSize;
+   	}
+    public long getContentSize() {
+    	return this.contentSize;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processFileOpenBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenOkBody.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 stagedSize;    
-     
+    
+    public void setStagedSize(long stagedSize) {
+    	this.stagedSize = stagedSize;
+   	}
+    public long getStagedSize() {
+    	return this.stagedSize;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processFileOpenOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FilePublishBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FilePublishBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FilePublishBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FilePublishBody.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 mandatory;    
     public boolean immediate;    
     public String identifier;    
-     
+    
+    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 void setIdentifier(String identifier) {
+    	this.identifier = identifier;
+   	}
+    public String getIdentifier() {
+    	return this.identifier;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processFilePublishBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosBody.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 long prefetchSize;    
     public int prefetchCount;    
     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 setGlobal(boolean global) {
+    	this.global = global;
+   	}
+    public boolean getGlobal() {
+    	return this.global;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processFileQosBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosOkBody.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.processFileQosOkBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileRejectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileRejectBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileRejectBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileRejectBody.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 deliveryTag;    
     public boolean requeue;    
-     
+    
+    public void setDeliveryTag(long deliveryTag) {
+    	this.deliveryTag = deliveryTag;
+   	}
+    public long getDeliveryTag() {
+    	return this.deliveryTag;
+   	}   	
+   	
+    public void setRequeue(boolean requeue) {
+    	this.requeue = requeue;
+   	}
+    public boolean getRequeue() {
+    	return this.requeue;
+   	}   	
+   	 
+    
+
+    public Object process(Visitor visitor) throws Exception
+    {
+        return visitor.processFileRejectBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileReturnBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileReturnBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileReturnBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileReturnBody.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.processFileReturnBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileStageBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileStageBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileStageBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileStageBody.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.processFileStageBody(this);
+    }
 
     public String toString()
     {

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/Frame.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/Frame.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/Frame.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/Frame.java Mon Oct 16 11:47:51 2006
@@ -21,5 +21,21 @@
 public abstract class Frame
 {
     public int channel;
-    public abstract byte getType();    
+    public abstract byte getFrameType();
+	abstract public Object process(Visitor visitor) throws Exception;
+    
+    public String toString() {
+        StringBuffer buf = new StringBuffer(getClass().toString());
+        buf.append(" type: ").append(getFrameType());
+        buf.append(" channel: ").append(channel);
+        return buf.toString();
+    }
+
+	public int getChannel() {
+		return channel;
+	}
+	public void setChannel(int channel) {
+		this.channel = channel;
+	}    
+    
 }

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/HeartbeatBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/HeartbeatBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/HeartbeatBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/HeartbeatBody.java Mon Oct 16 11:47:51 2006
@@ -21,9 +21,13 @@
 {
     public static final byte TYPE = 8;
 
-    public byte getType()
+    public byte getFrameType()
     {
         return TYPE;
     }
+
+	public Object process(Visitor visitor) throws Exception {
+		return visitor.processHeartbeatBody(this);
+	}
 
 }

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/MethodBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/MethodBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/MethodBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/MethodBody.java Mon Oct 16 11:47:51 2006
@@ -21,7 +21,7 @@
 {
     public static final byte TYPE = 1;    
 
-	public byte getType() {
+	public byte getFrameType() {
 		return TYPE;
 	}
 	
@@ -35,4 +35,10 @@
      */
     public abstract int getMethod();
 
+    public String toString() {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" class: ").append(getClazz());
+        buf.append(" method: ").append(getMethod());
+        return buf.toString();
+    }
 }



Mime
View raw message